Darren_Han created FLINK-35889:
----------------------------------
Summary: 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
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)
