This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fdde1e4 [FLINK-23471][checkpoint] Try best to ensure all operators
and state manager handle the checkpoint complete notification
add 0139222 [FLINK-23402][streaming-java] Default to
GlobalStreamExchangeMode.ALL_EDGES_BLOCKING in batch mode
add a78f34a [FLINK-23402][streaming-java][table-planner] Add ShuffleMode
option
add bfcf9a1 [hotfix][docs] Regenerate options
No new revisions were added by this update.
Summary of changes:
.../generated/cluster_configuration.html | 4 +-
.../execution_checkpointing_configuration.html | 4 +-
.../generated/execution_config_configuration.html | 10 +-
.../generated/execution_configuration.html | 8 +-
.../generated/expert_cluster_section.html | 4 +-
.../generated/expert_scheduling_section.html | 2 +-
.../generated/influxdb_reporter_configuration.html | 4 +-
.../generated/job_manager_configuration.html | 2 +-
.../generated/kubernetes_config_configuration.html | 4 +-
.../generated/pipeline_configuration.html | 2 +-
.../rocksdb_configurable_configuration.html | 4 +-
.../generated/rocksdb_configuration.html | 2 +-
.../generated/sql_client_configuration.html | 2 +-
.../generated/state_backend_rocksdb_section.html | 2 +-
.../generated/stream_pipeline_configuration.html | 2 +-
.../generated/yarn_config_configuration.html | 2 +-
.../org/apache/flink/api/common/ShuffleMode.java | 94 +++++++++++++++++++
.../flink/configuration/ExecutionOptions.java | 36 ++++++-
.../apache/flink/table/tpcds/TpcdsTestProgram.java | 1 +
.../environment/StreamExecutionEnvironment.java | 29 ++----
.../streaming/api/graph/StreamGraphGenerator.java | 104 ++++++++++++++++-----
.../StreamGraphGeneratorBatchExecutionTest.java | 75 ++++++++++++++-
...amGraphGeneratorExecutionModeDetectionTest.java | 15 +--
.../api/graph/StreamingJobGraphGeneratorTest.java | 4 +-
.../gateway/context/ExecutionContextTest.java | 5 +-
.../table/api/config/ExecutionConfigOptions.java | 5 +-
.../plan/nodes/exec/batch/BatchExecExchange.java | 21 +----
.../utils/InputPriorityConflictResolver.java | 5 +-
.../flink/table/planner/utils/ExecutorUtils.java | 25 +++--
.../flink/table/planner/utils/ShortcutUtils.java | 5 +
.../planner/utils/StreamExchangeModeUtils.java | 62 +++++++++---
.../physical/batch/BatchPhysicalExchange.scala | 19 +---
.../planner/utils/StreamExchangeModeUtilsTest.java | 82 +++++++++-------
.../plan/batch/sql/MultipleInputCreationTest.xml | 68 +++++++-------
.../plan/batch/sql/MultipleInputCreationTest.scala | 10 +-
.../runtime/batch/sql/MultipleInputITCase.scala | 12 ++-
.../planner/runtime/utils/BatchTestBase.scala | 10 +-
.../flink/table/planner/utils/TableTestBase.scala | 9 +-
38 files changed, 516 insertions(+), 238 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/ShuffleMode.java
