Repository: flink Updated Branches: refs/heads/release-1.3 a30a8be98 -> 5605feb5d
[FLINK-6624] [cep] Fix SharedBuffer#hashCode(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5605feb5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5605feb5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5605feb5 Branch: refs/heads/release-1.3 Commit: 5605feb5dd7c676a8e03102bd93dd6e1d43e19ad Parents: a30a8be Author: kkloudas <kklou...@gmail.com> Authored: Thu May 18 11:27:42 2017 +0200 Committer: kkloudas <kklou...@gmail.com> Committed: Thu May 18 11:35:34 2017 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5605feb5/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 ab134d0..d0f6bf4 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 @@ -754,7 +754,7 @@ public class SharedBuffer<K extends Serializable, V> implements Serializable { @Override public int hashCode() { - return (int) (31 * (timestamp ^ timestamp >>> 32) + 31 * value.hashCode()) + counter; + return (int) (31 * (31 * (timestamp ^ timestamp >>> 32) + value.hashCode()) + counter); } }
