saves 1 zk call

apache · Jan 16, 2025 · 1be0316 · 1be0316
1 parent 8c8d8d3
commit 1be0316
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...r/src/main/java/org/apache/pinot/controller/api/resources/PinotRealtimeTableResource.java b/...r/src/main/java/org/apache/pinot/controller/api/resources/PinotRealtimeTableResource.java
@@ -238,8 +238,10 @@ public JsonNode getForceCommitJobStatus(
     controllerJobZKMetadata.put(CommonConstants.ControllerJob.CONSUMING_SEGMENTS_YET_TO_BE_COMMITTED_LIST,
         JsonUtils.objectToString(segmentsYetToBeCommitted));
 
-    _pinotHelixResourceManager.updateForceCommitJobMetadata(forceCommitJobId, segmentsYetToBeCommitted,
-        controllerJobZKMetadata);
+    if (segmentsYetToBeCommitted.size() < segmentsToCheck.size()) {
+      _pinotHelixResourceManager.updateForceCommitJobMetadata(forceCommitJobId, segmentsYetToBeCommitted,
+          controllerJobZKMetadata);
+    }
 
     Map<String, Object> result = new HashMap<>(controllerJobZKMetadata);
     result.put("numberOfSegmentsYetToBeCommitted", segmentsYetToBeCommitted.size());