You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/13 06:26:00 UTC
[jira] [Updated] (FLINK-16583) SQLClientKafkaITCase.testKafka
failed with SqlClientException
[ https://issues.apache.org/jira/browse/FLINK-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhijiang updated FLINK-16583:
-----------------------------
Summary: SQLClientKafkaITCase.testKafka failed with SqlClientException (was: SQLClientKafkaITCase.testKafka failed in SqlClientException)
> SQLClientKafkaITCase.testKafka failed with SqlClientException
> -------------------------------------------------------------
>
> Key: FLINK-16583
> URL: https://issues.apache.org/jira/browse/FLINK-16583
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Table SQL / Client, Tests
> Reporter: Zhijiang
> Priority: Critical
> Labels: test-stability
> Fix For: 1.11.0
>
>
> The end-to-end test {{SQLClientKafkaITCase.testKafka}} failed with
> {code:java}
> 18:13:02.425 [ERROR] testKafka[0: kafka-version:0.10 kafka-sql-version:.*kafka-0.10.jar](org.apache.flink.tests.util.kafka.SQLClientKafkaITCase) Time elapsed: 32.246 s <<< ERROR!
> java.io.IOException:
> Process execution failed due error. Error output:Mar 12, 2020 6:11:46 PM org.jline.utils.Log logr
> WARNING: Unable to create a system terminal, creating a dumb terminal (enable debug logging for more information)
> Exception in thread "main" org.apache.flink.table.client.SqlClientException: Could not submit given SQL update statement to cluster.
> at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:131)
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:104)
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)
> at org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.insertIntoAvroTable(SQLClientKafkaITCase.java:178)
> at org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.testKafka(SQLClientKafkaITCase.java:151)
> 18:13:02.425 [ERROR] testKafka[1: kafka-version:0.11 kafka-sql-version:.*kafka-0.11.jar](org.apache.flink.tests.util.kafka.SQLClientKafkaITCase) Time elapsed: 34.539 s <<< ERROR!
> java.io.IOException:
> Process execution failed due error. Error output:Mar 12, 2020 6:12:21 PM org.jline.utils.Log logr
> WARNING: Unable to create a system terminal, creating a dumb terminal (enable debug logging for more information)
> Exception in thread "main" org.apache.flink.table.client.SqlClientException: Could not submit given SQL update statement to cluster.
> at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:131)
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:104)
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:178)
> at org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.insertIntoAvroTable(SQLClientKafkaITCase.java:178)
> at org.apache.flink.tests.util.kafka.SQLClientKafkaITCase.testKafka(SQLClientKafkaITCase.java:151)
> {code}
> [https://api.travis-ci.org/v3/job/661535183/log.txt]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)