You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/02/21 07:23:35 UTC
[flink] 01/02: [FLINK-16019][runtime] fix
ContinuousFileReaderOperator error handling
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0f71ab3edb9318f2c6cf301be0245087aeb35445
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Wed Feb 12 15:31:56 2020 +0100
[FLINK-16019][runtime] fix ContinuousFileReaderOperator error handling
---
.../streaming/api/functions/source/ContinuousFileReaderOperator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
index 3b2e2af..ed8ab4a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
@@ -376,7 +376,7 @@ class ContinuousFileReaderOperator<OUT> extends AbstractStreamOperator<OUT>
try {
cleanUp();
} catch (Exception ex) {
- e = ExceptionUtils.firstOrSuppressed(ex, e);
+ e = ex;
}
}
{
@@ -442,7 +442,7 @@ class ContinuousFileReaderOperator<OUT> extends AbstractStreamOperator<OUT>
try {
r.run();
} catch (Exception e) {
- firstException = ExceptionUtils.firstOrSuppressed(firstException, e);
+ firstException = ExceptionUtils.firstOrSuppressed(e, firstException);
}
}
currentSplit = null;