Hi folks,
We are trying to setup flink sql client
<https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/table/sqlClient.html>.
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!
--
*Ashwin Sinha *| Data Engineer
ashwin.si...@go-mmt.com <shivam.sha...@go-mmt.com> | 9452075361
<https://www.makemytrip.com/> <https://www.goibibo.com/>
<https://www.redbus.in/>2nd floor, Tower B Divyashree Technopolis Yemalur,
Bangalore, Karnataka 560037, India
<https://www.redbus.in/>
--
::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.
