Hi there, Would you mind sharing the whole JM/TM log? It looks like the error log in the previous email is not the root cause.
Best, Biao Geng ou...@139.com <ou...@139.com> 于2024年4月29日周一 16:07写道： > Hi all: > When I ran flink sql datagen source and wrote to jdbc, checkpoint kept > failing with the following error log. > > 2024-04-29 15:46:25,270 ERROR > org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler > [] - Unhandled exception. > org.apache.flink.runtime.dispatcher.UnavailableDispatcherOperationException: > Unable to get JobMasterGateway for initializing job. The requested > operation is not available while the JobManager is initializing. > at > org.apache.flink.runtime.dispatcher.Dispatcher.getJobMasterGateway(Dispatcher.java:1465) > ~[flink-dist-1.18.1.jar:1.18.1] > at > org.apache.flink.runtime.dispatcher.Dispatcher.performOperationOnJobMasterGateway(Dispatcher.java:1475) > ~[flink-dist-1.18.1.jar:1.18.1] > at > org.apache.flink.runtime.dispatcher.Dispatcher.requestCheckpointStats(Dispatcher.java:927) > ~[flink-dist-1.18.1.jar:1.18.1] > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > ~[?:1.8.0_152] > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > ~[?:1.8.0_152] > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > ~[?:1.8.0_152] > at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_152] > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:309) > ~[?:?] > at > org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) > ~[flink-dist-1.18.1.jar:1.18.1] > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:307) > ~[?:?] > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:222) > ~[?:?] > at > org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:85) > ~[?:?] > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:168) > ~[?:?] > at > org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) > ~[?:?] > at > org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29) > ~[?:?] > at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) > ~[flink-scala_2.12-1.18.1.jar:1.18.1] > at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) > ~[flink-scala_2.12-1.18.1.jar:1.18.1] > at > org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29) > ~[?:?] > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) > ~[flink-scala_2.12-1.18.1.jar:1.18.1] > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) > ~[flink-scala_2.12-1. > > >
