Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r152701486
--- Diff:
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java ---
@@ -243,6 +280,25 @@ public StormBase stormBase(String stormId, Runnable
callback) {
return
ClusterUtils.maybeDeserialize(stateStorage.get_data(ClusterUtils.stormPath(stormId),
callback != null), StormBase.class);
}
+ @Override
+ public String stormId(String stormName) {
+ return this.backend.getStormId(stormName);
+ }
+
+ @Override
+ public void syncRemoteIds(Map<String, String> remote) {
+ if (null != remote) {
+ this.backend.syncRemoteIDS(remote);
+ }else {
+ Map<String, String> tmp = new HashMap<>();
+ List<String> activeStorms = activeStorms();
+ for (String stormID: activeStorms) {
--- End diff --
Same here: `stormID` -> `stormId`
---
