Flink sql之hive catalog踩雷记

先上代码: val streamEnv = StreamExecutionEnvironment.getExecutionEnvironment streamEnv.setParallelism(5) streamEnv.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime) val tableEnvSettings = En
相关文章
相关标签/搜索