[ https://issues.apache.org/jira/browse/FLINK-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ted Yu updated FLINK-3733: -------------------------- Description: {code} if (serializedRegisteredTypesWithKryoSerializers != null) { registeredTypesWithKryoSerializers = serializedRegisteredTypesWithKryoSerializers.deserializeValue(userCodeClassLoader); } else { registeredTypesWithKryoSerializerClasses = new LinkedHashMap<>(); } {code} When serializedRegisteredTypesWithKryoSerializers is null, registeredTypesWithKryoSerializers is not assigned. was: {code} if (serializedRegisteredTypesWithKryoSerializers != null) { registeredTypesWithKryoSerializers = serializedRegisteredTypesWithKryoSerializers.deserializeValue(userCodeClassLoader); } else { registeredTypesWithKryoSerializerClasses = new LinkedHashMap<>(); } {code} When serializedRegisteredTypesWithKryoSerializers is null, registeredTypesWithKryoSerializers is not assigned. > registeredTypesWithKryoSerializers is not assigned in > ExecutionConfig#deserializeUserCode() > ------------------------------------------------------------------------------------------- > > Key: FLINK-3733 > URL: https://issues.apache.org/jira/browse/FLINK-3733 > Project: Flink > Issue Type: Bug > Reporter: Ted Yu > Priority: Minor > > {code} > if (serializedRegisteredTypesWithKryoSerializers != null) { > registeredTypesWithKryoSerializers = > serializedRegisteredTypesWithKryoSerializers.deserializeValue(userCodeClassLoader); > } else { > registeredTypesWithKryoSerializerClasses = new LinkedHashMap<>(); > } > {code} > When serializedRegisteredTypesWithKryoSerializers is null, > registeredTypesWithKryoSerializers is not assigned. -- This message was sent by Atlassian JIRA (v6.3.4#6332)