hi,
I change the following config from
flink.shard.getrecords.maxrecordcount: 1000
flink.shard.getrecords.intervalmillis: 200
to
flink.shard.getrecords.maxrecordcount: 1
flink.shard.getrecords.intervalmillis: 1000
and found a few task managers around (10/1000) are becoming very slow.
We als
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 i
