Re: Reworking use of TableEnvironment due to API change in 1.15

Hi, one correction on the above, both cases when I mentioned tableEnv.executeAsync I was referring to StreamExecutionEnvironment's executeAsync, sorry for the typo. Any thoughts on the issue? Thanks Tamas On Thu, Aug 4, 2022 at 3:44 PM Tamas Kiss wrote: > Hi Experts, > > We

Reworking use of TableEnvironment due to API change in 1.15

Hi Experts, We are trying to upgrade to flink-1.1.5 and have to refactor our code due to the following method has been removed from TableEnvironment: void sqlUpdate(String sql). In our code we mix the SQL and DataStream API and use the sqlUpdate method to buffer several insert statements, also add