[FLINK-2963] Dependence on SerializationUtils#deserialize() should be avoided

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Robert Metzger
• Reporter: Ted Yu
• Created: 04/Nov/15 00:15
• Updated: 07/Dec/15 15:53
• Resolved: 07/Dec/15 15:53

Description

There is a problem with `SerializationUtils` from Apache Commons
Lang. Here is an open issue where the class will throw a
`ClassNotFoundException` even if the class is in the classpath in a
multiple-classloader environment:

https://issues.apache.org/jira/browse/LANG-1049

			state = (HashMap<String, Serializable>) SerializationUtils.deserialize(bais);
./flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/NonKeyedWindowOperator.java
			state = (HashMap<String, Serializable>) SerializationUtils.deserialize(bais);
./flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
		return SerializationUtils.deserialize(message);
./flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/JavaDefaultStringSchema.java
		T copied = SerializationUtils.deserialize(SerializationUtils
./flink-streaming-java/src/test/java/org/apache/flink/streaming/util/MockOutput.java

We should move away from SerializationUtils.deserialize()