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

Reply via email to