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

Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:14:00 UTC

[jira] [Created] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper

Martijn Visser created FLINK-40894:
--------------------------------------

             Summary: Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper
                 Key: FLINK-40894
                 URL: https://issues.apache.org/jira/browse/FLINK-40894
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Runtime
            Reporter: Martijn Visser


Both SinkUpsertMaterializer and KeyedLookupJoinWrapper only log when a retraction finds no matching row or when state was cleared by TTL. Wrong results from non-deterministic updates or a too short TTL are therefore invisible in metrics. LateralSnapshotJoinOperator already exposes {{numUnmatchedBuildRetractions}} for the same situation. We should add the same counter to both operators, the V2 and the watermark compacting materializer included.



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