[
https://issues.apache.org/jira/browse/FLINK-15500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010817#comment-17010817
]
Leonard Xu commented on FLINK-15500:
------------------------------------
I close this for tests have passed in my local environment:)
{code:java}
//master
[PASS] 'flink-end-to-end-tests/test-scripts/test_sql_client_kafka.sh' passed
after 1 minutes and 29 seconds! Test exited with exit code 0.Stopping
taskexecutor daemon (pid: 88090) on host mac.
Stopping standalonesession daemon (pid: 87360) on host mac.
Deleted all files under
/Users/bang/sourcecode/project/flink-master/flink/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/log/
Deleted
/Users/bang/sourcecode/project/flink-master/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-39N
No taskexecutor daemon (pid: 87854) is running anymore on mac.
No standalonesession daemon to stop on host mac.
rm:
/Users/bang/sourcecode/project/flink-master/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-39N/tmp/backup:
No such file or directory
bang@mac flink (master) $
//release-1.10
[PASS] 'flink-end-to-end-tests/test-scripts/test_sql_client_kafka011.sh' passed
after 0 minutes and 40 seconds! Test exited with exit code 0.Stopping
taskexecutor daemon (pid: 81231) on host mac.
Stopping standalonesession daemon (pid: 80502) on host mac.
Deleted all files under
/Users/bang/sourcecode/project/flink/flink-dist/target/flink-1.10-SNAPSHOT-bin/flink-1.10-SNAPSHOT/log/
Deleted
/Users/bang/sourcecode/project/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-22N
No taskexecutor daemon (pid: 80995) is running anymore on mac.
No standalonesession daemon to stop on host mac.
rm:
/Users/bang/sourcecode/project/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-22N/tmp/backup:
No such file or directory
bang@mac flink (release-1.10) $Git log
commit 90d5b76473ba28bf2d6997290604e8fbbf98a06c (HEAD -> release-1.10,
upstream/release-1.10)
{code}
> "SQL Client end-to-end test for Kafka" failed in my local environment
> ---------------------------------------------------------------------
>
> Key: FLINK-15500
> URL: https://issues.apache.org/jira/browse/FLINK-15500
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
> Reporter: Jark Wu
> Priority: Critical
>
> The "SQL Client end-to-end test for modern Kafka" (aka.
> {{test_sql_client_kafka.sh}}) test is failed in my local environment with
> following exception:
> {code:java}
> Exception in thread "main" org.apache.flink.table.client.SqlClientException:
> Unexpected exception. This is a bug. Please consider filing an issue.
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:190)
> Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could
> not create execution context.
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:759)
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:228)
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:98)
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)
> Caused by: java.lang.NoClassDefFoundError: org/apache/avro/io/DatumReader
> at
> org.apache.flink.formats.avro.AvroRowFormatFactory.createDeserializationSchema(AvroRowFormatFactory.java:64)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.getDeserializationSchema(KafkaTableSourceSinkFactoryBase.java:281)
> at
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.createStreamTableSource(KafkaTableSourceSinkFactoryBase.java:161)
> at
> org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:49)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:371)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:552)
> at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:550)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:487)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:159)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:118)
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:748)
> ... 3 more
> Caused by: java.lang.ClassNotFoundException: org.apache.avro.io.DatumReader
> at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> ... 15 more
> [FAIL] Test script contains errors.
> Checking of logs skipped.
> [FAIL] 'flink-end-to-end-tests/test-scripts/test_sql_client_kafka.sh' failed
> after 0 minutes and 27 seconds! Test exited with exit code 1
> {code}
> I guess the reason why nightly travis didn't report this is that "e2e - misc
> - hadoop 2.8" is failed on the "Streaming File Sink s3 end-to-end test", that
> result in all the following cases (including SQL Client end-to-end tests) are
> not triggered. For example https://api.travis-ci.org/v3/job/633275285/log.txt
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
