This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7a0c38b [FLINK-19078][table-runtime] Support row time temporal table
join in runtime
add a4cbe71 [FLINK-19870][table-planner] Fix special case when the reuse
of exchange causes the deadlock
No new revisions were added by this update.
Summary of changes:
.../processors/utils/InputOrderCalculator.java | 2 +-
.../utils/InputPriorityConflictResolver.java | 24 +++--
.../utils/InputPriorityGraphGenerator.java | 4 +-
.../utils/InputPriorityConflictResolverTest.java | 41 ++++++++
.../utils/InputPriorityGraphGeneratorTest.java | 2 +-
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 115 +++++++++++++--------
.../planner/plan/batch/sql/SetOperatorsTest.xml | 7 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 7 +-
.../plan/batch/sql/DeadlockBreakupTest.scala | 15 +++
9 files changed, 158 insertions(+), 59 deletions(-)
