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(-)