Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6149#discussion_r195138105
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java
---
@@ -731,6 +791,9 @@ public boolean checkNewBytesAndMark(long timestamp)
throws IOException {
public void write(int b) throws IOException {
try {
originalStream.write(b);
+ if (fs.outputRateLimiter != null){
--- End diff --
With optional: `rate.ifPresent(RateLimiter::acquire);`
---
