This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 64b430b0738 [hotfix][python] Refactor thread mode Python runtime to
make it more readable
add 1719ff85b8e [FLINK-28871][table-planner] Force the output edges of
dynamic filtering data collector to be BLOCKING
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/batch/BatchExecTableSourceScan.java | 43 +-
.../DynamicFilteringDependencyProcessor.java | 120 +++
.../plan/batch/sql/DynamicFilteringTest.java | 28 +
.../runtime/batch/sql/DynamicFilteringITCase.java | 57 +-
.../plan/batch/sql/DynamicFilteringTest.xml | 920 ++++++++++++++++++---
5 files changed, 1026 insertions(+), 142 deletions(-)
