Added retries for getCollection in DataStructuresProcessor - Fixes
@@ -1031,8 +1031,12 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen
}
}
+ return retryTopologySafe(new IgniteOutClosureX<T>() {
+ @Override public T applyx() throws IgniteCheckedException {
return c.applyx(cache.context());
}
+ });
+ }
/**
* Awaits for processor initialization.
