diff --git a/src/java/voldemort/client/rebalance/RebalancePartitionsInfo.java b/src/java/voldemort/client/rebalance/RebalancePartitionsInfo.java index 31acfe9057..beb69ef3c0 100644 --- a/src/java/voldemort/client/rebalance/RebalancePartitionsInfo.java +++ b/src/java/voldemort/client/rebalance/RebalancePartitionsInfo.java @@ -93,7 +93,7 @@ public RebalancePartitionsInfo(int stealerNodeId, this.initialCluster = Utils.notNull(initialCluster); } - private synchronized void findMaxReplicaType(HashMap>> storeToReplicaToPartitionList) { + private void findMaxReplicaType(HashMap>> storeToReplicaToPartitionList) { for(Entry>> entry: storeToReplicaToPartitionList.entrySet()) { for(Entry> replicaToPartitionList: entry.getValue().entrySet()) { if(replicaToPartitionList.getKey() > this.maxReplica) { @@ -103,7 +103,7 @@ private synchronized void findMaxReplicaType(HashMap map = reader.readObject(); @@ -113,7 +113,7 @@ public synchronized static RebalancePartitionsInfo create(String line) { } } - public synchronized static RebalancePartitionsInfo create(Map map) { + public static RebalancePartitionsInfo create(Map map) { int stealerId = (Integer) map.get("stealerId"); int donorId = (Integer) map.get("donorId"); List unbalancedStoreList = Utils.uncheckedCast(map.get("unbalancedStores")); @@ -321,7 +321,7 @@ public synchronized String toJsonString() { } @Override - public boolean equals(Object o) { + public synchronized boolean equals(Object o) { if(this == o) return true; if(o == null || getClass() != o.getClass()) @@ -348,7 +348,7 @@ public boolean equals(Object o) { } @Override - public int hashCode() { + public synchronized int hashCode() { int result = stealerId; result = 31 * result + donorId; result = 31 * result + initialCluster.hashCode();