Hi For e2e testing, we run tests with testcontainers. We have several jobs and we want to upgrade them one by one
Do you know if it is possible in Docker to run one JM + one TM for version 1 and version 2 at the same time? It looks like either the taskmanager registration is failing for the second cluster, either there is a classcastexception ERROR org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at ResourceManager failed due to an error java.util.concurrent.CompletionException: java.lang.ClassCastException: class org.apache.flink.util.SerializedValue cannot be cast to class org.apache.flink.runtime.registration.RegistrationResponse (org.apache.flink.util.SerializedValue and org.apache.flink.runtime.registration.RegistrationResponse are in unnamed module of loader 'app') at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown Source) at java.base/java.util.concurrent.CompletableFuture$UniAccept.tryFire(Unknown Source) at java.base/java.util.concurrent.CompletableFuture$Completion.run(Unknown Source) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: java.lang.ClassCastException: class org.apache.flink.util.SerializedValue cannot be cast to class org.apache.flink.runtime.registration.RegistrationResponse (org.apache.flink.util.SerializedValue and org.apache.flink.runtime.registration.RegistrationResponse are in unnamed module of loader 'app') ... 8 common frames omitted Thanks Farouk
