Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4821#discussion_r144514570
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/NonDuplicatingTypeSerializer.java
---
@@ -190,13 +190,6 @@ public int hashCode() {
return typeSerializer.hashCode();
}
- private void readObject(ObjectInputStream ois) throws IOException,
ClassNotFoundException {
--- End diff --
removing this means that `elementList` and `identityMap` will not be
initialised after deserialisation.
---