Repository: flink Updated Branches: refs/heads/release-1.4 82f395781 -> 5f9e367be
[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/5f9e367b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5f9e367b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5f9e367b Branch: refs/heads/release-1.4 Commit: 5f9e367be6429383be5d0f1ff80e3b77d5a0dda8 Parents: 82f3957 Author: Aljoscha Krettek <[email protected]> Authored: Wed Feb 7 17:33:03 2018 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Wed Feb 7 20:02:34 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/5f9e367b/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 7092d73..963efa8 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 @@ -1163,7 +1163,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);
