Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5521#discussion_r173453379
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -340,6 +341,10 @@
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5521#discussion_r173454031
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -819,6 +819,10 @@ public void open(FileInputSplit
Github user steveloughran commented on a diff in the pull request:
https://github.com/apache/flink/pull/5521#discussion_r169604725
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -819,6 +819,10 @@ public void open(FileInputSplit
Github user steveloughran commented on a diff in the pull request:
https://github.com/apache/flink/pull/5521#discussion_r169275364
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -706,6 +700,9 @@ public void open(FileInputSplit
Github user steveloughran commented on a diff in the pull request:
https://github.com/apache/flink/pull/5521#discussion_r169132404
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -691,6 +691,12 @@ public void open(FileInputSplit
GitHub user ChengzhiZhao opened a pull request:
https://github.com/apache/flink/pull/5521
[FLINK-8599] Improve the failure behavior of the FileInputFormat for â¦
## What is the purpose of the change
This pull request is intent to improve the failure behavior of the
