I encountered a similar issue as yours. The root cause was that I was writing a batch job, but my StreamTableEnvironment was not configured for batch mode. After I changed it to StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, EnvironmentSettings.newInstance().inBatchMode().build());, the problem was resolved.