MINOR: fix rawtype warning in StandbyTask (#17203)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
apache · Sep 16, 2024 · aaf3fc0 · aaf3fc0
1 parent f1c011a
commit aaf3fc0
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 12 deletions.
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
@@ -49,8 +49,7 @@ public class StandbyTask extends AbstractTask implements Task {
  private final Sensor updateSensor;
  private final StreamsMetricsImpl streamsMetrics;
 
- @SuppressWarnings("rawtypes")
- protected final InternalProcessorContext processorContext;
+ protected final InternalProcessorContext<?, ?> processorContext;
 
  /**
  * @param id the ID of this task
@@ -61,7 +60,6 @@ public class StandbyTask extends AbstractTask implements Task {
  * @param stateMgr the {@link ProcessorStateManager} for this task
  * @param stateDirectory the {@link StateDirectory} created by the thread
  */
- @SuppressWarnings("rawtypes")
  StandbyTask(final TaskId id,
  final Set<TopicPartition> inputPartitions,
  final ProcessorTopology topology,
@@ -70,7 +68,7 @@ public class StandbyTask extends AbstractTask implements Task {
  final ProcessorStateManager stateMgr,
  final StateDirectory stateDirectory,
  final ThreadCache cache,
- final InternalProcessorContext processorContext) {
+ final InternalProcessorContext<?, ?> processorContext) {
  super(
  id,
  topology,
@@ -333,11 +331,6 @@ public void addRecords(final TopicPartition partition, final Iterable<ConsumerRe
  throw new IllegalStateException("Attempted to add records to task " + id() + " for invalid input partition " + partition);
  }
 
- @SuppressWarnings("rawtypes")
- InternalProcessorContext processorContext() {
- return processorContext;
- }
-
  /**
  * Produces a string representation containing useful information about a Task.
  * This is useful in debugging scenarios.

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java
@@ -92,7 +92,7 @@ Collection<Task> createTasks(final Map<TaskId, Set<TopicPartition>> tasksToBeCre
  partitions,
  stateUpdaterEnabled);
 
- final InternalProcessorContext<Object, Object> context = new ProcessorContextImpl(
+ final InternalProcessorContext<?, ?> context = new ProcessorContextImpl(
  taskId,
  applicationConfig,
  stateManager,
@@ -147,7 +147,7 @@ StandbyTask createStandbyTask(final TaskId taskId,
  final Set<TopicPartition> inputPartitions,
  final ProcessorTopology topology,
  final ProcessorStateManager stateManager,
- final InternalProcessorContext<Object, Object> context) {
+ final InternalProcessorContext<?, ?> context) {
  final StandbyTask task = new StandbyTask(
  taskId,
  inputPartitions,

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java
@@ -598,7 +598,7 @@ private StandbyTask createStandbyTask() {
  streamsMetrics
  );
 
- final InternalProcessorContext context = new ProcessorContextImpl(
+ final InternalProcessorContext<?, ?> context = new ProcessorContextImpl(
  taskId,
  config,
  stateManager,