You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by wa...@apache.org on 2023/08/28 01:42:42 UTC
[flink] branch master updated (4b84b6cd598 -> a68dd419718)
This is an automated email from the ASF dual-hosted git repository.
wanglijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4b84b6cd598 [FLINK-32731][e2e] Add retry mechanism when fails to start the namenode (#23267)
add 43bcf319ff6 [hotfix][table-planner] Fix the wrong traitSet and inputs in runtime filter related exec node
add f518f8a5bdf [FLINK-32831][table-planner] RuntimeFilterProgram should aware join type when looking for the build side
add 07888af59bb [FLINK-32831][table-planner] Adjust default value of max build data size of runtime filter to cover more cases
add a68dd419718 [FLINK-32831][table-planner] Add check to ensure all tests in RuntimeFilterITcase have applied runtime filter.
No new revisions were added by this update.
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(-)