Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.9.0
Description
I think it is caused by: FLINK-12483. The reason is that the BackPressureStatsTrackerImpl samples only the main thread. FLINK-12483 introduced a separate thread for executing the sources in the mailbox model. It is similar to other old bug that concerned only Kafka source: FLINK-3456
Attachments
Issue Links
- is caused by
-
FLINK-12483 Support (legacy) SourceFunctions with mailbox
- Closed
- relates to
-
FLINK-3456 Backpressure Monitoring does not work for Kafka Sources
- Closed
- links to