Re: Issues with Flink1.5 SQL-Client

Posted by Timo Walther on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Issues-with-Flink1-5-SQL-Client-tp21178p21180.html

Hi Ashwin,

which Flink version is your (local cluster)? Are you executing Flink in the default (new deployment) or legacy mode? The SQL client supports only the new "FLIP-6" deployment model. I'm not sure about your error message but it might be related to that.

Regards,
Timo


Am 03.07.18 um 14:42 schrieb Ashwin Sinha:

Hi folks,

We are trying to setup flink sql client. It is still in development phase, but flink-1.5 contains beta version of this feature.

Our environment:

Kafka-
Topic: test_flink_state_check

Kafka Key: null
Kafka Value example: {"state": 299, "number": 299} 

Flink-
Jobmanager: http://localhost:8080/
conf/sql-client-defaults.yaml: https://pastebin.com/zGb3qs7E

Then we start sql-client shell by 

./bin/sql-client.sh embedded

When we run

select * from [tablename]

the result shell hangs and after sometime it exits without printing any data and give following error on screen: https://pastebin.com/wuitQx1a

Complete stacktrace in flink logs: https://pastebin.com/mgk06xeG

Please assist us in resolving this!

--

::DISCLAIMER::

----------------------------------------------------------------------------------------------------------------------------------------------------

This message is intended only for the use of the addressee and may contain information that is privileged, confidential and exempt from disclosure under applicable law. If the reader of this message is not the intended recipient, or the employee or agent responsible for delivering the message to the intended recipient, you are hereby notified that any dissemination, distribution or copying of this communication is strictly prohibited. If you have received this e-mail in error, please notify us immediately by return e-mail and delete this e-mail and all attachments from your system.