Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r152703493
--- Diff:
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java ---
@@ -647,6 +625,22 @@ public static boolean isConnectionReady(IConnection
connection) {
return executorsAssignedToThisWorker;
}
+ private Assignment getLocalAssignment(Map<String, Object> conf,
IStormClusterState stormClusterState, String topologyId) {
+ if (!ConfigUtils.isLocalMode(conf)) {
+ try{
--- End diff --
space between y and {
---