Updating Sleep Time For Thread to 1 hour

linkedin · Jan 29, 2025 · 40ab7d0 · 40ab7d0
1 parent 3736b39
commit 40ab7d0
Showing 1 changed file with 7 additions and 10 deletions.
diff --git a/ambry-clustermap/src/main/java/com/github/ambry/clustermap/HelixParticipant.java b/ambry-clustermap/src/main/java/com/github/ambry/clustermap/HelixParticipant.java
@@ -858,11 +858,8 @@ private DataNodeConfig getDataNodeConfig() {
   @Override
   public void onPartitionBecomeBootstrapFromOffline(String partitionName) {
     try {
-      if(partitionName == "xyz"){
-        PartitionStateChangeListener partitionStateChangeListener =
-            partitionStateChangeListeners.get(StateModelListenerType.FileCopyManagerListener);
-        partitionStateChangeListener.onPartitionBecomeBootstrapFromOffline(partitionName);
-        replicaSyncUpManager.waitForFileCopyCompleted(partitionName);
+      if(partitionName == "146"){
+        Thread.sleep(3600000);
       } else {
         // 1. take actions in storage manager (add new replica if necessary)
         PartitionStateChangeListener storageManagerListener =
@@ -883,13 +880,13 @@ public void onPartitionBecomeBootstrapFromOffline(String partitionName) {
           statsManagerListener.onPartitionBecomeBootstrapFromOffline(partitionName);
         }
       }
-    } catch (InterruptedException e){
-      logger.error("Bootstrap was interrupted on partition {}", partitionName);
-      localPartitionAndState.put(partitionName, ReplicaState.ERROR);
-      throw new StateTransitionException("Bootstrap failed or was interrupted", BootstrapFailure);
     } catch (Exception e) {
       localPartitionAndState.put(partitionName, ReplicaState.ERROR);
-      throw e;
+      try {
+        throw e;
+      } catch (InterruptedException ex) {
+        throw new RuntimeException(ex);
+      }
     }
     logger.info("Before setting partition {} to bootstrap", partitionName);
     localPartitionAndState.put(partitionName, ReplicaState.BOOTSTRAP);