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

Head commit for run:
018112e5113c04bc1d494596f11a89ecb3760ee6 / Pei Yu <[email protected]>
[flink] Work around Flink 2.3 ON CONFLICT validation in Table Sink 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 partial-update handling
in FlinkTableSink#getSinkRuntimeProvider runs, so the partial upsert ITCases
(testPartialUpsert and testPartialUpsertDuringAddColumn) in
FlinkTableSinkITCase can no longer reach the Fluss sink layer.

Disable the option in Flink23TableSinkITCase#beforeEach so the existing
partial-upsert assertions remain valid.

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

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

With regards,
GitHub Actions via GitBox

Reply via email to