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 <[email protected]> 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;
