flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [FLINK-4176][kinesis-connector] Remove Java8-specific `Long.hashCode()` method from Kinesis connector
Date Fri, 08 Jul 2016 10:20:20 GMT
Repository: flink
Updated Branches:
  refs/heads/master 7fb94173e -> 230847d52


[FLINK-4176][kinesis-connector] Remove Java8-specific `Long.hashCode()` method from Kinesis
connector

This closes #2215


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/230847d5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/230847d5
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/230847d5

Branch: refs/heads/master
Commit: 230847d52a2be163119abfd860e4c92a13031acc
Parents: 7fb9417
Author: Gordon Tai <tzulitai@gmail.com>
Authored: Fri Jul 8 16:52:28 2016 +0800
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Fri Jul 8 12:06:50 2016 +0200

----------------------------------------------------------------------
 .../flink/streaming/connectors/kinesis/model/SequenceNumber.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/230847d5/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java
----------------------------------------------------------------------
diff --git a/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java
b/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java
index e5c6def..021f53f 100644
--- a/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java
+++ b/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java
@@ -57,7 +57,7 @@ public class SequenceNumber implements Serializable {
 		this.sequenceNumber = checkNotNull(sequenceNumber);
 		this.subSequenceNumber = subSequenceNumber;
 
-		this.cachedHash = 37 * (sequenceNumber.hashCode() + Long.hashCode(subSequenceNumber));
+		this.cachedHash = 37 * (sequenceNumber.hashCode() + Long.valueOf(subSequenceNumber).hashCode());
 	}
 
 	public boolean isAggregated() {


Mime
View raw message