Repository: apache/flink
File: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java (Java)

Code before:

    /**
     * If any connection limit is configured, this option can be optionally set to define after
     * which time (in milliseconds) stream opening fails with a timeout exception, if no stream
     * connection becomes available. Unlimited timeout be default.
     */
    public static ConfigOption<Long> fileSystemConnectionLimitTimeout(String scheme) {
        return ConfigOptions.key("fs." + scheme + ".limit.timeout").longType().defaultValue(0L);
    }

    /**
     * If any connection limit is configured, this option can be optionally set to define after
     * which time (in milliseconds) inactive streams are reclaimed. This option can help to prevent
     * that inactive streams make up the full pool of limited connections, and no further
     * connections can be established. Unlimited timeout be default.
     */
    public static ConfigOption<Long> fileSystemConnectionLimitStreamInactivityTimeout(
            String scheme) {
        return ConfigOptions.key("fs." + scheme + ".limit.stream-timeout")
                .longType()
                .defaultValue(0L);
    }

    /**
     * Explicitly resolves the conflict between multiple FileSystemFactory implementations when
     * multiple jars are loaded for the same schema. Primary use is to allow configuration based
     * migration between file systems without the need to build separate images.
     *
     * <p>Config key pattern: {@code fs.<scheme>.priority.<factoryClassName>}
     */
    public static ConfigOption<Integer> fileSystemFactoryPriority(String scheme, String className) {
        return ConfigOptions.key("fs." + scheme + ".priority." + className)
                .intType()
                .noDefaultValue()
                .withDescription(
                        "Priority for the filesystem factory '"
                                + className
                                + "' when multiple factories register for the '"
                                + scheme
                                + "' scheme. Higher priority wins. "
                                + "When not set, the factory's declared priority is used.");
    }
}


Review comment (suggestion):
```suggestion
     * multiple jars are loaded for the same scheme. Primary use is to allow configuration based
```

Code after:

    /**
     * If any connection limit is configured, this option can be optionally set to define after
     * which time (in milliseconds) stream opening fails with a timeout exception, if no stream
     * connection becomes available. Unlimited timeout be default.
     */
    public static ConfigOption<Long> fileSystemConnectionLimitTimeout(String scheme) {
        return ConfigOptions.key("fs." + scheme + ".limit.timeout").longType().defaultValue(0L);
    }

    /**
     * If any connection limit is configured, this option can be optionally set to define after
     * which time (in milliseconds) inactive streams are reclaimed. This option can help to prevent
     * that inactive streams make up the full pool of limited connections, and no further
     * connections can be established. Unlimited timeout be default.
     */
    public static ConfigOption<Long> fileSystemConnectionLimitStreamInactivityTimeout(
            String scheme) {
        return ConfigOptions.key("fs." + scheme + ".limit.stream-timeout")
                .longType()
                .defaultValue(0L);
    }

    /**
     * Explicitly resolves the conflict between multiple FileSystemFactory implementations when
     * multiple jars are loaded for the same scheme. Primary use is to allow configuration based
     * migration between file systems without the need to build separate images.
     *
     * <p>Config key pattern: {@code fs.<scheme>.priority.<factoryClassName>}
     */
    public static ConfigOption<Integer> fileSystemFactoryPriority(String scheme, String className) {
        return ConfigOptions.key("fs." + scheme + ".priority." + className)
                .intType()
                .noDefaultValue()
                .withDescription(
                        "Priority for the filesystem factory '"
                                + className
                                + "' when multiple factories register for the '"
                                + scheme
                                + "' scheme. Higher priority wins. "
                                + "When not set, the factory's declared priority is used.");
    }
}