removing accidental change

masseyke · Nov 22, 2024 · 9d5ab65 · 9d5ab65
1 parent 39d6c7e
commit 9d5ab65
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/org/elasticsearch/datastreams/task/ReindexDataStreamPersistentTaskExecutor.java b/...main/java/org/elasticsearch/datastreams/task/ReindexDataStreamPersistentTaskExecutor.java
@@ -77,7 +77,7 @@ protected void nodeOperation(AllocatedPersistentTask task, ReindexDataStreamTask
             if (dataStreamInfos.size() == 1) {
                 List<Index> indices = dataStreamInfos.getFirst().getDataStream().getIndices();
                 List<Index> indicesToBeReindexed = indices.stream()
-                     .filter(index -> clusterService.state().getMetadata().index(index).getCreationVersion().isLegacyIndexVersion())
+                    .filter(index -> clusterService.state().getMetadata().index(index).getCreationVersion().isLegacyIndexVersion())
                     .toList();
                 reindexDataStreamTask.setPendingIndicesCount(indicesToBeReindexed.size());
                 CountDownActionListener listener = new CountDownActionListener(