Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6149#discussion_r195138248
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java
---
@@ -741,6 +804,10 @@ public void write(int b) throws IOException {
public void write(byte[] b, int off, int len) throws
IOException {
try {
originalStream.write(b, off, len);
+ if (fs.outputRateLimiter != null){
--- End diff --
With optional: `rate.ifPresent(limiter -> limiter.acquire(len));`
---
