Skip to content

Commit 89db61f

Browse files
committed
simplify description for upsert key and link vv blog
1 parent c243865 commit 89db61f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

website/docs/engine-flink/delta-joins.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ There is a known issue ([FLINK-38399](https://issues.apache.org/jira/browse/FLIN
160160
- The join must be a INNER join.
161161
- The downstream nodes of the join can accept duplicate changes, such as a sink that provides UPSERT mode without `upsertMaterialize`.
162162
- When the pk of the sink does not align with (or does not include) the upstream upsert key, the sink will produce a sink materialization (called `upsertMaterialize`).
163-
- In Flink, an upsert key is formed when the update history order of unique keys is maintained. This allows for the recognition of record updates and inserts during stream processing, and enables downstream operators to accurately track the update history for the efficient handling of both update-before and update-after records.
163+
- About upsert key and `upsertMaterialize`, more details can be found in this [blog](https://www.ververica.com/blog/flink-sql-secrets-mastering-the-art-of-changelog-events).
164164
- All join inputs should be INSERT-ONLY streams.
165165
- This is why the option `'table.merge-engine' = 'first_row'` is added to the source table DDL.
166166
- All upstream nodes of the join should be `TableSourceScan` or `Exchange`.
@@ -181,7 +181,7 @@ There is a known issue ([FLINK-38399](https://issues.apache.org/jira/browse/FLIN
181181
- The join must be a INNER join.
182182
- The downstream nodes of the join can accept duplicate changes, such as a sink that provides UPSERT mode without `upsertMaterialize`.
183183
- When the pk of the sink does not align with (or does not include) the upstream upsert key, the sink will produce a sink materialization (called `upsertMaterialize`).
184-
- In Flink, an upsert key is formed when the update history order of unique keys is maintained. This allows for the recognition of record updates and inserts during stream processing, and enables downstream operators to accurately track the update history for the efficient handling of both update-before and update-after records.
184+
- About upsert key and `upsertMaterialize`, more details can be found in this [blog](https://www.ververica.com/blog/flink-sql-secrets-mastering-the-art-of-changelog-events).
185185
- When consuming a CDC stream, the join key used in the delta join must be part of the primary key.
186186
- All filters must be applied on the upsert key, and neither filters nor projections should contain non-deterministic functions.
187187

0 commit comments

Comments
 (0)