Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201375170
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
---
@@ -41,6 +44,8 @@
@Internal
class HadoopRecoverableFsDataOutputStream extends
RecoverableFsDataOutputStream {
+ private static final long LEASE_TIMEOUT = 100000L;
--- End diff --
Can we add digit grouping chars here? Makes it easier to read...
---
