Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 1 addition & 7 deletions docs/content.zh/release-notes/flink-2.3.md
Original file line number Diff line number Diff line change
Expand Up @@ -90,17 +90,11 @@ CREATE FUNCTION my_func AS 'com.example.MyUdf'

Flink 2.3 reworks how `SinkUpsertMaterializer` handles the case where a query's upsert key
differs from the sink's primary key. Previously this required maintaining the full history of
records and could blow up state. Two changes address this:
records and could blow up state. A change partially addressed this issue:
Comment thread
RocMarshal marked this conversation as resolved.
Outdated

- A new `ON CONFLICT` clause with `DO NOTHING`, `DO ERROR` and `DO DEDUPLICATE` strategies makes
the behavior on key conflict explicit. By default, planning now fails when the upsert and
primary keys differ, requiring the user to choose a conflict strategy.
- Watermark-based record compaction is introduced to fix internal changelog disorder. The
trigger and frequency of compaction are controlled by:
- `table.exec.sink.upserts.compaction-mode` (default: `WATERMARK`) — `WATERMARK` or
`CHECKPOINT`.
- `table.exec.sink.upserts.compaction-interval` — optional fallback interval for emitting
watermarks when none arrive naturally.

#### Process Table Function enhancements

Expand Down
8 changes: 1 addition & 7 deletions docs/content/release-notes/flink-2.3.md
Original file line number Diff line number Diff line change
Expand Up @@ -90,17 +90,11 @@ CREATE FUNCTION my_func AS 'com.example.MyUdf'

Flink 2.3 reworks how `SinkUpsertMaterializer` handles the case where a query's upsert key
differs from the sink's primary key. Previously this required maintaining the full history of
records and could blow up state. Two changes address this:
records and could blow up state. A change partially addressed this issue:
Comment thread
RocMarshal marked this conversation as resolved.
Outdated
Comment thread
RocMarshal marked this conversation as resolved.
Outdated

- A new `ON CONFLICT` clause with `DO NOTHING`, `DO ERROR` and `DO DEDUPLICATE` strategies makes
the behavior on key conflict explicit. By default, planning now fails when the upsert and
primary keys differ, requiring the user to choose a conflict strategy.
- Watermark-based record compaction is introduced to fix internal changelog disorder. The
trigger and frequency of compaction are controlled by:
- `table.exec.sink.upserts.compaction-mode` (default: `WATERMARK`) — `WATERMARK` or
`CHECKPOINT`.
- `table.exec.sink.upserts.compaction-interval` — optional fallback interval for emitting
watermarks when none arrive naturally.

#### Process Table Function enhancements

Expand Down