This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from bc964a102a8 [FLINK-32632][test] Downloads binaries for cri-dockerd to
avoid building the binaries using Go
add bff837622dd [FLINK-32279][table-runtime] Shuffle HashJoin support
spill to disk when enable operator fusion codegen
add a0a66d70398 [FLINK-32279][table-runtime] Add plan test for
MulitpleInput support one-input node as root when operator fusion codegen
enabled
No new revisions were added by this update.
Summary of changes:
.../plan/fusion/spec/CalcFusionCodegenSpec.scala | 2 +
.../fusion/spec/HashJoinFusionCodegenSpec.scala | 289 +++++++++++++--------
.../plan/batch/sql/OperatorFusionCodegenTest.xml | 203 +++++++++++++++
.../plan/batch/sql/OperatorFusionCodegenTest.scala | 105 ++++++++
.../batch/sql/OperatorFusionCodegenITCase.scala | 60 +++--
.../runtime/hashtable/LongHybridHashTable.java | 36 ++-
6 files changed, 557 insertions(+), 138 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/OperatorFusionCodegenTest.xml
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/OperatorFusionCodegenTest.scala
