This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 90fed72 [FLINK-17345][python][table] Support register and get Python
UDF in Catalog (#11884)
add deb1268 [FLINK-17021][table-planner-blink] Blink batch planner set
GlobalDataExchangeMode
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 6 +-
.../apache/flink/table/tpcds/TpcdsTestProgram.java | 3 -
.../table/api/config/ExecutionConfigOptions.java | 39 ++++++++--
.../flink/table/planner/utils/ExecutorUtils.java | 23 ++----
.../table/planner/utils/ShuffleModeUtils.java | 55 ++++++++++++++
.../nodes/physical/batch/BatchExecExchange.scala | 4 +-
.../table/planner/utils/ShuffleModeUtilsTest.java | 86 ++++++++++++++++++++++
.../planner/runtime/utils/BatchTestBase.scala | 6 +-
.../flink/table/planner/utils/TableTestBase.scala | 6 +-
9 files changed, 197 insertions(+), 31 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/ShuffleModeUtils.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils/ShuffleModeUtilsTest.java
