Nafer Sanabria
08/20/2024, 10:17 AM$FLINK_HOME/bin/flink run -Dexecution.runtime-mode=STREAMING -c com.example.DataStreamJob target/flink-poc-1.0.jar
I also tried by explicitly setting the runtime in the env
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setRuntimeMode(RuntimeExecutionMode.STREAMING);
but it did not work because the job finishes in a couple of seconds. The test I want to perform is by copying a new file into the directory and check that the file is being processed
What am I missing ? Any hints ?Nafer Sanabria
08/20/2024, 11:02 AMenv#readTextFile(String)
instead of env#readFile(FileInputFormat<OUT>, String, FileProcessingMode, long, TypeInformation<OUT>)
with FileProcessingMode.PROCESS_CONTINUOUSLY