diff --git a/astra/src/main/java/com/slack/astra/metadata/core/AstraPartitioningMetadataStore.java b/astra/src/main/java/com/slack/astra/metadata/core/AstraPartitioningMetadataStore.java index 1177648b7b..fb577eaa17 100644 --- a/astra/src/main/java/com/slack/astra/metadata/core/AstraPartitioningMetadataStore.java +++ b/astra/src/main/java/com/slack/astra/metadata/core/AstraPartitioningMetadataStore.java @@ -230,7 +230,9 @@ public CompletionStage findAsync(String path) { */ public T findSync(String path) { try { - return findAsync(path).toCompletableFuture().get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS); + return findAsync(path) + .toCompletableFuture() + .get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS); } catch (InterruptedException | ExecutionException | TimeoutException e) { throw new InternalMetadataStoreException("Error fetching node at path " + path, e); } @@ -283,7 +285,9 @@ public CompletableFuture> listAsync() { public List listSync() { try { - return listAsync().toCompletableFuture().get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS); + return listAsync() + .toCompletableFuture() + .get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS); } catch (ExecutionException | InterruptedException | TimeoutException e) { throw new InternalMetadataStoreException("Error listing nodes", e); }