??????flink sql hive streaming??????????????????bug

2020-11-15 文章 Excalibur
??hive table read       blinkStreamTableEnv.getConfig().getConfiguration().setBoolean("table.dynamic-table-options.enabled", true);       Table table=blinkStreamTableEnv.sqlQuery("SELECT * FROM test.table_config /*+ OPTIONS('streaming-source.enable'='true','streaming-source.monitor-inte

flink sql hive streaming??????????????????bug

2020-11-15 文章 Excalibur
??1.11.2 ??java.lang.IllegalArgumentException: The ContinuousFileMonitoringFunction has already restored from a previous Flink version.     at org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction.initializeState(ContinuousFileMonitoringFunction.java:176)  

flink sql hive streaming??????????????????bug

2020-11-15 文章 Excalibur
??1.11.2 ??java.lang.IllegalArgumentException: The ContinuousFileMonitoringFunction has already restored from a previous Flink version.     at org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction.initializeState(ContinuousFileMonitoringFunction.java:176)   

flink sql hive streaming??????????????????bug

2020-11-15 文章 Excalibur
??1.11.2 ??java.lang.IllegalArgumentException: The ContinuousFileMonitoringFunction has already restored from a previous Flink version. at org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction.initializeState(ContinuousFileMonitoringFunction.java:176)