Sanil15 commented on a change in pull request #1281: SAMZA-2378: Container
Placements support for Standby containers enabled jobs
URL: https://github.com/apache/samza/pull/1281#discussion_r382868897
##########
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java
##########
@@ -425,6 +423,15 @@ public void handleExpiredResourceRequest(String
containerID, SamzaResourceReques
}
}
+ /**
+ * Fetches a list of standby container for an active container
+ * @param activeContainerId logical id of the container ex: 0,1,2
+ * @return list of standby containers ex: for active container 0: {0-0, 0-1}
+ */
+ List<String> getStandbyList(String activeContainerId) {
+ return this.standbyContainerConstraints.get(activeContainerId);
+ }
Review comment:
So I need this exposed from StandbyContainerManager because I need to refer
to metadata maintained in ContainerManager for checking active actions on each
standby replica, the method here just exposes the list of standby replicas!
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
