I'm trying to build a Docker container image containing the bits needed to run the Flink SQL client to issue SQL queries on Kafka topics, and I'm struggling to work out what JAR files to include in the container. I'm starting with the 1.17.0 Docker image, and based on this https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/table/kafka/, https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/configuration/connector/, and https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/configuration/overview/, I've added • flink-json/1.17.0/flink-json-1.17.0.jar • flink-table-api-java-bridge-1.17.0.jar • flink-sql-connector-kafka-1.17.0.jar But when I run a query on a the following table:

CREATE TABLE FOO (id STRING, name STRING)

WITH (

'connector'='kafka',

'topic'='foo',

'format'='json',

'properties.bootstrap.servers'='flinktests-kafka-1:29091',

'properties.group.id'='flink',

'scan.startup.mode'='earliest-offset'

);

I get the following error from the SQL Client

[ERROR] Could not execute SQL statement. Reason:

2023-03-30 15:23:43 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 @4c013fb6; org.codehaus.commons.compiler.ICompilerFactory is in unnamed module of loader 'app')

Any ideas where I should look?

Hi Gil, Were you able to fix it?