执行mongodbcdc报：Caused by: com.mongodb.MongoCommandException: Command failed with error 260 (InvalidResumeToken) #2226
Unanswered
MonsterChenzhuo
asked this question in
Q&A
Replies: 1 comment
-
|
For MongoDB 4.0, CDC will use For MongoDB version 4.2 and above, CDC will try to use new |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
mongodb版本：4.0.3
flink版本：1.14.5
flink cdc版本：2.3.0
mongodb权限设置：
大佬您好请问下mongodbcdc执行后报如下错误是什么原因导致的：
Caused by: org.apache.flink.util.FlinkRuntimeException: Read split SnapshotSplit{tableId=resblock.resb_image, splitId='resblock.resb_image:1', splitKeyType=[
_idINT], splitStart=[{"_id": 1}, {"_id": {"$oid": "60b9e9f668f16f000866b924"}}], splitEnd=[{"_id": 1}, {"_id": {"$oid": "60b9ea0c68f16f00086731d6"}}], highWatermark=null} error due to Open change stream failed.Caused by: org.apache.flink.util.FlinkRuntimeException: Open change stream failed
Caused by: com.mongodb.MongoCommandException: Command failed with error 260 (InvalidResumeToken): 'Attempted to resume a stream on a collection which has been dropped. The change stream's pipeline may need to make comparisons which should respect the collection's default collation, which can no longer be determined. If you wish to resume this change stream you must specify a collation with the request.' on server 10.216.26.59:27017. The full response is {"operationTime": {"$timestamp": {"t": 1687325301, "i": 1}}, "ok": 0.0, "errmsg": "Attempted to resume a stream on a collection which has been dropped. The change stream's pipeline may need to make comparisons which should respect the collection's default collation, which can no longer be determined. If you wish to resume this change stream you must specify a collation with the request.", "code": 260, "codeName": "InvalidResumeToken", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1687325301, "i": 1}}, "signature": {"hash": {"$binary": {"base64": "Y2PdYDUS01/IFfgr8KIQh1DKSwE=", "subType": "00"}}, "keyId": 7210220251315699716}}}
Beta Was this translation helpful? Give feedback.
All reactions