Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r158688366
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java
---
@@ -69,10 +65,8 @@
public ReadClusterState(Supervisor supervisor) throws Exception {
this.superConf = supervisor.getConf();
this.stormClusterState = supervisor.getStormClusterState();
- this.syncSupEventManager = supervisor.getEventManger();
- this.assignmentVersions = new AtomicReference<>(new HashMap<>());
this.assignmentId = supervisor.getAssignmentId();
- this.iSuper = supervisor.getiSupervisor();
+ this.iSupervisor = supervisor.getiSupervisor();
--- End diff --
done
---
