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