The GitHub Actions job "CI" on fluss.git/support-flink-2.3 has failed.
Run started by GitHub user sd4324530 (triggered by sd4324530).

Head commit for run:
859d4b748dad024f4896f6cca4edd5b7d36e20be / Pei Yu <[email protected]>
[flink] Work around Flink 2.3 ON CONFLICT validation in Delta Join ITCase

Flink 2.3 introduces ExecutionConfigOptions.TABLE_EXEC_SINK_REQUIRE_ON_CONFLICT
(table.exec.sink.require-on-conflict), defaulting to true. In
FlinkChangelogModeInferenceProgram, this triggers a ValidationException
("upsert key differs from primary key") before the
StreamPhysicalDeltaJoinForceValidator runs, so the Delta Join ITCases can no
longer reach the original "doesn't support to do delta join optimization"
error path.

Disable the option in Flink23DeltaJoinITCase#beforeEach so the existing
assertions remain valid. Production-side impact (real Fluss users hitting
this on multi-table joins / group-by + insert) is left to community
discussion.

Signed-off-by: Pei Yu <[email protected]>

Report URL: https://github.com/apache/fluss/actions/runs/28217943805

With regards,
GitHub Actions via GitBox

Reply via email to