From 35a5e6f22bc9be06c2d1bec93d3704bdbf67b658 Mon Sep 17 00:00:00 2001
From: inv-jishnu <31100916+inv-jishnu@users.noreply.github.com>
Date: Sat, 31 May 2025 10:08:55 +0530
Subject: [PATCH] Reset data chunk id counter for import process  (#2697)

---
 .../core/dataimport/processor/CsvImportProcessor.java           | 2 +-
 .../core/dataimport/processor/JsonImportProcessor.java          | 2 +-
 .../core/dataimport/processor/JsonLinesImportProcessor.java     | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/CsvImportProcessor.java b/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/CsvImportProcessor.java
index 0c68d5e566..f16bb8137b 100644
--- a/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/CsvImportProcessor.java
+++ b/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/CsvImportProcessor.java
@@ -39,7 +39,7 @@
  */
 public class CsvImportProcessor extends ImportProcessor {
   private static final DataLoaderObjectMapper OBJECT_MAPPER = new DataLoaderObjectMapper();
-  private static final AtomicInteger dataChunkIdCounter = new AtomicInteger(0);
+  private final AtomicInteger dataChunkIdCounter = new AtomicInteger(0);
 
   /**
    * Creates a new CsvImportProcessor with the specified parameters.
diff --git a/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonImportProcessor.java b/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonImportProcessor.java
index 733a5afa96..deecf6cce5 100644
--- a/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonImportProcessor.java
+++ b/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonImportProcessor.java
@@ -43,7 +43,7 @@
 public class JsonImportProcessor extends ImportProcessor {
 
   private static final DataLoaderObjectMapper OBJECT_MAPPER = new DataLoaderObjectMapper();
-  private static final AtomicInteger dataChunkIdCounter = new AtomicInteger(0);
+  private final AtomicInteger dataChunkIdCounter = new AtomicInteger(0);
 
   public JsonImportProcessor(ImportProcessorParams params) {
     super(params);
diff --git a/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonLinesImportProcessor.java b/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonLinesImportProcessor.java
index a121a106a5..3b85e381d3 100644
--- a/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonLinesImportProcessor.java
+++ b/data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/JsonLinesImportProcessor.java
@@ -37,7 +37,7 @@
 public class JsonLinesImportProcessor extends ImportProcessor {
 
   private static final DataLoaderObjectMapper OBJECT_MAPPER = new DataLoaderObjectMapper();
-  private static final AtomicInteger dataChunkIdCounter = new AtomicInteger(0);
+  private final AtomicInteger dataChunkIdCounter = new AtomicInteger(0);
 
   /**
    * Creates a new JsonLinesImportProcessor with the specified parameters.