Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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 

...