Caused by: com.mongodb.MongoCommandException: Command failed with error 280 (ChangeStreamFatalError): 'cannot resume stream; the resume token was not found. {_data: "8263AEB0210000003B2B022C0100296E5A1004E28F30E3685F4772819381BF6E9E239E46645F6964006463AEB021753B52459B6D54530004"}' on server 172.17.11.95:3717. The full response is {"errorLabels": ["NonResumableChangeStreamError"], "operationTime": {"$timestamp": {"t": 1672392737, "i": 71}}, "ok": 0.0, "errmsg": "cannot resume stream; the resume token was not found. {_data: "8263AEB0210000003B2B022C0100296E5A1004E28F30E3685F4772819381BF6E9E239E46645F6964006463AEB021753B52459B6D54530004"}", "code": 280, "codeName": "ChangeStreamFatalError", "$clusterTime": {"clusterTime": {"$timestamp": {"t": 1672392737, "i": 71}}, "signature": {"hash": {"$binary": {"base64": "XdkUEuKqvsjum7+fD7Ap0KBsKaI=", "subType": "00"}}, "keyId": 7153074040700141670}}} at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:195)
此错误表明您正在尝试将 BsonDocument 转换为 BsonArray,这是不可能的。BsonDocument 和 BsonArray 是两种不同的 BSON 类型,不能相互转换。
可能的解决方案:
检查您的代码以确保您尝试转换的文档实际上是 BsonArray。
如果您确定文档是 BsonDocument,则需要更改代码以处理 BsonDocument。
其他信息:
BsonDocument 表示一个 JSON 文档,它是一个键值对集合。
BsonArray 表示一个 JSON 数组,它是一个元素集合。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。