Hello Team,
I am getting below error while running...
# troubleshootingk
Keyur Makwana
07/25/2023, 1:17 PMHello Team,
I am getting below error while running basic Table API job.
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 @c5e6dec; 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)
Keyur Makwana
07/25/2023, 1:17 PMBelow is the POM file of my Job
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-java -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java</artifactId>
<version>1.17.1</version>
<scope>provided</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-java -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java</artifactId>
<version>1.17.1</version>
<scope>provided</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table-api-java-bridge -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge</artifactId>
<version>1.17.1</version>
<scope>provided</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table-api-scala -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-scala_2.12</artifactId>
<version>1.17.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table-api-java-bridge -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge</artifactId>
<version>1.17.1</version>
<scope>provided</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table-api-scala-bridge -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-scala-bridge_2.12</artifactId>
<version>1.17.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.28</version>
<scope>provided</scope>
</dependency>
s
Shiv Desai
07/25/2023, 2:25 PMThere is a package that is missing in your POM file. Can you try including the
flink-table-planner-loader Copy code
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-loader</artifactId>
<version>1.17.1</version>
<scope>test</scope>
</dependency>m
Martijn Visser
07/25/2023, 2:30 PMCheck https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/configuration/advanced/#anatomy-of-table-dependencies for which JARs you need to use the Table API
k
Keyur Makwana
07/26/2023, 7:37 AM@Martijn Visser It works for me Thank you so much
I have one more concern,
I have Flink Job that is using Table API, Input log in the Flink Job has a diff log schema, let’s say
log1 has {x=1,y=“abc”,z=true}
log2 has {x=1,a=“yu”,b=false} in future I can have other fields
As far as I have explored I need fix schema, But in this example I can not make schema correct, So how can I make dynamic schema on the each rule?
Thank you so much, I highly appreciate your reply
2 Views