Skip to content

Commit 1888749

Browse files
committed
Itarate targets explicitly after rebuild
1 parent 06350d6 commit 1888749

File tree

1 file changed

+5
-3
lines changed
  • fdb-record-layer-core/src/main/java/com/apple/foundationdb/record/provider/foundationdb

1 file changed

+5
-3
lines changed

fdb-record-layer-core/src/main/java/com/apple/foundationdb/record/provider/foundationdb/IndexingBase.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1028,10 +1028,12 @@ public CompletableFuture<Void> rebuildIndexAsync(@Nonnull FDBRecordStore store)
10281028
}))
10291029
.thenCompose(vignore -> setIndexingTypeOrThrow(store, false))
10301030
.thenCompose(vignore -> rebuildIndexInternalAsync(store))
1031-
.thenCompose(vignore -> forEachTargetIndex(index -> {
1032-
clearHeartbeatSingleTarget(store, index);
1031+
.thenApply(vignore -> {
1032+
for (Index index: common.getTargetIndexes()) {
1033+
clearHeartbeatSingleTarget(store, index);
1034+
}
10331035
return null;
1034-
}));
1036+
});
10351037
}
10361038

10371039
abstract CompletableFuture<Void> rebuildIndexInternalAsync(FDBRecordStore store);

0 commit comments

Comments
 (0)