Open
Description
异常栈如下：
2025-06-26 10:04:58,221 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job volc_prod_mongo_to_sr (4a54e28083aff7bf3d72ac0755cb4d93) switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:176) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:107) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:285) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:276) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:269) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:764) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:741) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:488) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[?:?]
at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?]
at java.lang.reflect.Method.invoke(Unknown Source) ~[?:?]
at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:309) ~[flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:307) ~[flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.flink.runtime.rpc.pekko.
6C64
PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:222) ~[flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:85) ~[flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:168) ~[flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253) [flink-rpc-akkac2a6d136-d9ae-4ac3-8c6e-6712961a9d1a.jar:tis-1.18.1]
at java.util.concurrent.ForkJoinTask.doExec(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinPool.scan(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) [?:?]
at java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) [?:?]
Caused by: java.lang.UnsupportedOperationException: unsupported type:NULL
at com.qlangtech.tis.plugin.datax.mongo.MongoDataXColUtils$MongoDateTimeValueDTOConvert.getInstant(MongoDataXColUtils.java:323) ~[?:?]
at com.qlangtech.tis.plugin.datax.mongo.MongoDataXColUtils$MongoDateTimeValueDTOConvert.apply(MongoDataXColUtils.java:330) ~[?:?]
at com.qlangtech.tis.plugin.datax.mongo.MongoDataXColUtils.createCol(MongoDataXColUtils.java:192) ~[?:?]
at com.qlangtech.tis.plugin.datax.mongo.MongoColValGetter$FlinkPropValGetter.apply(MongoColValGetter.java:66) ~[?:?]
at com.qlangtech.tis.plugin.datax.mongo.MongoColValGetter$FlinkPropValGetter.apply(MongoColValGetter.java:55) ~[?:?]
at com.qlangtech.plugins.incr.flink.cdc.mongdb.impl.MongoDBDeserializationSchema.fillAfterValsFromEvent(MongoDBDeserializationSchema.java:223) ~[?:?]
at com.qlangtech.plugins.incr.flink.cdc.TISDeserializationSchema.extractAfterRow(TISDeserializationSchema.java:194) ~[?:?]
at com.qlangtech.plugins.incr.flink.cdc.TISDeserializationSchema.deserialize(TISDeserializationSchema.java:91) ~[?:?]
at org.apache.flink.cdc.debezium.internal.DebeziumChangeFetcher.handleBatch(DebeziumChangeFetcher.java:245) ~[?:?]
at org.apache.flink.cdc.debezium.internal.DebeziumChangeFetcher.runFetchLoop(DebeziumChangeFetcher.java:155) ~[?:?]
at org.apache.flink.cdc.debezium.DebeziumSourceFunction.run(DebeziumSourceFunction.java:447) ~[?:?]
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:114) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:71) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:338) ~[flink-dist-tis-1.18.1.jar:tis-1.18.1]
2025-06-26 10:04:58,226 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job volc_prod_mongo_to_sr (4a54e28083aff7bf3d72ac0755cb4d93) switched from state FAILING to FAILED.关键错误信息：
Caused by: java.lang.UnsupportedOperationException: unsupported type:NULL
at com.qlangtech.tis.plugin.datax.mongo.MongoDataXColUtils$MongoDateTimeValueDTOConvert.getInstant(MongoDataXColUtils.java:323) ~[?:?]Metadata
Metadata
Assignees
Labels
No labels