This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git
from 51eedac476e [FLINK-39073][runtime] Test split state timers during
deferred alignment check
new e329f33c34b [FLINK-38916][table-planner] MultiJoin produces incorrect
results for OR join conditions when parallelism is greater than 1
new f64c549aeea [FLINK-38417][table-planner] Ensure attribute ordering
when managing join attributes in JoinKeyExtractor
new a6082b3d20b [FLINK-38445][table] Upsert keys test plans without
sinkMaterialize
new ef1952c7841 [FLINK-39015][table] Fix key extractor for multi join by
changing GenericRowData to BinaryRowData
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../table/planner/plan/utils/MultiJoinUtil.java | 10 +-
.../nodes/exec/stream/MultiJoinSemanticTests.java | 6 +-
.../nodes/exec/stream/MultiJoinTestPrograms.java | 744 +++++++++++++++++++--
.../planner/plan/stream/sql/MultiJoinTest.xml | 259 +++----
.../planner/runtime/stream/sql/JoinITCase.scala | 17 +
.../join/stream/StreamingMultiJoinOperator.java | 10 +
.../AttributeBasedJoinKeyExtractor.java | 728 ++++++++++++++------
.../join/stream/keyselector/JoinKeyExtractor.java | 3 +
.../table/runtime/typeutils/RowDataSerializer.java | 6 +-
...StreamingFourWayMixedOuterJoinOperatorTest.java | 12 +-
.../StreamingMultiJoinOperatorTestBase.java | 1 +
11 files changed, 1422 insertions(+), 374 deletions(-)
