denis-chudov commented on code in PR #6651:
URL: https://github.com/apache/ignite-3/pull/6651#discussion_r2406064812
##########
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DataNodesManager.java:
##########
@@ -1042,18 +1070,23 @@ private CompletableFuture<Void> msInvokeWithRetry(
CompletableFuture<DataNodesHistoryMetaStorageOperation>
> metaStorageOperationSupplier,
int attemptsLeft,
- CatalogZoneDescriptor zone
+ CatalogZoneDescriptor zone,
+ boolean ensureContextIsPresent
) {
if (attemptsLeft <= 0) {
throw new AssertionError("Failed to perform meta storage invoke,
maximum number of attempts reached [zone=" + zone + "].");
}
// Get locally on the first attempt, otherwise it means that invoke
has failed because of different value in meta storage,
// so we need to retrieve the value from meta storage.
- DataNodeHistoryContextMetaStorageGetter msGetter = attemptsLeft ==
MAX_ATTEMPTS_ON_RETRY
+ DataNodeHistoryContextMetaStorageGetter msGetter0 = attemptsLeft ==
MAX_ATTEMPTS_ON_RETRY
? this::getDataNodeHistoryContextMsLocally
: this::getDataNodeHistoryContextMs;
+ DataNodeHistoryContextMetaStorageGetter msGetter =
ensureContextIsPresent
+ ? keys -> msGetter0.get(keys).thenCompose(context ->
ensureContextIsPresent(context, keys, zone.id()))
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
