Sachin Sharma
09/18/2024, 5:58 AMjava.lang.ClassCastException: cannot assign instance of java.util.ArrayList to field org.apache.flink.runtime.jobgraph.JobVertex.results of type java.util.Map in instance of org.apache.flink.runtime.jobgraph.JobVertex\n\tat java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(Unknown Source)\n\tat java.io.ObjectStreamClass$FieldReflector.checkObjectFieldValueTypes(Unknown Source)\n\tat java.io.ObjectStreamClass.checkObjFieldValueTypes(Unknown Source)\n\tat java.io.ObjectInputStream.defaultCheckFieldValues(Unknown Source)\n\tat java.io.ObjectInputStream.readSerialData(Unknown Source)\n\t... 23 frames truncated\n\t... 10 common frames omitted\nWrapped by: org.apache.flink.util.FlinkRuntimeException: Could not recover job with job id 00000000000000000000000000000000.\n\tat org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.tryRecoverJob(SessionDispatcherLeaderProcess.java:183)\n\tat org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.recoverJobs(SessionDispatcherLeaderProcess.java:150)\n\tat org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.lambda$recoverJobsIfRunning$2(SessionDispatcherLeaderProcess.java:139)\n\tat org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.supplyUnsynchronizedIfRunning(AbstractDispatcherLeaderProcess.java:198)\n\tat org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.recoverJobsIfRunning(SessionDispatcherLeaderProcess.java:139)\n\t... 1 frames truncated\n\t... 5 common frames omitted\nWrapped by: java.util.concurrent.CompletionException: org.apache.flink.util.FlinkRuntimeException: Could not recover job with job id 00000000000000000000000000000000.\n\tat java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source)\n\tat java.util.concurrent.CompletableFuture.completeThrowable(Unknown Source)\n\tat java.util.concurrent.CompletableFuture$UniApply.tryFire(Unknown Source)\n\tat java.util.concurrent.CompletableFuture$Completion.run(Unknown Source)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)\n\t... 2 frames truncatedWhat can I do to make it compatible?