We are running Flink 1.10 about 900+ task managers with kinesis as an input stream. The problem we are having now is that only Max Age of kinesis shard is growing and the average age of that kinesis is very low meaning most of shards having very low age. We already checked the data skew issue but it's quite uniformly distributed. Any idea how this can happen and how to debug on this issue? I'm wondering is it possible to have one TM's operator stuck and source still fetching data so that Kinesis's age still going high.
Terry
