THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- The general option for choosing the overall runtime mode
- we will expose it via a configuration under the
execution.runtime-mode
key with an enum value BATCH/STREAM/AUTOMATIC - through StreamExecutionEnvironment#setRuntimeMode(RuntimeMode mode)
- each of the particular modes will set default values of other settings such as ScheduleMode, ShuffleMode, buffer timeout, etc. It will be possible to override the defaults for particular options, but only as long as the value is compatible chosen mode, e.g. shuffle-mode other than ALL_EDGED_PIPELINED is illegal for STREAM mode. Illegal combinations will result in an exception.
- we will expose it via a configuration under the
- An option for choosing the shuffle-mode
- exposed only through a configuration option under the
execution.shuffle-mode
key. We will not expose a dedicated setter in StreamExecutionEnvironment, or ExecutionConfig
- exposed only through a configuration option under the
Examples:
Users will be able to choose BATCH mode:
...