This is an automated email from the ASF dual-hosted git repository.
wanglijie pushed a change to branch release-1.18
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1b250f7128a [FLINK-32869][e2e] Fix Kubernetes tests on aarch64
new ac3f3cf4802 [hotfix][table-planner] Fix the wrong traitSet and inputs
in runtime filter related exec node
new e48a0262834 [FLINK-32831][table-planner] RuntimeFilterProgram should
aware join type when looking for the build side
new 6938b928e01 [FLINK-32831][table-planner] Adjust default value of max
build data size of runtime filter to cover more cases
new fa2ab5e3bfe [FLINK-32831][table-planner] Add check to ensure all
tests in RuntimeFilterITcase have applied runtime filter.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../generated/optimizer_config_configuration.html | 2 +-
.../table/api/config/OptimizerConfigOptions.java | 2 +-
.../BatchPhysicalGlobalRuntimeFilterBuilder.java | 4 +-
.../BatchPhysicalLocalRuntimeFilterBuilder.java | 4 +-
.../runtimefilter/BatchPhysicalRuntimeFilter.java | 6 +-
.../program/FlinkRuntimeFilterProgram.java | 67 +++++---
.../program/FlinkRuntimeFilterProgramTest.java | 69 ++++++++
.../runtime/batch/sql/RuntimeFilterITCase.java | 19 ++-
.../program/FlinkRuntimeFilterProgramTest.xml | 174 ++++++++++++++++++---
9 files changed, 296 insertions(+), 51 deletions(-)
