[
https://issues.apache.org/jira/browse/FLINK-35889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868347#comment-17868347
]
yux edited comment on FLINK-35889 at 7/24/24 12:08 PM:
-------------------------------------------------------
Sure, I noticed that such behaviour could be controlled by
`MongoSourceTask#sourceConfig#tolerateErrors` configuration. Could you please
share more information about your configuration, like are you setting
`errors.tolerance` to `none`?
was (Author: JIRAUSER300787):
Sure, I noticed that such behaviour could be controlled by
`MongoSourceTask#sourceConfig#tolerateErrors` configuration. Should we add a
new option for 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)
