[jira] [Created] (FLINK-16583) SQLClientKafkaITCase.testKafka failed in SqlClientException

[Shang Yuanchun (Jira)]

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)