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 < [email protected]> wrote: > Hi > > I’m working with a simple pipeline that reads from two Kafka topics one > standard and one compacted in sql. Then create a temporary view doing a > join of the two tables also in sql On top of the view I create two queries > and transform the result to data streams and forward to a sink for each. > > Please look at the DAG > > > It reads from Kafka twice and doing the join twice instead of one time I > don’t understand why. My best guess is because of the transformation to > data stream. > I testing on Flink 1.16.1 on a mini cluster. > > Any suggestions / explanation are much appreciated. > > Med venlig hilsen / Best regards > Lasse Nedergaard > >
