You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2019/05/10 07:51:57 UTC
[flink] branch master updated: [hotfix] Don't swallow exception in
FromElementsFunction
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9ffd7e7 [hotfix] Don't swallow exception in FromElementsFunction
9ffd7e7 is described below
commit 9ffd7e788588be5697dabc4518e881f3b9cbb48f
Author: Aljoscha Krettek <al...@gmail.com>
AuthorDate: Fri May 10 09:47:13 2019 +0200
[hotfix] Don't swallow exception in FromElementsFunction
---
.../flink/streaming/api/functions/source/FromElementsFunction.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/FromElementsFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
index 691d3d6..980aed0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
@@ -141,7 +141,7 @@ public class FromElementsFunction<T> implements SourceFunction<T>, CheckpointedF
catch (Exception e) {
throw new IOException("Failed to deserialize an element from the source. " +
"If you are using user-defined serialization (Value and Writable types), check the " +
- "serialization functions.\nSerializer is " + serializer);
+ "serialization functions.\nSerializer is " + serializer, e);
}
this.numElementsEmitted = this.numElementsToSkip;
@@ -157,7 +157,7 @@ public class FromElementsFunction<T> implements SourceFunction<T>, CheckpointedF
catch (Exception e) {
throw new IOException("Failed to deserialize an element from the source. " +
"If you are using user-defined serialization (Value and Writable types), check the " +
- "serialization functions.\nSerializer is " + serializer);
+ "serialization functions.\nSerializer is " + serializer, e);
}
synchronized (lock) {