Hi, I can run my standalone Flink project from command line without having any issue but when I try to rut it through Flink job, I get this error (and yes, my Java version is 11.0.18):

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Unable to instantiate java compiler

at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)

at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)

at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)

at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)

at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)

at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)

at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)

at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)

at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)

at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)

Caused by: java.lang.IllegalStateException: Unable to instantiate java compiler

at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.compile(JaninoRelMetadataProvider.java:163)

at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.generateCompileAndInstantiate(JaninoRelMetadataProvider.java:141)

at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.lambda$static$0(JaninoRelMetadataProvider.java:73)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.CacheLoader$FunctionToCacheLoader.load(CacheLoader.java:165)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache.get(LocalCache.java:3951)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3974)

at <http://org.apache.flink.calcite.shaded.com|org.apache.flink.calcite.shaded.com>.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4958)

at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.revise(JaninoRelMetadataProvider.java:197)

at org.apache.calcite.rel.metadata.RelMetadataQueryBase.revise(RelMetadataQueryBase.java:118)

at org.apache.calcite.rel.metadata.RelMetadataQuery.getPulledUpPredicates(RelMetadataQuery.java:844)

at org.apache.calcite.rel.rules.ReduceExpressionsRule$FilterReduceExpressionsRule.onMatch(ReduceExpressionsRule.java:153)

at org.apache.calcite.plan.AbstractRelOptPlanner.fireRule(AbstractRelOptPlanner.java:337)

at org.apache.calcite.plan.hep.HepPlanner.applyRule(HepPlanner.java:565)

at org.apache.calcite.plan.hep.HepPlanner.applyRules(HepPlanner.java:428)

at org.apache.calcite.plan.hep.HepPlanner.executeInstruction(HepPlanner.java:251)

at org.apache.calcite.plan.hep.HepInstruction$RuleInstance.execute(HepInstruction.java:130)

at org.apache.calcite.plan.hep.HepPlanner.executeProgram(HepPlanner.java:208)

at org.apache.calcite.plan.hep.HepPlanner.findBestExp(HepPlanner.java:195)

at org.apache.flink.table.planner.plan.optimize.program.FlinkHepProgram.optimize(FlinkHepProgram.scala:64)

at org.apache.flink.table.planner.plan.optimize.program.FlinkHepRuleSetProgram.optimize(FlinkHepRuleSetProgram.scala:78)

at org.apache.flink.table.planner.plan.optimize.program.FlinkChainedProgram.$anonfun$optimize$1(FlinkChainedProgram.scala:59)

at scala.collection.TraversableOnce.$anonfun$foldLeft$1(TraversableOnce.scala:156)

at scala.collection.TraversableOnce.$anonfun$foldLeft$1$adapted(TraversableOnce.scala:156)

at scala.collection.Iterator.foreach(Iterator.scala:937)

at scala.collection.Iterator.foreach$(Iterator.scala:937)

at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)

at scala.collection.IterableLike.foreach(IterableLike.scala:70)

at scala.collection.IterableLike.foreach$(IterableLike.scala:69)

at scala.collection.AbstractIterable.foreach(Iterable.scala:54)

at scala.collection.TraversableOnce.foldLeft(TraversableOnce.scala:156)

at scala.collection.TraversableOnce.foldLeft$(TraversableOnce.scala:154)

at scala.collection.AbstractTraversable.foldLeft(Traversable.scala:104)

at org.apache.flink.table.planner.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:55)

at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.optimizeTree(StreamCommonSubGraphBasedOptimizer.scala:176)

at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.doOptimize(StreamCommonSubGraphBasedOptimizer.scala:83)

at org.apache.flink.table.planner.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:87)

at org.apache.flink.table.planner.delegation.PlannerBase.optimize(PlannerBase.scala:329)

at org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:195)

at org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.toStreamInternal(AbstractStreamTableEnvironmentImpl.java:224)

at org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.toStreamInternal(AbstractStreamTableEnvironmentImpl.java:219)

at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toDataStream(StreamTableEnvironmentImpl.java:253)

at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toDataStream(StreamTableEnvironmentImpl.java:226)

at <http://org.varimat.com|org.varimat.com>.EMPADStreamCommand.processWorkflow(EMPADStreamCommand.java:220)

at <http://org.varimat.com|org.varimat.com>.EMPADStreamCommand.processFromStream(EMPADStreamCommand.java:203)

at <http://org.varimat.com|org.varimat.com>.EMPADStreamCommand.main(EMPADStreamCommand.java:240)

at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.base/java.lang.reflect.Method.invoke(Method.java:566)

at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)

... 9 more

Caused by: java.lang.ClassCastException: class org.codehaus.janino.CompilerFactory cannot be cast to class org.codehaus.commons.compiler.ICompilerFactory (org.codehaus.janino.CompilerFactory is in unnamed module of loader org.apache.flink.util.ChildFirstClassLoader @338494fa; org.codehaus.commons.compiler.ICompilerFactory is in unnamed module of loader 'app')

at org.codehaus.commons.compiler.CompilerFactoryFactory.getCompilerFactory(CompilerFactoryFactory.java:129)

at org.codehaus.commons.compiler.CompilerFactoryFactory.getDefaultCompilerFactory(CompilerFactoryFactory.java:79)

at org.apache.calcite.rel.metadata.JaninoRelMetadataProvider.compile(JaninoRelMetadataProvider.java:161)

... 62 more

Hey @Amir Hossein Sharifzadeh did you get this working ? I pretty stumbled into the same issue and am using table API too

Hi @Srivatsav Gorti No unfortunately! I think this might be a bug for Windows users! I have no issue running the code on Linux or Mac though…

ohh ! no I am getting this issue when running it on cloud server which is an ec2 instance in a k8s cluster. But yeah nvm ! The stack trace is exactly what I am getting so was wondering coz I had spent so much on this now .

what's your flink, janino version? it's very likely you have janino 3.1.x janino version in classpath while flink 1.17, 1.16 depend on 3.0.x