[
https://issues.apache.org/jira/browse/FLINK-16353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17048818#comment-17048818
]
Jark Wu commented on FLINK-16353:
---------------------------------
Hi [~miguelangel], please have a look at the above user mailing list. It should
be a similar problem. Please make sure {{flink-table-planner}} and
{{flink-table-planner-blink}} is not packaged into the user jar.
> Issue when flink upload a job with stream sql query
> ---------------------------------------------------
>
> Key: FLINK-16353
> URL: https://issues.apache.org/jira/browse/FLINK-16353
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.10.0
> Environment: This is my code
> {code:java}
> class TestQueries extends Serializable{
> def testQuery(): Unit = {
> // Enable settings
> val settings =
> EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> val tableEnv = StreamTableEnvironment.create(env, settings)
>
> //Consumer kafka topic
> //... topic_consumer
> val stream: DataStream[String] = env.addSource(topic_consumer)
>
> // Convert stream to DataStream[Row]
> val result: DataStream[Row] = stream.map(str => desJson(str))(rowType)
> // desJson is a function to return Row values from deserialize json topic
> // rowType is a rowTypeInfo with (fieldTypes, fieldNames). fieldTypes are
> Strings and fieldNames ("user", "name", "lastName")
> // Register table
> tableEnv.createTemporaryView("table", result)
> //Queries
> val first_query = tableEnv.sqlQuery("SELECT * from table WHERE name =
> 'Sansa'")
> val second_query = tableEnv.sqlQuery("SELECT * from table WHERE lastName
> = 'Stark'")
> //In the following two lines is where the exception occurs
> val first_row: DataStream[Row] = tableEnv.toAppendStream[Row](first_query)
> val second_row: DataStream[Row] =
> tableEnv.toAppendStream[Row](second_query)
> //Elasticsearch
> // Sending data to Elasticsearch
> env.execute("Test Queries")
> }
> {code}
> Reporter: Miguel Angel
> Priority: Major
>
> {color:#242729}I used the latest flink version(1.10.0) and sbt(1.3.7). I have
> this exception when upload a job with streaming sql query:{color}
> {color:#242729}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 @3270d194;
> 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:432){color}
>
> {color:#242729}When I running main class with {color}*sbt run*{color:#242729}
> it works perfectly.{color}
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
