??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
??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)
??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)
??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)