Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19239 (addendum) Fix findbugs and error-prone warnings (branch-1) 

Signed-off-by: Andrew Purtell <apurtell@apache.org>
This commit is contained in:
Guanghao Zhang 2017-12-02 20:30:56 +08:00 committed by Andrew Purtell
parent cb3bef3574
commit 9d481b1c43
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-server/src/main/java/org/apache/hadoop/hbase/master/ClusterStatusPublisher.java
View File

@ -99,7 +99,7 @@ public class ClusterStatusPublisher extends ScheduledChore {
private final ConcurrentMap<ServerName, Integer> lastSent =
new ConcurrentHashMap<ServerName, Integer>();
private Publisher publisher;
private boolean connected = false;
private volatile boolean connected = false;
/**
* We want to limit the size of the protobuf message sent, do fit into a single packet.
@ -169,9 +169,11 @@ public class ClusterStatusPublisher extends ScheduledChore {
}
@Override
protected synchronized void cleanup() {
protected void cleanup() {
connected = false;
publisher.close();
synchronized (this) {
publisher.close();
}
}
/**