You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Zhijiang (Jira)" <ji...@apache.org> on 2020/03/13 06:26:00 UTC
[jira] [Created] (FLINK-16583) SQLClientKafkaITCase.testKafka
failed in SqlClientException
Zhijiang created FLINK-16583:
--------------------------------
Summary: SQLClientKafkaITCase.testKafka failed in 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
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)