[
https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361129#comment-17361129
]
Ryan Darling commented on FLINK-22907:
--------------------------------------
[~jark] from the pyflink/bin dir we typically execute like this:
./sql-client.sh --jar
<full_path>/pyflink/opt/flink-sql-connector-kafka_2.11-1.13.0.jar --jar
<full_path>/pyflink/opt/flink-table-planner_2.12-1.13.0.jar --jar
<full_path>/pyflink/opt/flink-table-common-1.13.0.jar --jar
<full_path>/pyflink/opt/flink-sql-avro-confluent-registry-1.13.0.jar --jar
<full_path>/pyflink/opt/flink-table-planner-blink_2.12-1.13.0.jar
> 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
> Priority: Major
> 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)
