MINOR: remove unnecessary nulllity check (apache#7282)

Minor code enhancement: remove unnecessary check of nullity. Reviewers: Bill Bejeck <[email protected]>
amedia · Sep 4, 2019 · caaf253 · caaf253
1 parent 8dc80e2
commit caaf253
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java
@@ -63,9 +63,6 @@ public void put(final Bytes key, final byte[] value, final long windowStartTimes
     @Override
     public byte[] fetch(final Bytes key, final long timestamp) {
         final byte[] bytesValue = wrapped().get(WindowKeySchema.toStoreKeyBinary(key, timestamp, seqnum));
-        if (bytesValue == null) {
-            return null;
-        }
         return bytesValue;
     }