You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "sukang (Jira)" <ji...@apache.org> on 2025/01/10 09:15:00 UTC
[jira] [Updated] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year
[ https://issues.apache.org/jira/browse/FLINK-37096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
sukang updated FLINK-37096:
---------------------------
Description:
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=659,height=258,id=u750186d3!
was:
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!
> 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
> Priority: Minor
> Original Estimate: 612h
> Remaining Estimate: 612h
>
> 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=659,height=258,id=u750186d3!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)