You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ga...@apache.org on 2022/08/09 15:33:56 UTC

[flink] branch master updated (64b430b0738 -> 1719ff85b8e)

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