You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/06/12 06:42:12 UTC
[flink] 01/02: [hotfix] Improve exception message for parsing kryo
serializer classes from config
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b1472a8b504a02baf226e97469161ccc3fc0d98b
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Thu Jun 11 12:07:58 2020 +0200
[hotfix] Improve exception message for parsing kryo serializer classes from config
---
.../src/main/java/org/apache/flink/api/common/ExecutionConfig.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
index 291bced..73ff232 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
@@ -1222,7 +1222,11 @@ public class ExecutionConfig implements Serializable, Archiveable<ArchivedExecut
try {
return parseKryoSerializers(classLoader, kryoSerializers);
} catch (Exception e) {
- throw new IllegalArgumentException("Could not configure kryo serializers from " + kryoSerializers);
+ throw new IllegalArgumentException(
+ String.format(
+ "Could not configure kryo serializers from %s. The expected format is:" +
+ "'class:<fully qualified class name>,serializer:<fully qualified serializer name>;...",
+ kryoSerializers), e);
}
}