Hi Vtygoss, Can you explain a bit more about your ideal pipeline? Is the batch data bounded data or could you also process it in streaming execution mode? And is the streaming data derived from the batch data or do you just want to ensure that the batch has been finished before running the processing of the streaming data?
Best Regards, Alexander (sending again because I accidentally left out the user ml in the reply on the first try) On Tue, Nov 30, 2021 at 12:38 PM vtygoss <vtyg...@126.com> wrote: > Hi, community! > > > By Flink, I want to unify batch process and streaming process in data > production pipeline. Batch process is used to process inventory data, then > streaming process is used to process incremental data. But I meet a > problem, there is no state in batch and the result is error if i run > stream process directly. > > > So how to run streaming process accurately after batch process is > completed? Is there any doc or demo to handle this scenario? > > > Thanks for your any reply or suggestion! > > > Best Regards! > > > > >