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 can add more insights. Matthias [1] https://issues.apache.org/jira/browse/FLINK-20823 On Tue, Jun 22, 2021 at 9:44 PM Sonam Mandal <soman...@linkedin.com> wrote: > 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 submission to > be successful. If the versions don't match, the job submission goes through > but the job errors out for various reasons. We do not want to use the SQL > shell (which I also believe is version specific and must run on the same > pod as the Job Manager). > > Is there any version agnostic way to submit SQL jobs to the Flink cluster? > > Thanks, > Sonam >
