Repository: flink Updated Branches: refs/heads/master b2fc8b427 -> c212701d5
[FLINK-7760] Fix deserialization of NFA state in CEP library Before, the condition was being read via in.read() and not in.readFully() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c212701d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c212701d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c212701d Branch: refs/heads/master Commit: c212701d56cfe9cffd9e5dc1e34c3483a50f8182 Parents: b2fc8b4 Author: Aljoscha Krettek <[email protected]> Authored: Wed Feb 7 17:33:03 2018 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Wed Feb 7 20:00:04 2018 +0100 ---------------------------------------------------------------------- .../flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c212701d/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java index deee0a1..5624db9 100644 --- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java +++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java @@ -1132,7 +1132,7 @@ public class NFA<T> implements Serializable { int length = in.readInt(); byte[] serCondition = new byte[length]; - in.read(serCondition); + in.readFully(serCondition); ByteArrayInputStream bais = new ByteArrayInputStream(serCondition); ObjectInputStream ois = new ObjectInputStream(bais);
