fixed codeStyle errors (lines longer than 140 chars)

Signed-off-by: Nicholas Knize <nknize@amazon.com>
opensearch-project · Apr 11, 2021 · 29e1d85 · 29e1d85
1 parent 8edcfd7
commit 29e1d85
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/server/src/main/java/org/opensearch/repositories/blobstore/BlobStoreRepository.java b/server/src/main/java/org/opensearch/repositories/blobstore/BlobStoreRepository.java
@@ -1055,7 +1055,8 @@ private List<String> cleanupStaleRootFiles(long previousGeneration, Collection<S
         return Collections.emptyList();
     }
 
-    private void cleanupStaleIndices(GroupedActionListener<DeleteResult> listener, BlockingQueue<Map.Entry<String, BlobContainer>> staleIndicesToDelete) {
+    private void cleanupStaleIndices(GroupedActionListener<DeleteResult> listener,
+                                     BlockingQueue<Map.Entry<String, BlobContainer>> staleIndicesToDelete) {
         final GroupedActionListener<DeleteResult> groupedListener = new GroupedActionListener<>(ActionListener.wrap(deleteResults -> {
             DeleteResult deleteResult = DeleteResult.ZERO;
             for (DeleteResult result : deleteResults) {
@@ -1079,7 +1080,9 @@ private void cleanupStaleIndices(GroupedActionListener<DeleteResult> listener, B
         }
     }
 
-    private void executeOneStaleIndexDelete(GroupedActionListener<DeleteResult> listener, BlockingQueue<Map.Entry<String, BlobContainer>> staleIndicesToDelete) throws InterruptedException {
+    private void executeOneStaleIndexDelete(GroupedActionListener<DeleteResult> listener,
+                                            BlockingQueue<Map.Entry<String, BlobContainer>> staleIndicesToDelete)
+        throws InterruptedException {
         Map.Entry<String, BlobContainer> indexEntry = staleIndicesToDelete.poll(0L, TimeUnit.MILLISECONDS);
         if (indexEntry != null) {
             final String indexSnId = indexEntry.getKey();
@@ -1095,7 +1098,8 @@ private void executeOneStaleIndexDelete(GroupedActionListener<DeleteResult> list
                             "but failed to clean up their index folders", metadata.name(), indexSnId), e);
                 } catch (Exception e) {
                     assert false : e;
-                    logger.warn(new ParameterizedMessage("[{}] Exception during cleanup of stale index [{}]", metadata.name(), indexSnId), e);
+                    logger.warn(() ->
+                        new ParameterizedMessage("[{}] Exception during cleanup of stale index [{}]", metadata.name(), indexSnId), e);
                 }
 
                 executeOneStaleIndexDelete(listener, staleIndicesToDelete);