Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5393
@tzulitai done adding test
(CI failure BackPressureStatsTrackerITCase.testBackPressuredProducer
unrelated to this PR)---
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5393
@tzulitai done adding test
(CI failure BackPressureStatsTrackerITCase.testBackPressuredProducer
unrelated to this PR)---