piotrp commented on PR #27697: URL: https://github.com/apache/flink/pull/27697#issuecomment-3981384980
Looks like this test I provided verifies only MiniCluster behavior, where user classes are mixed with Flink classes. Even after applying your patch Flink's JobManager still crashes after throwing an exception after job JAR is uploaded: ``` 2026-03-02 01:13:16.471 | 2026-03-02 00:13:16,469 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Fatal error occurred in the cluster entrypoint. 2026-03-02 01:13:16.471 | org.apache.flink.util.FlinkException: JobMaster for job 73e1c9595b191dae276e39958e99435a failed. 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.dispatcher.Dispatcher.jobMasterFailed(Dispatcher.java:1942) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.dispatcher.Dispatcher.jobManagerRunnerFailed(Dispatcher.java:1010) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.dispatcher.Dispatcher.lambda$runJob$12(Dispatcher.java:932) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.CompletableFuture.uniHandle(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.CompletableFuture$Completion.run(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:460) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:460) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:225) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246) [flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source) [?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) [?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source) [?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) [?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) [?:?] 2026-03-02 01:13:16.471 | Caused by: org.apache.flink.runtime.jobmaster.JobMasterException: Could not update the state of task execution for JobMaster. 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:544) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.reflect.Method.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | ... 23 more 2026-03-02 01:13:16.471 | Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Failed to deserialize AdaptiveJoin instance. Please check whether the flink-table-planner-loader.jar is in the classpath. 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.DefaultAdaptiveExecutionHandler.handleJobEvent(DefaultAdaptiveExecutionHandler.java:86) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.lambda$notifyJobVertexFinishedIfPossible$17(AdaptiveBatchScheduler.java:660) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.util.Optional.ifPresent(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.notifyJobVertexFinishedIfPossible(AdaptiveBatchScheduler.java:658) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.onTaskFinished(AdaptiveBatchScheduler.java:406) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:833) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:813) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:534) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.reflect.Method.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | ... 23 more 2026-03-02 01:13:16.471 | Caused by: java.lang.RuntimeException: Failed to deserialize AdaptiveJoin instance. Please check whether the flink-table-planner-loader.jar is in the classpath. 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoinOperatorFactory.lazyInitialize(AdaptiveJoinOperatorFactory.java:134) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoinOperatorFactory.checkAndLazyInitialize(AdaptiveJoinOperatorFactory.java:96) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoinOperatorFactory.getJoinType(AdaptiveJoinOperatorFactory.java:78) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.strategy.AdaptiveBroadcastJoinOptimizationStrategy.tryOptimizeAdaptiveJoin(AdaptiveBroadcastJoinOptimizationStrategy.java:105) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.strategy.BaseAdaptiveJoinOperatorOptimizationStrategy.visitDownstreamAdaptiveJoinNode(BaseAdaptiveJoinOperatorOptimizationStrategy.java:90) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.strategy.AdaptiveBroadcastJoinOptimizationStrategy.onOperatorsFinished(AdaptiveBroadcastJoinOptimizationStrategy.java:74) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.StreamGraphOptimizer.onOperatorsFinished(StreamGraphOptimizer.java:72) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.DefaultAdaptiveExecutionHandler.tryOptimizeStreamGraph(DefaultAdaptiveExecutionHandler.java:118) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.DefaultAdaptiveExecutionHandler.handleJobEvent(DefaultAdaptiveExecutionHandler.java:82) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.lambda$notifyJobVertexFinishedIfPossible$17(AdaptiveBatchScheduler.java:660) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.util.Optional.ifPresent(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.notifyJobVertexFinishedIfPossible(AdaptiveBatchScheduler.java:658) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.onTaskFinished(AdaptiveBatchScheduler.java:406) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:833) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:813) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:534) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.reflect.Method.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | ... 23 more 2026-03-02 01:13:16.471 | Caused by: java.lang.ClassNotFoundException: org.apache.notflink.TableJoinTestClass 2026-03-02 01:13:16.471 | at java.base/java.net.URLClassLoader.findClass(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.ClassLoader.loadClass(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.lang.ClassLoader.loadClass(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:197) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.lang.Class.forName0(Native Method) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.Class.forName(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:76) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readNonProxyDesc(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readClassDesc(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readClass(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream$FieldValues.<init>(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream$FieldValues.<init>(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.util.ArrayList.readObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.GeneratedMethodAccessor13.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.reflect.Method.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectStreamClass.invokeReadObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream$FieldValues.<init>(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream$FieldValues.<init>(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream$FieldValues.<init>(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject0(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.io.ObjectInputStream.readObject(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:488) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:472) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:467) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoinOperatorFactory.lazyInitialize(AdaptiveJoinOperatorFactory.java:132) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoinOperatorFactory.checkAndLazyInitialize(AdaptiveJoinOperatorFactory.java:96) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoinOperatorFactory.getJoinType(AdaptiveJoinOperatorFactory.java:78) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.strategy.AdaptiveBroadcastJoinOptimizationStrategy.tryOptimizeAdaptiveJoin(AdaptiveBroadcastJoinOptimizationStrategy.java:105) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.strategy.BaseAdaptiveJoinOperatorOptimizationStrategy.visitDownstreamAdaptiveJoinNode(BaseAdaptiveJoinOperatorOptimizationStrategy.java:90) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.table.runtime.strategy.AdaptiveBroadcastJoinOptimizationStrategy.onOperatorsFinished(AdaptiveBroadcastJoinOptimizationStrategy.java:74) ~[flink-table-runtime-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.StreamGraphOptimizer.onOperatorsFinished(StreamGraphOptimizer.java:72) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.DefaultAdaptiveExecutionHandler.tryOptimizeStreamGraph(DefaultAdaptiveExecutionHandler.java:118) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.DefaultAdaptiveExecutionHandler.handleJobEvent(DefaultAdaptiveExecutionHandler.java:82) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.lambda$notifyJobVertexFinishedIfPossible$17(AdaptiveBatchScheduler.java:660) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/java.util.Optional.ifPresent(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.notifyJobVertexFinishedIfPossible(AdaptiveBatchScheduler.java:658) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchScheduler.onTaskFinished(AdaptiveBatchScheduler.java:406) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:833) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:813) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:534) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at java.base/java.lang.reflect.Method.invoke(Unknown Source) ~[?:?] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-dist-2.3-SNAPSHOT.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | at org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229) ~[flink-rpc-akkae6f85170-a441-4a28-b81e-ab5fdfbeb1ca.jar:2.3-SNAPSHOT] 2026-03-02 01:13:16.471 | ... 23 more ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
