Hello,
I'm using Flink 1.18 and have this error, any idea? Works in IDE.
2023-11-24 16:04:47.062 [DEBUG] [jobmanager-io-thread-1]
DefaultJobMasterServiceProcess - Initialization of the JobMasterService for job
abbad350a6a161919104f8e2fe2670b8 under leader id
b5a63392-d3e4-49d8-85d1-52cd3b71bf89 failed.
org.apache.flink.runtime.client.JobInitializationException: Could not start the
JobMaster.
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
~[flink-runtime-1.18.0.jar:1.18.0]
at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
[?:?]
at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
[?:?]
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
[?:?]
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1773)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.util.concurrent.CompletionException:
java.lang.RuntimeException: java.lang.ClassNotFoundException:
org.apache.flink.api.common.ExecutionConfig
at
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1770)
~[?:?]
... 3 more
Caused by: java.lang.RuntimeException: java.lang.ClassNotFoundException:
org.apache.flink.api.common.ExecutionConfig
at
deployment.teste.ear.teste.war/org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
~[flink-core-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
~[flink-core-1.18.0.jar:1.18.0]
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
~[?:?]
... 3 more
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.api.common.ExecutionConfig
at
java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
~[?:?]
at
java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
~[?:?]
at
java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520) ~[?:?]
at java.base/java.lang.Class.forName0(Native Method) ~[?:?]
at java.base/java.lang.Class.forName(Class.java:467) ~[?:?]
at
deployment.teste.ear.teste.war/org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
~[flink-core-1.18.0.jar:1.18.0]
at
java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2043)
~[?:?]
at
java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1907)
~[?:?]
at
java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2209)
~[?:?]
at
java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742)
~[?:?]
at
java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514)
~[?:?]
at
java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472)
~[?:?]
at
deployment.teste.ear.teste.war/org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
~[flink-core-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
~[flink-core-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
~[flink-core-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.scheduler.adaptivebatch.AdaptiveBatchSchedulerFactory.createInstance(AdaptiveBatchSchedulerFactory.java:149)
~[flink-runtime-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122)
~[flink-runtime-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
~[flink-runtime-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356)
~[flink-runtime-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128)
~[flink-runtime-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100)
~[flink-runtime-1.18.0.jar:1.18.0]
at
deployment.teste.ear.teste.war/org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
~[flink-core-1.18.0.jar:1.18.0]
at
java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
~[?:?]
... 3 more
Thanks,
Dulce Morim
