Hello Flink Community,
I am in the process of migrating my Flink jobs from version 1.20.0 with
Java 17, but I am encountering some issues.
{\"errors\":[\"org.apache.flink.runtime.rest.handler.RestHandlerException:
Could not execute application.\\n\\tat
org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$1(JarRunHandler.java:114)\\n\\tat
java.base/java.util.concurrent.CompletableFuture.uniHandle(Unknown
Source)\\n\\tat
java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(Unknown
Source)\\n\\tat
java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown
Source)\\n\\tat
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown
Source)\\n\\tat java.base/java.lang.Thread.run(Unknown Source)\\nCaused by:
java.util.concurrent.CompletionException: java.lang.NoClassDefFoundError:
Could not initialize class
org.apache.flink.datastream.impl.ExecutionContextEnvironment\\n\\tat
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown
Source)\\n\\tat
java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown
Source)\\n\\t... 2 more\\nCaused by: java.lang.NoClassDefFoundError: Could
not initialize class
org.apache.flink.datastream.impl.ExecutionContextEnvironment\\n\\tat
org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:109)\\n\\tat
org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84)\\n\\tat
org.apache.flink.client.deployment.application.DetachedApplicationRunner.run(DetachedApplicationRunner.java:70)\\n\\tat
org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:108)\\n\\t...
2 more\\nCaused by: java.lang.ExceptionInInitializerError: Exception
java.lang.ExceptionInInitializerError [in thread
\\\"flink-jar-runner-thread-1\\\"]\\n\\t... 6 more\\n\"]}
*Here are the details of my setup:*
Java Version: 17.0.13+11
Scala Version: 2.12
Flink Version: 1.20.0
Flink Image: Flink Dockerfile
After reviewing several threads, I found that Java 17 is reportedly
incompatible with Scala 2.12, and it is recommended to use Scala 2.13
instead.
If this is indeed the issue, is there a way to resolve it? Unfortunately, I
couldn't find any Flink 1.20.0 images that use Scala 2.13.
I would greatly appreciate any assistance you can provide.
Best regards,
Nitin Saini
