[
https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024466#comment-17024466
]
Jark Wu commented on FLINK-15685:
---------------------------------
Hi [~trohrmann], if this is not urgent I think I can take this, because I'm
still on vacation.
If this is the root cause, I guess the fixing is not difficult, we can just
copy the hadoop pre-bundled jars into
{{flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/target/dependencies}}
directory. But I'm wondering is the case always failed since
{{SQLClientKafkaITCase}} was checked in or failed recently?
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs
> -----------------------------------------------------------------------
>
> Key: FLINK-15685
> URL: https://issues.apache.org/jira/browse/FLINK-15685
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client, Tests
> Affects Versions: 1.11.0
> Reporter: Congxian Qiu(klion26)
> Priority: Major
> Fix For: 1.11.0
>
>
> {code}
> 08:50:02.717 [ERROR] Tests run: 3, Failures: 0, Errors: 3, Skipped: 0, Time
> elapsed: 76.395 s <<< FAILURE! - in
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase
>
> 1897208:50:02.722 [ERROR] testKafka[0: kafka-version:0.10
> kafka-sql-version:.*kafka-0.10.jar](org.apache.flink.tests.util.kafka.SQLClientKafkaITCase)
> Time elapsed: 23.806 s <<< ERROR!
>
> 18973java.io.IOException:
>
> 18974Process execution failed due error. Error output:Exception in thread
> "main" org.apache.flink.table.client.SqlClientException: Unexpected
> exception. This is a bug. Please consider filing an issue.
>
> 18975 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:190)
>
> 18976Caused by: org.apache.flink.table.client.gateway.SqlExecutionException:
> Could not create execution context.
>
> 18977 at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:759)
>
> 18978 at
> org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:228)
>
> 18979 at org.apache.flink.table.client.SqlClient.start(SqlClient.java:98)
>
> 18980 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)
>
> 18981Caused by: java.lang.NoClassDefFoundError: org/apache/avro/io/DatumReader
>
> 18982 at
> org.apache.flink.formats.avro.AvroRowFormatFactory.createDeserializationSchema(AvroRowFormatFactory.java:64)
>
> 18983 at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.getDeserializationSchema(KafkaTableSourceSinkFactoryBase.java:285)
>
> 18984 at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.createStreamTableSource(KafkaTableSourceSinkFactoryBase.java:163)
>
> 18985 at
> org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:49)
>
> 18986 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:371)
>
> 18987 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:552)
>
> 18988 at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
>
> 18989 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:550)
>
> 18990 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:487)
>
> 18991 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:159)
>
> 18992 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:118)
>
> 18993 at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:748)
>
> 18994 ... 3 more
>
> 18995Caused by: java.lang.ClassNotFoundException:
> org.apache.avro.io.DatumReader
>
> 18996 at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
>
> 18997 at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
>
> 18998 at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
>
> 18999 ... 15 more
>
> 19000
>
> 19001 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.insertIntoAvroTable(SQLClientKafkaITCase.java:178)
>
> 19002 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.testKafka(SQLClientKafkaITCase.java:151)
>
> 19003
>
> 1900408:50:02.734 [ERROR] testKafka[1: kafka-version:0.11
> kafka-sql-version:.*kafka-0.11.jar](org.apache.flink.tests.util.kafka.SQLClientKafkaITCase)
> Time elapsed: 25.227 s <<< ERROR!
>
> 19005java.io.IOException:
>
> 19006Process execution failed due error. Error output:Exception in thread
> "main" org.apache.flink.table.client.SqlClientException: Unexpected
> exception. This is a bug. Please consider filing an issue.
>
> 19007 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:190)
>
> 19008Caused by: org.apache.flink.table.client.gateway.SqlExecutionException:
> Could not create execution context.
>
> 19009 at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:759)
>
> 19010 at
> org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:228)
>
> 19011 at org.apache.flink.table.client.SqlClient.start(SqlClient.java:98)
>
> 19012 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)
>
> 19013Caused by: java.lang.NoClassDefFoundError: org/apache/avro/io/DatumReader
>
> 19014 at
> org.apache.flink.formats.avro.AvroRowFormatFactory.createDeserializationSchema(AvroRowFormatFactory.java:64)
>
> 19015 at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.getDeserializationSchema(KafkaTableSourceSinkFactoryBase.java:285)
>
> 19016 at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.createStreamTableSource(KafkaTableSourceSinkFactoryBase.java:163)
>
> 19017 at
> org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:49)
>
> 19018 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:371)
>
> 19019 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:552)
>
> 19020 at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
>
> 19021 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:550)
>
> 19022 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:487)
>
> 19023 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:159)
>
> 19024 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:118)
>
> 19025 at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:748)
>
> 19026 ... 3 more
>
> 19027Caused by: java.lang.ClassNotFoundException:
> org.apache.avro.io.DatumReader
>
> 19028 at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
>
> 19029 at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
>
> 19030 at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
>
> 19031 ... 15 more
>
> 19032
>
> 19033 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.insertIntoAvroTable(SQLClientKafkaITCase.java:178)
>
> 19034 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.testKafka(SQLClientKafkaITCase.java:151)
>
> 19035
>
> 1903608:50:02.745 [ERROR] testKafka[2: kafka-version:universal
> kafka-sql-version:.*kafka.jar](org.apache.flink.tests.util.kafka.SQLClientKafkaITCase)
> Time elapsed: 27.321 s <<< ERROR!
>
> 19037java.io.IOException:
>
> 19038Process execution failed due error. Error output:Exception in thread
> "main" org.apache.flink.table.client.SqlClientException: Unexpected
> exception. This is a bug. Please consider filing an issue.
>
> 19039 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:190)
>
> 19040Caused by: org.apache.flink.table.client.gateway.SqlExecutionException:
> Could not create execution context.
>
> 19041 at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:759)
>
> 19042 at
> org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:228)
>
> 19043 at org.apache.flink.table.client.SqlClient.start(SqlClient.java:98)
>
> 19044 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)
>
> 19045Caused by: java.lang.NoClassDefFoundError: org/apache/avro/io/DatumReader
>
> 19046 at
> org.apache.flink.formats.avro.AvroRowFormatFactory.createDeserializationSchema(AvroRowFormatFactory.java:64)
>
> 19047 at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.getDeserializationSchema(KafkaTableSourceSinkFactoryBase.java:285)
>
> 19048 at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.createStreamTableSource(KafkaTableSourceSinkFactoryBase.java:163)
>
> 19049 at
> org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:49)
>
> 19050 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:371)
>
> 19051 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:552)
>
> 19052 at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
>
> 19053 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:550)
>
> 19054 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:487)
>
> 19055 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:159)
>
> 19056 at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:118)
>
> 19057 at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:748)
>
> 19058 ... 3 more
>
> 19059Caused by: java.lang.ClassNotFoundException:
> org.apache.avro.io.DatumReader
>
> 19060 at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
>
> 19061 at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
>
> 19062 at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
>
> 19063 ... 15 more
>
> 19064
>
> 19065 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.insertIntoAvroTable(SQLClientKafkaITCase.java:178)
>
> 19066 at
> org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.testKafka(SQLClientKafkaITCase.java:151)
>
> 19067
>
> 1906808:50:03.069 [INFO]
>
> 1906908:50:03.069 [INFO] Results:
>
> 1907008:50:03.069 [INFO]
>
> 1907108:50:03.069 [ERROR] Errors:
>
> 1907208:50:03.069 [ERROR]
> SQLClientKafkaITCase.testKafka:151->insertIntoAvroTable:178 » IO Process
> execu...
>
> 1907308:50:03.069 [ERROR]
> SQLClientKafkaITCase.testKafka:151->insertIntoAvroTable:178 » IO Process
> execu...
>
> 1907408:50:03.069 [ERROR]
> SQLClientKafkaITCase.testKafka:151->insertIntoAvroTable:178 » IO Process
> execu...
>
> 1907508:50:03.069 [INFO]
>
> 1907608:50:03.069 [ERROR] Tests run: 6, Failures: 0, Errors: 3, Skipped: 0
> {code}
> [https://travis-ci.org/klion26/flink/jobs/639304872?utm_medium=notification&utm_source=github_status]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
