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.
---