Re: Help to understand sql DAG

I have found a ticket 20637 and as I understand it this is the problem I have. No activity since September 2021 on this major issue. Med venlig hilsen / Best regards Lasse Nedergaard > Den 8. mar. 2023 kl. 09.11 skrev Shammon FY : > >  >

Re: Help to understand sql DAG

Sure. query String = “Select table1.*, table2.*From table1 inner join table2 on table1.Id = table2.refId”;TableEnv.createTemporaryView(“myView”, tableEnv.sqlQuery(query));newQuery1 String = “select * from myView where myField1>10”newQuery2 String = “select * from myView where myField2 >1999”Then ta

Re: Help to understand sql DAG

Hi Can you provide more information about the job such as sql? It may help to find the answer Best, Shammon On Thu, Mar 2, 2023 at 6:02 PM Lasse Nedergaard < lassenedergaardfl...@gmail.com> wrote: > Hi > > I’m working with a simple pipeline that reads from two Kafka topics one > standard and o