Hi guys. I am using Flink 1.15 DataStream api to do ETL job. I want to set my job as BATCH execution mode, so I use code provided in official webstie.

env.setRuntimeMode(RuntimeExecutionMode.BATCH);

However, I encountered the following error when I run in Kineses Data Analytics:

java.lang.UnsupportedOperationException at <http://org.apache.flink.runtime.io|org.apache.flink.runtime.io>.network.partition.ResultPartition.getAllDataProcessedFuture(ResultPartition.java:233)

My whole code logic

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

DataStream<String> text = env.readTextFile("file:///path/to/file");

env.setRuntimeMode(RuntimeExecutionMode.BATCH);

DataStream<OutputType> result = text
.map(/* map logic here */ )
.keyBy(/* keyby logic here */)
.reduce(/* reduce logic here */)

result.writeAsText("filePath")

Can I know why the error happen? which part has "`UnsupportedOperationException` "? Thanks in advance!❤️