[FLINK-15685] org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Table SQL / Client, Tests
• Assignee: Chesnay Schepler
• Reporter: Congxian Qiu
• Created: 20/Jan/20 10:15
• Updated: 13/Feb/20 09:44
• Resolved: 13/Feb/20 09:44

Description

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
 

https://travis-ci.org/klion26/flink/jobs/639304872?utm_medium=notification&utm_source=github_status

Issue Links

• links to: GitHub Pull Request #10954