Hi Sara, do you have logs? Any exceptions in them?
Best, -- Alexander Fedulov | Solutions Architect +49 1514 6265796 <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Tony) Cheng On Tue, May 19, 2020 at 11:28 PM Sara Arshad <sara.arshad...@gmail.com> wrote: > Hi, > > I have been using Flink with kinesis analytics. > I have a stream of data and also I need a cache which I update every 300 > seconds. > To share the cache data with the kinesis stream elements, I used a > broadcast stream as I implemented a SourceFunction which gets the data from > DB and broadcast it to the next stream which is > KeyedBroadcastProcessFuction. > But after adding the broadcast stream (in the previous version I hadn't > a cache and I was using KeyedProcessFuction for kinesis stream), when I > execute it in kinesis analytics, it keeps restarting about every 20 > minutes. > Could you please help me that what could be the issue? > > Best regards, > Sara Arshad >
