Skip to content

Commit 230847d

Browse files
tzulitairmetzger
authored andcommitted
[FLINK-4176][kinesis-connector] Remove Java8-specific Long.hashCode() method from Kinesis connector
This closes apache#2215
1 parent 7fb9417 commit 230847d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public SequenceNumber(String sequenceNumber, long subSequenceNumber) {
5757
this.sequenceNumber = checkNotNull(sequenceNumber);
5858
this.subSequenceNumber = subSequenceNumber;
5959

60-
this.cachedHash = 37 * (sequenceNumber.hashCode() + Long.hashCode(subSequenceNumber));
60+
this.cachedHash = 37 * (sequenceNumber.hashCode() + Long.valueOf(subSequenceNumber).hashCode());
6161
}
6262

6363
public boolean isAggregated() {

0 commit comments

Comments
 (0)