cleaning up

Signed-off-by: Himshikha Gupta <[email protected]>
opensearch-project · 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())