Address review comment

linkedin · Jan 22, 2025 · 8846302 · 8846302
1 parent 8d2135a
commit 8846302
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...venice-push-job/src/main/java/com/linkedin/venice/hadoop/input/kafka/KafkaInputSplit.java b/...venice-push-job/src/main/java/com/linkedin/venice/hadoop/input/kafka/KafkaInputSplit.java
@@ -20,12 +20,13 @@ public class KafkaInputSplit implements InputSplit {
   private long startingOffset;
   private long endingOffset;
   private PubSubTopicPartition topicPartition;
-  private PubSubTopicRepository topicRepository;
+  private final PubSubTopicRepository topicRepository;
 
   /**
    * Nullary Constructor for creating the instance inside the Mapper instance.
    */
   public KafkaInputSplit() {
+    topicRepository = new PubSubTopicRepository();
   }
 
   /**