cleaning up

Signed-off-by: Himshikha Gupta <[email protected]>
himshikha · Sep 23, 2024 · 1b5edaa · 1b5edaa
1 parent 1948321
commit 1b5edaa
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 8 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/remote/ClusterStateChecksum.java b/server/src/main/java/org/opensearch/gateway/remote/ClusterStateChecksum.java
@@ -186,10 +186,8 @@ public ClusterStateChecksum(ClusterState clusterState) {
         } catch (InterruptedException e) {
             throw new RemoteStateTransferException("Failed to create checksum for cluster state.", e);
         }
-        logger.info("checksum execution time {}", System.currentTimeMillis() - start);
-
         createClusterStateChecksum();
-
+        logger.debug("Checksum execution time {}", System.currentTimeMillis() - start);
     }
 
     private void executeChecksumTask(Function<BufferedChecksumStreamOutput, Void> checksumTask, Consumer<Long> checksumConsumer, ExecutorService executorService, CountDownLatch latch) {
@@ -199,10 +197,9 @@ private void executeChecksumTask(Function<BufferedChecksumStreamOutput, Void> ch
                 checksumConsumer.accept(checksum);
                 latch.countDown();
             } catch (IOException  e) {
-                throw new RuntimeException(e);
-            }git 
+                throw new RemoteStateTransferException("Failed to execute checksum task", e);
+            }
         });
-
     }
 
     private long createChecksum(Function<BufferedChecksumStreamOutput, Void> o) throws IOException {

diff --git a/server/src/main/java/org/opensearch/gateway/remote/RemoteClusterStateService.java b/server/src/main/java/org/opensearch/gateway/remote/RemoteClusterStateService.java
@@ -156,7 +156,7 @@ public class RemoteClusterStateService implements Closeable {
 
     public static final Setting<RemoteClusterStateValidationMode> REMOTE_CLUSTER_STATE_CHECKSUM_VALIDATION_MODE_SETTING = new Setting<>(
         "cluster.remote_store.state.checksum_validation.mode",
-        RemoteClusterStateValidationMode.FAILURE.name(),
+        RemoteClusterStateValidationMode.NONE.name(),
         RemoteClusterStateValidationMode::parseString,
         Setting.Property.Dynamic,
         Setting.Property.NodeScope

diff --git a/server/src/main/java/org/opensearch/gateway/remote/RemoteManifestManager.java b/server/src/main/java/org/opensearch/gateway/remote/RemoteManifestManager.java
@@ -103,7 +103,6 @@ RemoteClusterStateManifestInfo uploadManifest(
         boolean committed,
         int codecVersion
     ) {
-        logger.info("checksum created {}", clusterStateChecksum);
         synchronized (this) {
             ClusterMetadataManifest.Builder manifestBuilder = ClusterMetadataManifest.builder();
             manifestBuilder.clusterTerm(clusterState.term())