File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
fdb-record-layer-core/src/main/java/com/apple/foundationdb/record/provider/foundationdb Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -1028,10 +1028,12 @@ public CompletableFuture<Void> rebuildIndexAsync(@Nonnull FDBRecordStore store)
1028
1028
}))
1029
1029
.thenCompose (vignore -> setIndexingTypeOrThrow (store , false ))
1030
1030
.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
+ }
1033
1035
return null ;
1034
- })) ;
1036
+ });
1035
1037
}
1036
1038
1037
1039
abstract CompletableFuture <Void > rebuildIndexInternalAsync (FDBRecordStore store );
You can’t perform that action at this time.
0 commit comments