sborya commented on a change in pull request #1430:
URL: https://github.com/apache/samza/pull/1430#discussion_r492874508
##########
File path: samza-core/src/main/java/org/apache/samza/config/SystemConfig.java
##########
@@ -102,8 +112,15 @@ public SystemConfig(Config config) {
* @param systemName System name
* @return SystemAdmin of the system if it exists, otherwise null.
*/
+ public SystemAdmin getSystemAdmin(String systemName, String adminLabel) {
+ if (systemAdminMap.isEmpty() || (systemAdminMap.containsKey(systemName) &&
systemAdminMap.get(systemName).isStopped())) {
Review comment:
no need for isEmpty() check.
----------------------------------------------------------------
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]
