开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

环境mongdb cdc 2.3 + flink16 这个是什么错误啊?

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)

展开
收起
爱喝咖啡嘿 2023-01-03 16:25:23 310 0
1 条回答
写回答
取消 提交回答
  • 此错误表明您正在尝试将 BsonDocument 转换为 BsonArray,这是不可能的。BsonDocument 和 BsonArray 是两种不同的 BSON 类型,不能相互转换。

    可能的解决方案:

    检查您的代码以确保您尝试转换的文档实际上是 BsonArray。
    如果您确定文档是 BsonDocument,则需要更改代码以处理 BsonDocument。
    其他信息:

    BsonDocument 表示一个 JSON 文档,它是一个键值对集合。
    BsonArray 表示一个 JSON 数组,它是一个元素集合。

    2024-02-26 16:54:21
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载