Flink sql之hive catalog踩雷記

先上代碼: val streamEnv = StreamExecutionEnvironment.getExecutionEnvironment streamEnv.setParallelism(5) streamEnv.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime) val tableEnvSettings = En
相關文章
相關標籤/搜索