Hi All ,
Facing the same issue.
Has anyone else faced the same issue.
Is Java 17 still on experimental support in Flink 1.20 ?
Thanks,
Prasanna.
On Tue, Nov 19, 2024 at 3:36 PM Nitin Saini <nitinsaini1...@gmail.com>
wrote:
> 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
>
