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
