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

Posted to dev@flink.apache.org by "Marton Greber (Jira)" <ji...@apache.org> on 2025/10/27 11:05:00 UTC

[jira] [Created] (FLINK-38575) Checkpoint Race Condition in KuduSourceEnumerator

Marton Greber created FLINK-38575:
-------------------------------------

             Summary: Checkpoint Race Condition in KuduSourceEnumerator
                 Key: FLINK-38575
                 URL: https://issues.apache.org/jira/browse/FLINK-38575
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kudu
    Affects Versions: 2.0.0
            Reporter: Marton Greber
             Fix For: 2.1.0


KuduSourceEnumerator violates Flink's documented CheckpointListener pattern[1] by mutating state immediately in handleSourceEvent() instead of deferring until notifyCheckpointComplete(). This creates a race condition where splits are removed from state before records are durable, causing data loss on crash.

[1]: [https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/state/CheckpointListener.java]



--
This message was sent by Atlassian Jira
(v8.20.10#820010)