THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setRuntimeMode(RuntimeMode.BATCH);
Configuration conf = new Configuration();
conf.setString("execution.shuffle-mode", "ALL_EDGES_BLOCKING");
env.configure(conf);
As a configuration option named execution.mode
.This will allow users to use it through:
- the environment constructors,
- through the CLI, and
- through the
env.configure()
method.
Rejected Alternative: An alternative could be to expose it through the executionConfig
or directly in the Environments but those were rejected because we can achieve the same through a configuration option.
Processing Time Support in Batch
...