mongodb cdc 报空指针 #658
Replies: 1 comment 1 reply
-
同上,求问怎么处理的 |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
遇到了好几次,求问什么原因?
日志如下:
TableSourceScan(table=[[ter]], fields=[_id, serialutilizeLeisureArgument, utilizLeisureArea, utilizeRoamArea, utilizeLeaseArea, quitHouseholds, quitArea, quitCompensation, deleted]) -> MiniBatchAssigner(interval=[5000ms], mode=[ProcTime]) (1/1) (09c422e7c1aabd4d771b2147849b71a6) switched from RUNNING to FAILED on container_e68_1637350693136_0092_01_000002 @ i-siqi03.novalocal (dataPort=12906).
java.lang.NullPointerException: null
at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:59) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at com.ververica.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema.deserialize(MongoDBConnectorDeserializationSchema.java:122) ~[flink-sql-connector-mongodb-cdc-2.1.0.jar:2.1.0]
at com.ververica.cdc.debezium.internal.DebeziumChangeFetcher.handleBatch(DebeziumChangeFetcher.java:217) ~[flink-sql-connector-mongodb-cdc-2.1.0.jar:2.1.0]
at com.ververica.cdc.debezium.internal.DebeziumChangeFetcher.runFetchLoop(DebeziumChangeFetcher.java:163) ~[flink-sql-connector-mongodb-cdc-2.1.0.jar:2.1.0]
at com.ververica.cdc.debezium.DebeziumSourceFunction.run(DebeziumSourceFunction.java:439) ~[flink-sql-connector-mongodb-cdc-2.1.0.jar:2.1.0]
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:269) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
Beta Was this translation helpful? Give feedback.
All reactions