This is an automated email from the ASF dual-hosted git repository.
gustavodemorais pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 769d9fe34d5 [FLINK-40905][rpc] Bump Pekko to 1.7.1
add 0c619470086 [FLINK-40841][table] Non-equi joins fix: retract the
matches that a replaced record loses
add 5afe863af62 [FLINK-40858][table] Non-equi joins fix: join key-only
deletes with the stored record
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/stream/StreamExecJoin.java | 43 +++
.../stream/StreamExecProcessTableFunction.java | 2 +-
.../nodes/physical/stream/StreamPhysicalJoin.scala | 4 +-
.../plan/nodes/exec/common/JoinTestPrograms.java | 110 +++++++
.../plan/nodes/exec/stream/JoinRestoreTest.java | 5 +-
.../join-inner-join-key-only-deletes-non-equi.json | 260 +++++++++++++++
.../savepoint/_metadata | Bin 0 -> 11862 bytes
...n-left-join-upsert-input-non-equi-pre-2-4.json} | 174 +++++-----
.../savepoint/_metadata | Bin 0 -> 15576 bytes
.../join-left-join-upsert-input-non-equi.json} | 177 ++++++-----
.../savepoint/_metadata | Bin 0 -> 15736 bytes
.../planner/runtime/stream/sql/JoinITCase.scala | 88 ++++--
.../stream/MiniBatchStreamingJoinOperator.java | 45 ++-
.../join/stream/StreamingJoinOperator.java | 266 +++++++++++++---
.../join/stream/state/JoinRecordStateView.java | 9 +-
.../join/stream/state/JoinRecordStateViews.java | 12 +-
.../stream/state/OuterJoinRecordStateViews.java | 15 +-
.../process/AbstractProcessTableOperator.java | 1 +
.../operators/process/ProcessRowTableOperator.java | 1 +
.../operators/process/ProcessSetTableOperator.java | 1 +
.../process/ProcessTableOperatorFactory.java | 1 +
.../operators/process/RuntimeTableSemantics.java | 1 +
.../process => util}/RuntimeChangelogMode.java | 2 +-
.../join/stream/StreamingJoinOperatorTest.java | 350 ++++++++++++++++++++-
.../join/stream/StreamingJoinOperatorTestBase.java | 30 ++
.../stream/StreamingMiniBatchJoinOperatorTest.java | 88 +++++-
...essSetTableOperatorInterruptibleTimersTest.java | 1 +
27 files changed, 1420 insertions(+), 266 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-inner-join-key-only-deletes-non-equi/plan/join-inner-join-key-only-deletes-non-equi.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-inner-join-key-only-deletes-non-equi/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/{join-inner-join-with-non-equi-join/plan/join-inner-join-with-non-equi-join.json
=>
join-left-join-upsert-input-non-equi-pre-2-4/plan/join-left-join-upsert-input-non-equi-pre-2-4.json}
(53%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-left-join-upsert-input-non-equi-pre-2-4/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/{join-inner-join-with-non-equi-join/plan/join-inner-join-with-non-equi-join.json
=>
join-left-join-upsert-input-non-equi/plan/join-left-join-upsert-input-non-equi.json}
(51%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-left-join-upsert-input-non-equi/savepoint/_metadata
rename
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/{operators/process
=> util}/RuntimeChangelogMode.java (97%)
