[
https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-35889:
----------------------------------
Assignee: yux
> 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
> Assignee: yux
> 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)
