fresh-borzoni opened a new pull request, #2268: URL: https://github.com/apache/fluss/pull/2268
### Purpose Linked issue: close #2231 Add comprehensive test coverage for Delta Join feature in Flink 2.2 and improve documentation. ### Brief change log - Added tests for normal PK tables with `table.delete.behavior=IGNORE` (not just `first_row` merge engine) - Added tests for joining on bucket key (not just full primary key) - Added tests verifying LEFT/RIGHT/FULL OUTER joins fail with appropriate validation error - Added test verifying cascade joins are not supported - Updated documentation for Flink 2.2 Delta Join with new supported features and limitations ### Tests <!-- List UT and IT cases to verify this change --> - `testDeltaJoinWithPrimaryKeyTableNoDeletes` - normal PK table with `delete.behavior=IGNORE` - `testDeltaJoinOnBucketKey` - join on bucket key only - `testDeltaJoinFailsWhenFilterOnNonUpsertKeys` - filter on non-upsert-key columns fails - `testDeltaJoinOnBucketKey` - join on bucket key only (not full PK) - `testDeltaJoinFailsWhenSourceHasDelete` - source with DELETE records fails - `testDeltaJoinFailsWhenJoinKeyNotContainIndex` - join key not containing index fail - `testDeltaJoinFailsWithLeftJoin` - LEFT JOIN wouldn't be converted to DeltaJoin - `testDeltaJoinFailsWithRightJoin` - RIGHT JOIN wouldn't be converted to DeltaJoin - `testDeltaJoinFailsWithFullOuterJoin` - FULL OUTER JOIN wouldn't be converted to DeltaJoin - `testDeltaJoinFailsWithCascadeJoin` - cascade join wouldn't be converted to DeltaJoin ### API and Format <!-- Does this change affect API or storage format --> No ### Documentation <!-- Does this change introduce a new feature --> Yes - updated `docs/engine-flink/delta-joins.md` with Flink 2.2 part. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
