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

Flink CDC里这是什么错误?

Flink CDC里这是什么错误?com.ververica.cdc.debezium.internal.DebeziumChangeConsumer [] - commitOffset() called on Debezium change consumer which doesn't receive records yet.DropUpdateBefore[557] (1/1)#6 (e6cdfa4dfec0db2b479787404ffdb094_bb47084b2dbbe1d832e2397f5b80c9bb_0_6) switched from RUNNING to FAILED with failure cause:
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:214) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_311]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_311]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_311]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_311]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_311]
Caused by: org.apache.kafka.connect.errors.ConnectException: Message from transaction {} has {} data columns but only {} of type info
at io.debezium.connector.postgresql.connection.pgproto.PgProtoMessageDecoder.processNotEmptyMessage(PgProtoMessageDecoder.java:56) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.connection.AbstractMessageDecoder.processMessage(AbstractMessageDecoder.java:33) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.deserializeMessages(PostgresReplicationConnection.java:604) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:594) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.searchWalPosition(PostgresStreamingChangeEventSource.java:393) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:191) ~[blob_p-35e98cc51e96900930d3ba545e7f5fbbfd9ec2db-4a96d5b71ca0641615d7d08028169bf2:?]
... 9 more

展开
收起
小小鹿鹿鹿 2024-01-24 13:18:59 205 0
0 条回答
写回答
取消 提交回答

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

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