[
https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868311#comment-17868311
]
Jiabao Sun edited comment on FLINK-35889 at 7/24/24 9:36 AM:
-------------------------------------------------------------
Hi [~xiqian_yu], could you help investigate this?
was (Author: JIRAUSER304154):
Hi @yux, could you help investigate this?
> mongo cdc restore from expired resume token and job status still running but
> expect failed
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-35889
> URL: https://issues.apache.org/jira/browse/FLINK-35889
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.1.0
> Reporter: Darren_Han
> Priority: Blocker
>
> version
> mongodb: 3.6
> flink: 1.14.6
> mongo-cdc:2.4.2
>
> Restarting job from a savepoint/checpoint which contains expired resume
> token/point, job status is always running and do not capture change data,
> printing logs continuously.
> Here is some example logs:
> 2024-07-23 11:11:04,214 INFO
> com.mongodb.kafka.connect.source.MongoSourceTask [] - An
> exception occurred when trying to get the next item from the Change Stream
> com.mongodb.MongoQueryException: Query failed with error code 280 and error
> message 'resume of change stream was not possible, as the resume token was
> not found. \{_data: BinData(0, "xxxxxx")}'
> 2024-07-23 17:53:27,330 INFO
> com.mongodb.kafka.connect.source.MongoSourceTask [] - An
> exception occurred when trying to get the next item from the Change Stream
> com.mongodb.MongoQueryException: Query failed with error code 280 and error
> message 'resume of change notification was not possible, as the resume point
> may no longer be in the oplog. ' on server
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
