Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6149#discussion_r195341250
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java ---
@@ -278,15 +278,15 @@
* Unlimited be default.
*/
public static ConfigOption<Long>
rateLimitingInputBytesPerSeconds(String scheme) {
- return ConfigOptions.key("fs." + scheme +
".limit.rateLimitingInput").defaultValue(0L);
+ return ConfigOptions.key("fs." + scheme +
".limit.input-rate-limit").defaultValue(0L);
--- End diff --
Please rename also variables/methods to match the new config name and match
the other properties above:
`s/rateLimitingInputBytesPerSeconds/fileSystemConnectionLimitInputRate/g`
`s/rateLimitingOututBytesPerSeconds/fileSystemConnectionLimitOutputRate/g`
---
