Hi to all, I was trying to update my legacy code to Flink 1.11. Before I was using a BatchTableEnv and now I've tried to use the following:
EnvironmentSettings settings = EnvironmentSettings.newInstance().inBatchMode().build(); Unfortunately in the StreamTableEnvironmentImpl code there's : if (!settings.isStreamingMode()) { throw new TableException( "StreamTableEnvironment can not run in batch mode for now, please use TableEnvironment."); } What should I do here? Thanks in advance, Flavio