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