Repository: flink Updated Branches: refs/heads/release-1.4 bafb91eeb -> a044d9d6c
[hotfix] Remove costly logging statements from CEP SharedBuffer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a044d9d6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a044d9d6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a044d9d6 Branch: refs/heads/release-1.4 Commit: a044d9d6caa5e6af2d9edb9321d40617f0ca6f78 Parents: bafb91e Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Wed Feb 14 17:46:51 2018 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Wed Feb 14 17:46:51 2018 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a044d9d6/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java index cb1a68d..36a3656 100644 --- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java +++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java @@ -944,15 +944,12 @@ public class SharedBuffer<K extends Serializable, V> implements Serializable { // the ids of the source and target SharedBufferEntry Integer id = entryIDs.get(sharedBuffer); - Preconditions.checkState(id != null, "Could not find id for entry: " + sharedBuffer); for (SharedBufferEdge<K, V> edge: sharedBuffer.edges) { // in order to serialize the previous relation we simply serialize the ids // of the source and target SharedBufferEntry if (edge.target != null) { Integer targetId = entryIDs.get(edge.getTarget()); - Preconditions.checkState(targetId != null, - "Could not find id for entry: " + edge.getTarget()); target.writeInt(id); target.writeInt(targetId);
