alievmirza commented on code in PR #2605:
URL: https://github.com/apache/ignite-3/pull/2605#discussion_r1347459475
##########
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZoneManager.java:
##########
@@ -288,6 +289,24 @@ public CompletableFuture<Set<String>> dataNodes(long
causalityToken, int zoneId)
return causalityDataNodesEngine.dataNodes(causalityToken, zoneId);
}
+ /**
+ * Returns the actual data nodes of the specified zone.
+ *
+ * @param zoneId Zone id.
+ * @return The future which will be completed with data nodes for the
zoneId.
+ */
+ public CompletableFuture<Set<String>> currentDataNodes(int zoneId) {
+ return
metaStorageManager.get(zoneDataNodesKey(zoneId)).thenApply(dataNodesEntry -> {
+ int catalogVersion = catalogManager.latestCatalogVersion();
Review Comment:
I've removed this method
##########
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZoneManager.java:
##########
@@ -288,6 +289,24 @@ public CompletableFuture<Set<String>> dataNodes(long
causalityToken, int zoneId)
return causalityDataNodesEngine.dataNodes(causalityToken, zoneId);
}
+ /**
+ * Returns the actual data nodes of the specified zone.
+ *
+ * @param zoneId Zone id.
+ * @return The future which will be completed with data nodes for the
zoneId.
+ */
+ public CompletableFuture<Set<String>> currentDataNodes(int zoneId) {
+ return
metaStorageManager.get(zoneDataNodesKey(zoneId)).thenApply(dataNodesEntry -> {
Review Comment:
I've removed this method
--
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]
