[
https://issues.apache.org/jira/browse/FLINK-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-16583:
------------------------------------
Assignee: Timo Walther
> 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
> Assignee: Timo Walther
> 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)
