Skip to content

Commit 68064f6

Browse files
SNOW-569611 Fix boxed Long comparison
1 parent 6a57ba0 commit 68064f6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/net/snowflake/ingest/streaming/internal/ChannelCache.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ void removeChannelIfSequencersMatch(SnowflakeStreamingIngestChannelInternal chan
6565
// We need to compare the channel sequencer in case the old channel was already been
6666
// removed
6767
return channelInCache != null
68-
&& channelInCache.getChannelSequencer() == channel.getChannelSequencer() // TODO: 4/11/22 this is wrong because the long is boxed so == checks refs and not the value
68+
&& channelInCache.getChannelSequencer().equals(channel.getChannelSequencer())
6969
&& v.remove(channel.getName()) != null
7070
&& v.isEmpty()
7171
? null

0 commit comments

Comments
 (0)