[jira] [Created] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year

Fri, 10 Jan 2025 01:16:14 -0800 

sukang created FLINK-37096:
------------------------------

             Summary: If the MongoDB connector is implemented with 
DebeziumSourceFunction, the curve will appear in the full phase delay curve 
showing 55year
                 Key: FLINK-37096
                 URL: https://issues.apache.org/jira/browse/FLINK-37096
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / MongoDB
    Affects Versions: cdc-3.2.1
            Reporter: sukang


emitDelay =isInDbSnapshotPhase ? 0L : System.currentTimeMillis() - 
messageTimestamp;
In the full phase, messageTimestamp is 0 which will cause an exception here 
when we compute it.
!https://intranetproxy.alipay.com/skylark/lark/0/2025/png/109956362/1736480972716-696877e2-e202-454d-bee4-947944159891.png|width=1053,id=u750186d3!



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

Reply via email to