You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2021/06/13 11:03:25 UTC
[kafka] branch trunk updated: MINOR: clean up unneeded
`@SuppressWarnings` (#10855)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 787b4fe MINOR: clean up unneeded `@SuppressWarnings` (#10855)
787b4fe is described below
commit 787b4fe9550389a2ca6d1131b32aff6e4f8610d1
Author: Josep Prat <jo...@aiven.io>
AuthorDate: Sun Jun 13 13:00:14 2021 +0200
MINOR: clean up unneeded `@SuppressWarnings` (#10855)
Reviewers: Luke Chen <sh...@gmail.com>, Matthias J. Sax <mj...@apache.org>, Chia-Ping Tsai <ch...@gmail.com>
---
.../main/java/org/apache/kafka/streams/StreamsConfig.java | 1 -
.../kstream/internals/CogroupedStreamAggregateBuilder.java | 1 -
.../kstream/internals/graph/KTableKTableJoinNode.java | 1 -
.../streams/kstream/internals/graph/ProcessorParameters.java | 1 -
.../streams/kstream/internals/graph/TableProcessorNode.java | 1 -
.../kafka/streams/processor/internals/ProcessorAdapter.java | 1 -
.../streams/processor/internals/ProcessorContextImpl.java | 1 -
.../streams/processor/internals/RecordDeserializer.java | 1 -
.../kafka/streams/state/internals/RecordConverters.java | 1 -
.../state/internals/RocksDBTimeOrderedWindowStore.java | 3 ---
.../state/internals/TimestampedWindowStoreBuilder.java | 3 ---
.../internals/WindowToTimestampedWindowByteStoreAdapter.java | 3 ---
.../test/java/org/apache/kafka/streams/KafkaStreamsTest.java | 1 -
.../streams/integration/EosV2UpgradeIntegrationTest.java | 1 -
.../integration/StandbyTaskCreationIntegrationTest.java | 1 -
.../kstream/internals/InternalStreamsBuilderTest.java | 1 -
.../streams/kstream/internals/KGroupedTableImplTest.java | 3 ---
.../kafka/streams/kstream/internals/KTableImplTest.java | 1 -
.../kstream/internals/SessionWindowedKStreamImplTest.java | 1 -
.../kstream/internals/SlidingWindowedKStreamImplTest.java | 1 -
.../kstream/internals/TimeWindowedKStreamImplTest.java | 1 -
.../kstream/internals/TransformerSupplierAdapterTest.java | 1 -
.../foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java | 1 -
.../foreignkeyjoin/SubscriptionWrapperSerdeTest.java | 2 --
.../processor/internals/ProcessorContextImplTest.java | 8 ++------
.../state/internals/CachingPersistentWindowStoreTest.java | 12 ------------
.../streams/state/internals/FilteredCacheIteratorTest.java | 1 -
.../state/internals/MeteredTimestampedKeyValueStoreTest.java | 1 -
.../streams/state/internals/RocksDBWindowStoreTest.java | 1 -
.../org/apache/kafka/streams/tests/StreamsUpgradeTest.java | 1 -
.../tests/StreamsUpgradeToCooperativeRebalanceTest.java | 1 -
.../org/apache/kafka/test/GenericInMemoryKeyValueStore.java | 1 -
.../kafka/test/GenericInMemoryTimestampedKeyValueStore.java | 1 -
33 files changed, 2 insertions(+), 58 deletions(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
index 2ef29af..cb6d58b 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -135,7 +135,6 @@ import static org.apache.kafka.common.config.ConfigDef.parseType;
* @see ConsumerConfig
* @see ProducerConfig
*/
-@SuppressWarnings("deprecation")
public class StreamsConfig extends AbstractConfig {
private static final Logger log = LoggerFactory.getLogger(StreamsConfig.class);
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java
index c758526..6cb529d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java
@@ -48,7 +48,6 @@ class CogroupedStreamAggregateBuilder<K, VOut> {
CogroupedStreamAggregateBuilder(final InternalStreamsBuilder builder) {
this.builder = builder;
}
- @SuppressWarnings("unchecked")
<KR> KTable<KR, VOut> build(final Map<KGroupedStreamImpl<K, ?>, Aggregator<? super K, ? super Object, VOut>> groupPatterns,
final Initializer<VOut> initializer,
final NamedInternal named,
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java
index 0ca1e35..ac8d821 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java
@@ -209,7 +209,6 @@ public class KTableKTableJoinNode<K, V1, V2, VR> extends BaseJoinProcessorNode<K
return this;
}
- @SuppressWarnings("unchecked")
public KTableKTableJoinNode<K, V1, V2, VR> build() {
return new KTableKTableJoinNode<>(
nodeName,
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java
index 018d2b7..ec2ce48 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java
@@ -60,7 +60,6 @@ public class ProcessorParameters<KIn, VIn, KOut, VOut> {
return oldProcessorSupplier;
}
- @SuppressWarnings("unchecked")
KTableSource<KIn, VIn> kTableSourceSupplier() {
// This cast always works because KTableSource hasn't been converted yet.
return oldProcessorSupplier == null
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java
index 5254c57..f13631f 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java
@@ -57,7 +57,6 @@ public class TableProcessorNode<K, V> extends GraphNode {
"} " + super.toString();
}
- @SuppressWarnings("unchecked")
@Override
public void writeToTopology(final InternalTopologyBuilder topologyBuilder, final Properties props) {
final String processorName = processorParameters.processorName();
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java
index f067bbd..687e92f 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java
@@ -46,7 +46,6 @@ public final class ProcessorAdapter<KIn, VIn, KOut, VOut> implements Processor<K
this.delegate = delegate;
}
- @SuppressWarnings("unchecked")
@Override
public void init(final ProcessorContext<KOut, VOut> context) {
// It only makes sense to use this adapter internally to Streams, in which case
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
index bd7ece4..ce06cb1 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
@@ -263,7 +263,6 @@ public class ProcessorContextImpl extends AbstractProcessorContext<Object, Objec
streamTask.requestCommit();
}
- @SuppressWarnings("deprecation") // removing #schedule(final long intervalMs,...) will fix this
@Override
public Cancellable schedule(final Duration interval,
final PunctuationType type,
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java
index a965187..b5c821a 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java
@@ -50,7 +50,6 @@ class RecordDeserializer {
* {@link DeserializationExceptionHandler.DeserializationHandlerResponse#FAIL FAIL}
* or throws an exception itself
*/
- @SuppressWarnings("deprecation")
ConsumerRecord<Object, Object> deserialize(final ProcessorContext processorContext,
final ConsumerRecord<byte[], byte[]> rawRecord) {
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java
index 1f2e593..ad3c91e 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java
@@ -23,7 +23,6 @@ import java.nio.ByteBuffer;
public final class RecordConverters {
private static final RecordConverter IDENTITY_INSTANCE = record -> record;
- @SuppressWarnings("deprecation")
private static final RecordConverter RAW_TO_TIMESTAMED_INSTANCE = record -> {
final byte[] rawValue = record.value();
final long timestamp = record.timestamp();
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java
index f8ba883..37aaa27 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java
@@ -66,7 +66,6 @@ public class RocksDBTimeOrderedWindowStore
throw new UnsupportedOperationException();
}
- @SuppressWarnings("deprecation")
@Override
public WindowStoreIterator<byte[]> fetch(final Bytes key, final long timeFrom, final long timeTo) {
throw new UnsupportedOperationException();
@@ -77,7 +76,6 @@ public class RocksDBTimeOrderedWindowStore
throw new UnsupportedOperationException();
}
- @SuppressWarnings("deprecation") // note, this method must be kept if super#fetch(...) is removed
@Override
public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes keyFrom,
final Bytes keyTo,
@@ -105,7 +103,6 @@ public class RocksDBTimeOrderedWindowStore
throw new UnsupportedOperationException();
}
- @SuppressWarnings("deprecation") // note, this method must be kept if super#fetchAll(...) is removed
@Override
public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long timeFrom, final long timeTo) {
throw new UnsupportedOperationException();
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java
index 417b45b..b3727f5 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java
@@ -135,7 +135,6 @@ public class TimestampedWindowStoreBuilder<K, V>
return wrapped.fetch(key, time);
}
- @SuppressWarnings("deprecation")
@Override
public WindowStoreIterator<byte[]> fetch(final Bytes key,
final long timeFrom,
@@ -150,7 +149,6 @@ public class TimestampedWindowStoreBuilder<K, V>
return wrapped.backwardFetch(key, timeFrom, timeTo);
}
- @SuppressWarnings("deprecation")
@Override
public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes keyFrom,
final Bytes keyTo,
@@ -167,7 +165,6 @@ public class TimestampedWindowStoreBuilder<K, V>
return wrapped.backwardFetch(keyFrom, keyTo, timeFrom, timeTo);
}
- @SuppressWarnings("deprecation")
@Override
public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long timeFrom,
final long timeTo) {
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java
index 8d895fc..f7999d3 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java
@@ -54,7 +54,6 @@ class WindowToTimestampedWindowByteStoreAdapter implements WindowStore<Bytes, by
}
@Override
- @SuppressWarnings("deprecation")
public WindowStoreIterator<byte[]> fetch(final Bytes key,
final long timeFrom,
final long timeTo) {
@@ -83,7 +82,6 @@ class WindowToTimestampedWindowByteStoreAdapter implements WindowStore<Bytes, by
}
@Override
- @SuppressWarnings("deprecation")
public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes keyFrom,
final Bytes keyTo,
final long timeFrom,
@@ -126,7 +124,6 @@ class WindowToTimestampedWindowByteStoreAdapter implements WindowStore<Bytes, by
}
@Override
- @SuppressWarnings("deprecation")
public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long timeFrom,
final long timeTo) {
return new KeyValueToTimestampedKeyValueIteratorAdapter<>(store.fetchAll(timeFrom, timeTo));
diff --git a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
index 300a9e9..54a15cc 100644
--- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
@@ -1079,7 +1079,6 @@ public class KafkaStreamsTest {
}
}
- @SuppressWarnings("unchecked")
@Deprecated // testing old PAPI
private Topology getStatefulTopology(final String inputTopic,
final String outputTopic,
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/EosV2UpgradeIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/EosV2UpgradeIntegrationTest.java
index 4543b99..b6aab86 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/EosV2UpgradeIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/EosV2UpgradeIntegrationTest.java
@@ -875,7 +875,6 @@ public class EosV2UpgradeIntegrationTest {
final KStream<Long, Long> input = builder.stream(MULTI_PARTITION_INPUT_TOPIC);
input.transform(new TransformerSupplier<Long, Long, KeyValue<Long, Long>>() {
- @SuppressWarnings("unchecked")
@Override
public Transformer<Long, Long, KeyValue<Long, Long>> get() {
return new Transformer<Long, Long, KeyValue<Long, Long>>() {
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java
index ab22ae6..f924e08 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java
@@ -105,7 +105,6 @@ public class StandbyTaskCreationIntegrationTest {
builder.addStateStore(keyValueStoreBuilder);
builder.stream(INPUT_TOPIC, Consumed.with(Serdes.Integer(), Serdes.Integer()))
.transform(() -> new Transformer<Integer, Integer, KeyValue<Integer, Integer>>() {
- @SuppressWarnings("unchecked")
@Override
public void init(final ProcessorContext context) {}
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java
index 1fffb50..76ae717 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java
@@ -51,7 +51,6 @@ import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
-@SuppressWarnings("unchecked")
public class InternalStreamsBuilderTest {
private static final String APP_ID = "app-id";
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java
index 130e299..ee4b136 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java
@@ -201,7 +201,6 @@ public class KGroupedTableImplTest {
}
}
- @SuppressWarnings("unchecked")
@Test
public void shouldReduceAndMaterializeResults() {
final KeyValueMapper<String, Number, KeyValue<String, Integer>> intProjection =
@@ -235,7 +234,6 @@ public class KGroupedTableImplTest {
}
}
- @SuppressWarnings("unchecked")
@Test
public void shouldCountAndMaterializeResults() {
builder
@@ -265,7 +263,6 @@ public class KGroupedTableImplTest {
}
}
- @SuppressWarnings("unchecked")
@Test
public void shouldAggregateAndMaterializeResults() {
builder
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java
index b979d3e..1885d57 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java
@@ -574,7 +574,6 @@ public class KTableImplTest {
assertThrows(NullPointerException.class, () -> table.transformValues(valueTransformerSupplier, (Materialized) null));
}
- @SuppressWarnings("unchecked")
@Test
public void shouldThrowNullPointerOnTransformValuesWithKeyWhenStoreNamesNull() {
final ValueTransformerWithKeySupplier<String, String, ?> valueTransformerSupplier =
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java
index d6e56ba..abca688 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java
@@ -283,7 +283,6 @@ public class SessionWindowedKStreamImplTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldThrowNullPointerOnMaterializedReduceIfNamedIsNull() {
assertThrows(NullPointerException.class, () -> stream.reduce(MockReducer.STRING_ADDER, (Named) null));
}
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java
index d6b26bf..f012ced 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java
@@ -361,7 +361,6 @@ public class SlidingWindowedKStreamImplTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldThrowNullPointerOnMaterializedReduceIfNamedIsNull() {
assertThrows(NullPointerException.class, () -> windowedStream.reduce(MockReducer.STRING_ADDER, (Named) null));
}
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java
index c35da00..38fda9d 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java
@@ -300,7 +300,6 @@ public class TimeWindowedKStreamImplTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldThrowNullPointerOnMaterializedReduceIfNamedIsNull() {
assertThrows(NullPointerException.class, () -> windowedStream.reduce(
MockReducer.STRING_ADDER,
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.java
index 115855d..1eb55d0 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.java
@@ -34,7 +34,6 @@ import static org.hamcrest.core.IsSame.sameInstance;
import static org.hamcrest.core.IsNot.not;
import static org.hamcrest.MatcherAssert.assertThat;
-@SuppressWarnings("unchecked")
public class TransformerSupplierAdapterTest extends EasyMockSupport {
private ProcessorContext context;
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java
index 1bd1bd2..30fc0c3 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java
@@ -127,7 +127,6 @@ public class SubscriptionResponseWrapperSerdeTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldThrowExceptionWithBadVersionTest() {
final long[] hashedValue = null;
assertThrows(UnsupportedVersionException.class,
diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java
index b7ce34f..e937efe 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java
@@ -59,7 +59,6 @@ public class SubscriptionWrapperSerdeTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldThrowExceptionOnNullKeyTest() {
final String originalKey = null;
final long[] hashedValue = Murmur3.hash128(new byte[] {(byte) 0xFF, (byte) 0xAA, (byte) 0x00, (byte) 0x19});
@@ -68,7 +67,6 @@ public class SubscriptionWrapperSerdeTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldThrowExceptionOnNullInstructionTest() {
final String originalKey = "originalKey";
final long[] hashedValue = Murmur3.hash128(new byte[] {(byte) 0xFF, (byte) 0xAA, (byte) 0x00, (byte) 0x19});
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java
index 9412e55..13816d7 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java
@@ -220,7 +220,6 @@ public class ProcessorContextImplTest {
}
@Test
- @SuppressWarnings("deprecation")
public void globalWindowStoreShouldBeReadOnly() {
doTest("GlobalWindowStore", (Consumer<WindowStore<String, Long>>) store -> {
verifyStoreCannotBeInitializedOrClosed(store);
@@ -238,7 +237,6 @@ public class ProcessorContextImplTest {
@Test
- @SuppressWarnings("deprecation")
public void globalTimestampedWindowStoreShouldBeReadOnly() {
doTest("GlobalTimestampedWindowStore", (Consumer<TimestampedWindowStore<String, Long>>) store -> {
verifyStoreCannotBeInitializedOrClosed(store);
@@ -325,7 +323,6 @@ public class ProcessorContextImplTest {
}
@Test
- @SuppressWarnings("deprecation")
public void localWindowStoreShouldNotAllowInitOrClose() {
doTest("LocalWindowStore", (Consumer<WindowStore<String, Long>>) store -> {
verifyStoreCannotBeInitializedOrClosed(store);
@@ -345,7 +342,6 @@ public class ProcessorContextImplTest {
}
@Test
- @SuppressWarnings("deprecation")
public void localTimestampedWindowStoreShouldNotAllowInitOrClose() {
doTest("LocalTimestampedWindowStore", (Consumer<TimestampedWindowStore<String, Long>>) store -> {
verifyStoreCannotBeInitializedOrClosed(store);
@@ -615,7 +611,7 @@ public class ProcessorContextImplTest {
return timestampedKeyValueStoreMock;
}
- @SuppressWarnings({"unchecked", "deprecation"})
+ @SuppressWarnings("unchecked")
private WindowStore<String, Long> windowStoreMock() {
final WindowStore<String, Long> windowStore = mock(WindowStore.class);
@@ -638,7 +634,7 @@ public class ProcessorContextImplTest {
return windowStore;
}
- @SuppressWarnings({"unchecked", "deprecation"})
+ @SuppressWarnings("unchecked")
private TimestampedWindowStore<String, Long> timestampedWindowStoreMock() {
final TimestampedWindowStore<String, Long> windowStore = mock(TimestampedWindowStore.class);
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java
index 8bdf8b7..7c316f4 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java
@@ -236,7 +236,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldPutFetchFromCache() {
cachingStore.put(bytesKey("a"), bytesValue("a"), DEFAULT_TIMESTAMP);
cachingStore.put(bytesKey("b"), bytesValue("b"), DEFAULT_TIMESTAMP);
@@ -275,7 +274,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldPutFetchRangeFromCache() {
cachingStore.put(bytesKey("a"), bytesValue("a"), DEFAULT_TIMESTAMP);
cachingStore.put(bytesKey("b"), bytesValue("b"), DEFAULT_TIMESTAMP);
@@ -317,7 +315,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldGetAllBackwardFromCache() {
cachingStore.put(bytesKey("a"), bytesValue("a"), DEFAULT_TIMESTAMP);
cachingStore.put(bytesKey("b"), bytesValue("b"), DEFAULT_TIMESTAMP);
@@ -340,7 +337,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldFetchAllWithinTimestampRange() {
final String[] array = {"a", "b", "c", "d", "e", "f", "g", "h"};
for (int i = 0; i < array.length; i++) {
@@ -382,7 +378,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldFetchAllBackwardWithinTimestampRange() {
final String[] array = {"a", "b", "c", "d", "e", "f", "g", "h"};
for (int i = 0; i < array.length; i++) {
@@ -439,7 +434,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldForwardDirtyItemsWhenFlushCalled() {
final Windowed<String> windowedKey =
new Windowed<>("1", new TimeWindow(DEFAULT_TIMESTAMP, DEFAULT_TIMESTAMP + WINDOW_SIZE));
@@ -456,7 +450,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldForwardOldValuesWhenEnabled() {
cachingStore.setFlushListener(cacheListener, true);
final Windowed<String> windowedKey =
@@ -485,7 +478,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldForwardOldValuesWhenDisabled() {
final Windowed<String> windowedKey =
new Windowed<>("1", new TimeWindow(DEFAULT_TIMESTAMP, DEFAULT_TIMESTAMP + WINDOW_SIZE));
@@ -616,7 +608,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldClearNamespaceCacheOnClose() {
cachingStore.put(bytesKey("a"), bytesValue("a"), 0L);
assertEquals(1, cache.size());
@@ -637,7 +628,6 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldThrowIfTryingToWriteToClosedCachingStore() {
cachingStore.close();
assertThrows(InvalidStateStoreException.class, () -> cachingStore.put(bytesKey("a"), bytesValue("a"), 0L));
@@ -786,13 +776,11 @@ public class CachingPersistentWindowStoreTest {
}
@Test
- @SuppressWarnings("deprecation")
public void shouldThrowNullPointerExceptionOnPutNullKey() {
assertThrows(NullPointerException.class, () -> cachingStore.put(null, bytesValue("anyValue"), 0L));
}
@Test
- @SuppressWarnings("deprecation")
public void shouldNotThrowNullPointerExceptionOnPutNullValue() {
cachingStore.put(bytesKey("a"), null, 0L);
}
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java
index f49d881..bd79433 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java
@@ -50,7 +50,6 @@ public class FilteredCacheIteratorTest {
}
};
- @SuppressWarnings("unchecked")
private final KeyValueStore<Bytes, LRUCacheEntry> store = new GenericInMemoryKeyValueStore<>("my-store");
private final KeyValue<Bytes, LRUCacheEntry> firstEntry = KeyValue.pair(Bytes.wrap("a".getBytes()),
new LRUCacheEntry("1".getBytes()));
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.java
index eb48e0c..bce87ef 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.java
@@ -426,7 +426,6 @@ public class MeteredTimestampedKeyValueStoreTest {
}
@Test
- @SuppressWarnings("unchecked")
public void shouldNotThrowExceptionIfSerdesCorrectlySetFromProcessorContext() {
final MeteredTimestampedKeyValueStore<String, Long> store = new MeteredTimestampedKeyValueStore<>(
inner,
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java
index 2b890f1..3bb9f14 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java
@@ -43,7 +43,6 @@ import static org.apache.kafka.test.StreamsTestUtils.valuesToSet;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
-@SuppressWarnings("PointlessArithmeticExpression")
public class RocksDBWindowStoreTest extends AbstractWindowBytesStoreTest {
private static final String STORE_NAME = "rocksDB window store";
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
index 2ad07f2..2fabf97 100644
--- a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
@@ -65,7 +65,6 @@ import static org.apache.kafka.streams.processor.internals.assignment.StreamsAss
public class StreamsUpgradeTest {
- @SuppressWarnings("unchecked")
public static void main(final String[] args) throws Exception {
if (args.length < 1) {
System.err.println("StreamsUpgradeTest requires one argument (properties-file) but no provided: ");
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
index bd5752a..19e81ac 100644
--- a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
@@ -37,7 +37,6 @@ import java.util.Set;
public class StreamsUpgradeToCooperativeRebalanceTest {
- @SuppressWarnings("unchecked")
public static void main(final String[] args) throws Exception {
if (args.length < 1) {
System.err.println("StreamsUpgradeToCooperativeRebalanceTest requires one argument (properties-file) but no args provided");
diff --git a/streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java b/streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java
index 72e6c266..d9a2afe 100644
--- a/streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java
+++ b/streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java
@@ -60,7 +60,6 @@ public class GenericInMemoryKeyValueStore<K extends Comparable, V>
@Deprecated
@Override
- @SuppressWarnings("unchecked")
/* This is a "dummy" store used for testing;
it does not support restoring from changelog since we allow it to be serde-ignorant */
public void init(final ProcessorContext context, final StateStore root) {
diff --git a/streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java b/streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java
index c77cbac..2198d18 100644
--- a/streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java
+++ b/streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java
@@ -61,7 +61,6 @@ public class GenericInMemoryTimestampedKeyValueStore<K extends Comparable, V>
@Deprecated
@Override
- @SuppressWarnings("unchecked")
/* This is a "dummy" store used for testing;
it does not support restoring from changelog since we allow it to be serde-ignorant */
public void init(final ProcessorContext context, final StateStore root) {