From 88463027fcc486fb1e96f30509935539e6deea93 Mon Sep 17 00:00:00 2001
From: Sushant Mane <sumane@linkedin.com>
Date: Tue, 21 Jan 2025 17:10:26 -0800
Subject: [PATCH] Address review comment

---
 .../linkedin/venice/hadoop/input/kafka/KafkaInputSplit.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/clients/venice-push-job/src/main/java/com/linkedin/venice/hadoop/input/kafka/KafkaInputSplit.java b/clients/venice-push-job/src/main/java/com/linkedin/venice/hadoop/input/kafka/KafkaInputSplit.java
index 2ce0356542..ddd00a5b6c 100644
--- a/clients/venice-push-job/src/main/java/com/linkedin/venice/hadoop/input/kafka/KafkaInputSplit.java
+++ b/clients/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();
   }
 
   /**