This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new 3be78d01a2c [FLINK-26788][core] Add cause when
AbstractDeserializationSchema throw exception
3be78d01a2c is described below
commit 3be78d01a2c36cb89a91d43f08155a17ffb6cd7e
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);
}
}
