Hi all,
We are running Flink on AWS Kinesis Data Analytics and lately. After
the Flink 1.11 upgrades, we have noticed some of our apps have continuous
backpressure since the Flink job starts. However, we have been running
these apps for a while now and if we decrease the source parallelism to try
to reduce the backpressure, we see the app overall throughput drops
slightly comparing to when the source parallelism was still high. Just
wondering, if it's okay we keep the app configuration as it is (tolerating
the backpressure), since it's pretty stable and have good performance.
Thanks,
Jason
