This is an automated email from the ASF dual-hosted git repository. gaoyunhaii 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 0eda2cc35a7 [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception 0eda2cc35a7 is described below commit 0eda2cc35a7185592129df8d4b004acc7a60d3bf Author: Ran Tao <chucheng...@gmail.com> AuthorDate: Fri Mar 25 12:02:34 2022 +0800 [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception This closes #19241. --- .../flink/api/common/serialization/AbstractDeserializationSchema.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-core/src/main/java/org/apache/flink/api/common/serialization/AbstractDeserializationSchema.java b/flink-core/src/main/java/org/apache/flink/api/common/serialization/AbstractDeserializationSchema.java index d0517300519..0b08828bbeb 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/serialization/AbstractDeserializationSchema.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/serialization/AbstractDeserializationSchema.java @@ -108,7 +108,8 @@ public abstract class AbstractDeserializationSchema<T> implements Deserializatio "The implementation of AbstractDeserializationSchema is using a generic variable. " + "This is not supported, because due to Java's generic type erasure, it will not be possible to " + "determine the full type at runtime. For generic implementations, please pass the TypeInformation " - + "or type class explicitly to the constructor."); + + "or type class explicitly to the constructor.", + e); } }