2022-05-07 c307bc4c93e71c200165f4a22988a191 99+ fast 0.1 k0 visits

流批选择

之前版本

//流
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//批
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

现在版本

通过执行模式 execution mode选择

1 流处理 streaming 默认

2 批处理 batch

3 自动 automatic

（1）通过命令行

1	flink run -Dexecution.runtime-mode=BATCH/../..

（2）代码

1
2
3

env.setRuntimeMode(RuntimeExecutionMode.STREAMING);
       env.setRuntimeMode(RuntimeExecutionMode.BATCH);
       env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);

流批选择

http://example.com/2022/05/07/flink-batch-stream/