Re: Issues with Flink1.5 SQL-Client

2018-07-03 Thread Timo Walther
Great to hear! Timo Am 03.07.18 um 16:16 schrieb Ashwin Sinha: Hi Chesnay, We got the issue. Thanks for pointing out the issue. By mistake it was running the 1.3.2 jobmanager version, and now moved to 1.5.0 and working smooth. Will be careful from next time. Thanks for all the support and

Re: Issues with Flink1.5 SQL-Client

2018-07-03 Thread Xingcan Cui
Hi Ashwin, I encountered this problem before. You should make sure that the version for your Flink cluster and the version you run the SQL-Client are exactly the same. Best, Xingcan > On Jul 3, 2018, at 10:00 PM, Chesnay Schepler wrote: > > Can you provide us with the JobManager logs? > > Ba

Re: Issues with Flink1.5 SQL-Client

2018-07-03 Thread Chesnay Schepler
Can you provide us with the JobManager logs? Based on the exception i concur with Timo, it looks like the server is either running 1.4 or below, or was started in the legacy mode. On 03.07.2018 15:42, Ashwin Sinha wrote: Hi Timo, Our flink version is 1.5.0 We followed this

Re: Issues with Flink1.5 SQL-Client

2018-07-03 Thread Ashwin Sinha
Hi Timo, Our flink version is 1.5.0 We followed this documentation and started flink cluster same way. Also we are getting more logs https://pastebin.com/fGTW9s2b On Tue, Jul 3, 2018 at 7:01 PM

Re: Issues with Flink1.5 SQL-Client

2018-07-03 Thread Timo Walther
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 u

Issues with Flink1.5 SQL-Client

2018-07-03 Thread 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: nu