Ryan Darling created FLINK-22907:
------------------------------------
Summary: SQL Client queries fails on select statement
Key: FLINK-22907
URL: https://issues.apache.org/jira/browse/FLINK-22907
Project: Flink
Issue Type: Bug
Components: Table SQL / Client
Affects Versions: 1.13.0
Environment: python 3.7.6
JupyterLab
apache-flink==1.13.0
Reporter: Ryan Darling
Attachments: flink_sql_issue1.JPG
I have configured a Jupyter notebook to test flink jobs with the sql client.
All of my source / sink table creation statements are successful but we are
unable to query the created tables
In this scenario we are attempting to pull data from a kafka topic into a
source table and if successful insert into a sink table and on to another kafka
topic.
We start the sql_client.sh passing the needed jar file locations
(flink-sql-connector-kafka_2.11-1.13.0.jar,
flink-table-planner_2.12-1.13.0.jar, flink-table-common-1.13.0.jar,
flink-sql-avro-confluent-registry-1.13.0.jar,
flink-table-planner-blink_2.12-1.13.0.jar)
Next we create the source table and point to a kafka topic that we know has
avro data in it and registered schemas in the schema registry.
CREATE TABLE avro_sources (
prop_id INT,
check_in_dt STRING,
check_out_dt STRING,
los INT,
guests INT,
rate_amt INT
) WITH (
'connector' = 'kafka',
'topic' = 'avro_rate',
'properties.bootstrap.servers' = '<removed>',
'key.format' = 'avro-confluent',
'key.avro-confluent.schema-registry.url' = '<removed>',
'key.fields' = 'prop_id',
'value.format' = 'avro-confluent',
'value.avro-confluent.schema-registry.url' = '<removed>',
'value.fields-include' = 'ALL',
'key.avro-confluent.schema-registry.subject' = 'avro_rate',
'value.avro-confluent.schema-registry.subject' = 'avro_rate'
)
At this point I want to see the data that has been pulled into the source table
and I get the following error and are struggling to find a solution. I feel
this could be a bug
Flink SQL> select * from avro_sources;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassCastException: org.codehaus.janino.CompilerFactory cannot be
cast to org.codehaus.commons.compiler.ICompilerFactory
Any guidance on how I can resolve the bug or the problem would be appreciated.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
