You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/09/03 15:30:00 UTC

[jira] [Created] (FLINK-40547) Add "Interpreting Flink's SQL Changelog" concepts page

Gustavo de Morais created FLINK-40547:
-----------------------------------------

             Summary: 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


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)