|
@@ -51,7 +51,7 @@ public class DatanodeInfo extends DatanodeID implements Node {
|
|
private long lastUpdate;
|
|
private long lastUpdate;
|
|
private long lastUpdateMonotonic;
|
|
private long lastUpdateMonotonic;
|
|
private int xceiverCount;
|
|
private int xceiverCount;
|
|
- private String location = NetworkTopology.DEFAULT_RACK;
|
|
|
|
|
|
+ private volatile String location = NetworkTopology.DEFAULT_RACK;
|
|
private String softwareVersion;
|
|
private String softwareVersion;
|
|
private List<String> dependentHostNames = new LinkedList<>();
|
|
private List<String> dependentHostNames = new LinkedList<>();
|
|
private String upgradeDomain;
|
|
private String upgradeDomain;
|
|
@@ -293,11 +293,11 @@ public class DatanodeInfo extends DatanodeID implements Node {
|
|
|
|
|
|
/** network location */
|
|
/** network location */
|
|
@Override
|
|
@Override
|
|
- public synchronized String getNetworkLocation() {return location;}
|
|
|
|
|
|
+ public String getNetworkLocation() {return location;}
|
|
|
|
|
|
/** Sets the network location */
|
|
/** Sets the network location */
|
|
@Override
|
|
@Override
|
|
- public synchronized void setNetworkLocation(String location) {
|
|
|
|
|
|
+ public void setNetworkLocation(String location) {
|
|
this.location = NodeBase.normalize(location);
|
|
this.location = NodeBase.normalize(location);
|
|
}
|
|
}
|
|
|
|
|