This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 231bdf3 [hotfix][runtime] Remove unused method
ExecutionJobVertex#generateDebugString()
add 48bf9fb [FLINK-17093][python][table-planner][table-planner-blink] Fix
Python UDF to make it work with inputs from composite field (#11717)
No new revisions were added by this update.
Summary of changes:
.../rules/logical/PythonCorrelateSplitRule.java | 52 ++++---
.../plan/nodes/common/CommonPythonCorrelate.scala | 7 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 1 +
.../planner/plan/rules/FlinkStreamRuleSets.scala | 1 +
.../plan/rules/logical/PythonCalcSplitRule.scala | 111 ++++++++++-----
.../CalcPythonCorrelateTransposeRuleTest.xml | 8 +-
.../plan/rules/logical/PythonCalcSplitRuleTest.xml | 152 ++++++++++++++-------
.../rules/logical/PythonCorrelateSplitRuleTest.xml | 90 +++++++++---
.../rules/logical/PythonCalcSplitRuleTest.scala | 20 ++-
.../logical/PythonCorrelateSplitRuleTest.scala | 16 +++
.../rules/logical/PythonCorrelateSplitRule.java | 52 ++++---
.../table/plan/nodes/CommonPythonCorrelate.scala | 7 +-
.../flink/table/plan/rules/FlinkRuleSets.scala | 1 +
.../plan/rules/logical/PythonCalcSplitRule.scala | 111 ++++++++++-----
.../flink/table/plan/PythonCalcSplitRuleTest.scala | 73 ++++++++++
.../table/plan/PythonCorrelateSplitRuleTest.scala | 75 ++++++++++
16 files changed, 591 insertions(+), 186 deletions(-)
