[
https://issues.apache.org/jira/browse/FLINK-40894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40894:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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)
