diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java index 9a92df5533632..69e7d31e31b4b 100644 --- a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java @@ -59,7 +59,6 @@ public class RocksDBTimeOrderedKeyValueBufferTest { public Sensor sensor; public long offset; - @SuppressWarnings({"rawtypes", "unchecked"}) @BeforeEach public void setUp() { final Metrics metrics = new Metrics(); @@ -82,6 +81,7 @@ private boolean pipeRecord(final String key, final String value, final long time return buffer.put(time, record, context.recordContext()); } + @SuppressWarnings({"rawtypes", "unchecked"}) @Test public void shouldReturnIfRecordWasAdded() { when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde()); @@ -112,6 +112,7 @@ public void shouldAddAndEvictRecord() { assertThat(count.get(), equalTo(1)); } + @SuppressWarnings({"rawtypes", "unchecked"}) @Test public void shouldAddAndEvictRecordTwice() { when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde()); @@ -144,6 +145,7 @@ public void shouldAddAndEvictRecordTwiceWithNonZeroGrace() { assertThat(count.get(), equalTo(1)); } + @SuppressWarnings({"rawtypes", "unchecked"}) @Test public void shouldAddRecordsTwiceAndEvictRecordsOnce() { when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde()); @@ -158,6 +160,7 @@ public void shouldAddRecordsTwiceAndEvictRecordsOnce() { assertThat(count.get(), equalTo(2)); } + @SuppressWarnings({"rawtypes", "unchecked"}) @Test public void shouldDropLateRecords() { when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde()); @@ -180,6 +183,7 @@ public void shouldDropLateRecordsWithNonZeroGrace() { assertNumSizeAndTimestamp(buffer, 2, 1, 84); } + @SuppressWarnings({"rawtypes", "unchecked"}) @Test public void shouldHandleCollidingKeys() { when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());