[
https://issues.apache.org/jira/browse/FLINK-40547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40547:
-----------------------------------
Labels: pull-request-available (was: )
> Add "Interpreting Flink's SQL Changelog" concepts page
> ------------------------------------------------------
>
> Key: FLINK-40547
> URL: https://issues.apache.org/jira/browse/FLINK-40547
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
> Reporter: Gustavo de Morais
> Assignee: Gustavo de Morais
> Priority: Major
> Labels: pull-request-available
>
> Adds a new docs page under Streaming SQL & Table Concepts explaining how to
> correctly read a Flink changelog stream ({{{}RowKind{}}}, changelog modes,
> and the primary-key-or-not consumer algorithm), with worked examples for
> keyed and keyless streams, partition-distribution behavior, and common
> pitfalls.
>
> We've seen multiple times the discussion about what is a valid changelog and
> what is not and by now we have a common understand of how we process our
> internal changelog. This place should consolidate it so it can be used as a
> reference by any consumer, connector, client, PTF developer etc
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
