We are running flink applications on Flink version...
# troubleshooting
s
We are running flink applications on Flink versions 1.15.4 and now we want to migrate them to 1.19.1 version. When I am trying to start the application on a newer version, Flink is complaining about an internal change in the data structure of JobVertex. getting below error: JobVertex 1.19.1: private final Map<IntermediateDataSetID, IntermediateDataSet> results = new LinkedHashMap<>(); 1.15.4: private final ArrayList<IntermediateDataSet> results = new ArrayList<>();
java.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 truncated
What can I do to make it compatible?