It is possible but you need to make sure that all ports a configured such that the 2 clusters don't see each other.

On 13/07/2021 13:21, Farouk wrote:
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


Reply via email to