flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [FLINK-7760] Fix deserialization of NFA state in CEP library
Date Wed, 07 Feb 2018 19:03:25 GMT
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 <aljoscha.krettek@gmail.com>
Authored: Wed Feb 7 17:33:03 2018 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
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);


Mime
View raw message