Re: Recommended way to submit a SQL job via code without getting tied to a Flink version?

2021-07-01 Thread Sonam Mandal
...@ververica.com ; Jark Wu ; Timo Walther Subject: Re: Recommended way to submit a SQL job via code without getting tied to a Flink version? Hi Sonam! To answer this, let me quickly provide some background on the two ways flink deployments / job submissions work. See also here for some background: https

Re: Recommended way to submit a SQL job via code without getting tied to a Flink version?

2021-06-30 Thread Stephan Ewen
s, > Sonam > > > ---------- > *From:* Matthias Pohl > *Sent:* Tuesday, June 29, 2021 02:29 > *To:* Sonam Mandal > *Cc:* user@flink.apache.org; Jark Wu; Timo Walther > *Subject:* Re: Recommended way to submit a SQL job via code without > getting tied t

Re: Recommended way to submit a SQL job via code without getting tied to a Flink version?

2021-06-29 Thread Sonam Mandal
way to handle this? Is this safe and does it work in all scenarios? Thanks, Sonam From: Matthias Pohl Sent: Tuesday, June 29, 2021 02:29 To: Sonam Mandal Cc: user@flink.apache.org; Jark Wu; Timo Walther Subject: Re: Recommended way to submit a SQL job via code

Re: Recommended way to submit a SQL job via code without getting tied to a Flink version?

2021-06-29 Thread Matthias Pohl
Hi Sonam, what's the reason for not using the Flink SQL client? Because of the version issue? I only know that FlinkSQL's state is not backwards-compatible between major Flink versions [1]. But that seems to be unrelated to what you describe. I'm gonna add Jark and Timo to this thread. Maybe, they

Recommended way to submit a SQL job via code without getting tied to a Flink version?

2021-06-22 Thread Sonam Mandal
Hello, We've written a simple tool which takes SQL statements as input and uses a StreamTableEnvironment​ to eventually submit this to the Flink cluster. We've noticed that the Flink library versions we depend on must match the Flink version running in our Kubernetes cluster for the job submiss