You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/11/26 17:04:24 UTC
[01/10] git commit: ACCUMULO-1920 fix needs to be in 1.4 branch, too
Updated Branches:
refs/heads/1.4.5-SNAPSHOT 6446ad5c2 -> 51dd80509
refs/heads/1.5.1-SNAPSHOT ad9ee5e06 -> 11ba435a4
refs/heads/1.6.0-SNAPSHOT 6c80fa503 -> dd55dc7e2
refs/heads/master abc3d6993 -> 2e4ce5e52
ACCUMULO-1920 fix needs to be in 1.4 branch, too
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/51dd8050
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/51dd8050
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/51dd8050
Branch: refs/heads/1.4.5-SNAPSHOT
Commit: 51dd805097eeca9404b78e5b332c9aebb09c9ed4
Parents: 6446ad5
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:03:23 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:03:23 2013 -0500
----------------------------------------------------------------------
.../accumulo/core/zookeeper/ZooSession.java | 13 -----------
.../apache/accumulo/server/monitor/Monitor.java | 24 ++++++++------------
2 files changed, 10 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
----------------------------------------------------------------------
diff --git a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
index 401be0a..b3db26f 100644
--- a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
+++ b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
@@ -18,10 +18,7 @@ package org.apache.accumulo.core.zookeeper;
import java.io.IOException;
import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.Collection;
import java.util.HashMap;
-import java.util.HashSet;
import java.util.Map;
import org.apache.accumulo.core.util.UtilWaitThread;
@@ -52,17 +49,7 @@ class ZooSession {
private static class AccumuloWatcher implements Watcher {
- private HashSet<Watcher> watchers = new HashSet<Watcher>();
-
public void process(WatchedEvent event) {
- // copy the watchers, in case the callback adds() more Watchers
- // otherwise we get a ConcurrentModificationException
- Collection<Watcher> watcherCopy = new ArrayList<Watcher>(watchers);
-
- for (Watcher watcher : watcherCopy) {
- watcher.process(event);
- }
-
if (event.getState() == KeeperState.Expired) {
log.debug("Session expired, state of current session : " + event.getState());
}
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
index 178d4f9..7a284f0 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
@@ -397,21 +397,17 @@ public class Monitor {
try {
// Read the gc location from its lock
ZooReaderWriter zk = ZooReaderWriter.getInstance();
- try {
- String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
- List<String> locks = zk.getChildren(path, null);
- if (locks != null && locks.size() > 0) {
- Collections.sort(locks);
- InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
- GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
- try {
- result = client.getStatus(null, SecurityConstants.getSystemCredentials());
- } finally {
- ThriftUtil.returnClient(client);
- }
+ String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
+ List<String> locks = zk.getChildren(path, null);
+ if (locks != null && locks.size() > 0) {
+ Collections.sort(locks);
+ InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
+ GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
+ try {
+ result = client.getStatus(null, SecurityConstants.getSystemCredentials());
+ } finally {
+ ThriftUtil.returnClient(client);
}
- } finally {
- zk.close();
}
} catch (Exception ex) {
log.warn("Unable to contact the garbage collector", ex);
[06/10] git commit: Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Posted by ec...@apache.org.
Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/11ba435a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/11ba435a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/11ba435a
Branch: refs/heads/1.5.1-SNAPSHOT
Commit: 11ba435a4002ef44d18d0c646a3c7649943d7c80
Parents: ad9ee5e 51dd805
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:04:02 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:04:02 2013 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[10/10] git commit: Merge branch '1.6.0-SNAPSHOT'
Posted by ec...@apache.org.
Merge branch '1.6.0-SNAPSHOT'
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/2e4ce5e5
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/2e4ce5e5
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/2e4ce5e5
Branch: refs/heads/master
Commit: 2e4ce5e52558f890cf5a6446f98763ee462ac2b0
Parents: abc3d69 dd55dc7
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:04:34 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:04:34 2013 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[07/10] git commit: Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Posted by ec...@apache.org.
Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/11ba435a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/11ba435a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/11ba435a
Branch: refs/heads/master
Commit: 11ba435a4002ef44d18d0c646a3c7649943d7c80
Parents: ad9ee5e 51dd805
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:04:02 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:04:02 2013 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[09/10] git commit: Merge branch '1.5.1-SNAPSHOT' into 1.6.0-SNAPSHOT
Posted by ec...@apache.org.
Merge branch '1.5.1-SNAPSHOT' into 1.6.0-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/dd55dc7e
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/dd55dc7e
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/dd55dc7e
Branch: refs/heads/master
Commit: dd55dc7e242e4ecf48196812a718e608be7bac5b
Parents: 6c80fa5 11ba435
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:04:22 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:04:22 2013 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[03/10] git commit: ACCUMULO-1920 fix needs to be in 1.4 branch, too
Posted by ec...@apache.org.
ACCUMULO-1920 fix needs to be in 1.4 branch, too
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/51dd8050
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/51dd8050
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/51dd8050
Branch: refs/heads/1.6.0-SNAPSHOT
Commit: 51dd805097eeca9404b78e5b332c9aebb09c9ed4
Parents: 6446ad5
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:03:23 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:03:23 2013 -0500
----------------------------------------------------------------------
.../accumulo/core/zookeeper/ZooSession.java | 13 -----------
.../apache/accumulo/server/monitor/Monitor.java | 24 ++++++++------------
2 files changed, 10 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
----------------------------------------------------------------------
diff --git a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
index 401be0a..b3db26f 100644
--- a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
+++ b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
@@ -18,10 +18,7 @@ package org.apache.accumulo.core.zookeeper;
import java.io.IOException;
import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.Collection;
import java.util.HashMap;
-import java.util.HashSet;
import java.util.Map;
import org.apache.accumulo.core.util.UtilWaitThread;
@@ -52,17 +49,7 @@ class ZooSession {
private static class AccumuloWatcher implements Watcher {
- private HashSet<Watcher> watchers = new HashSet<Watcher>();
-
public void process(WatchedEvent event) {
- // copy the watchers, in case the callback adds() more Watchers
- // otherwise we get a ConcurrentModificationException
- Collection<Watcher> watcherCopy = new ArrayList<Watcher>(watchers);
-
- for (Watcher watcher : watcherCopy) {
- watcher.process(event);
- }
-
if (event.getState() == KeeperState.Expired) {
log.debug("Session expired, state of current session : " + event.getState());
}
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
index 178d4f9..7a284f0 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
@@ -397,21 +397,17 @@ public class Monitor {
try {
// Read the gc location from its lock
ZooReaderWriter zk = ZooReaderWriter.getInstance();
- try {
- String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
- List<String> locks = zk.getChildren(path, null);
- if (locks != null && locks.size() > 0) {
- Collections.sort(locks);
- InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
- GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
- try {
- result = client.getStatus(null, SecurityConstants.getSystemCredentials());
- } finally {
- ThriftUtil.returnClient(client);
- }
+ String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
+ List<String> locks = zk.getChildren(path, null);
+ if (locks != null && locks.size() > 0) {
+ Collections.sort(locks);
+ InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
+ GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
+ try {
+ result = client.getStatus(null, SecurityConstants.getSystemCredentials());
+ } finally {
+ ThriftUtil.returnClient(client);
}
- } finally {
- zk.close();
}
} catch (Exception ex) {
log.warn("Unable to contact the garbage collector", ex);
[02/10] git commit: ACCUMULO-1920 fix needs to be in 1.4 branch, too
Posted by ec...@apache.org.
ACCUMULO-1920 fix needs to be in 1.4 branch, too
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/51dd8050
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/51dd8050
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/51dd8050
Branch: refs/heads/1.5.1-SNAPSHOT
Commit: 51dd805097eeca9404b78e5b332c9aebb09c9ed4
Parents: 6446ad5
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:03:23 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:03:23 2013 -0500
----------------------------------------------------------------------
.../accumulo/core/zookeeper/ZooSession.java | 13 -----------
.../apache/accumulo/server/monitor/Monitor.java | 24 ++++++++------------
2 files changed, 10 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
----------------------------------------------------------------------
diff --git a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
index 401be0a..b3db26f 100644
--- a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
+++ b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
@@ -18,10 +18,7 @@ package org.apache.accumulo.core.zookeeper;
import java.io.IOException;
import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.Collection;
import java.util.HashMap;
-import java.util.HashSet;
import java.util.Map;
import org.apache.accumulo.core.util.UtilWaitThread;
@@ -52,17 +49,7 @@ class ZooSession {
private static class AccumuloWatcher implements Watcher {
- private HashSet<Watcher> watchers = new HashSet<Watcher>();
-
public void process(WatchedEvent event) {
- // copy the watchers, in case the callback adds() more Watchers
- // otherwise we get a ConcurrentModificationException
- Collection<Watcher> watcherCopy = new ArrayList<Watcher>(watchers);
-
- for (Watcher watcher : watcherCopy) {
- watcher.process(event);
- }
-
if (event.getState() == KeeperState.Expired) {
log.debug("Session expired, state of current session : " + event.getState());
}
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
index 178d4f9..7a284f0 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
@@ -397,21 +397,17 @@ public class Monitor {
try {
// Read the gc location from its lock
ZooReaderWriter zk = ZooReaderWriter.getInstance();
- try {
- String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
- List<String> locks = zk.getChildren(path, null);
- if (locks != null && locks.size() > 0) {
- Collections.sort(locks);
- InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
- GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
- try {
- result = client.getStatus(null, SecurityConstants.getSystemCredentials());
- } finally {
- ThriftUtil.returnClient(client);
- }
+ String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
+ List<String> locks = zk.getChildren(path, null);
+ if (locks != null && locks.size() > 0) {
+ Collections.sort(locks);
+ InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
+ GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
+ try {
+ result = client.getStatus(null, SecurityConstants.getSystemCredentials());
+ } finally {
+ ThriftUtil.returnClient(client);
}
- } finally {
- zk.close();
}
} catch (Exception ex) {
log.warn("Unable to contact the garbage collector", ex);
[05/10] git commit: Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Posted by ec...@apache.org.
Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/11ba435a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/11ba435a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/11ba435a
Branch: refs/heads/1.6.0-SNAPSHOT
Commit: 11ba435a4002ef44d18d0c646a3c7649943d7c80
Parents: ad9ee5e 51dd805
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:04:02 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:04:02 2013 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[08/10] git commit: Merge branch '1.5.1-SNAPSHOT' into 1.6.0-SNAPSHOT
Posted by ec...@apache.org.
Merge branch '1.5.1-SNAPSHOT' into 1.6.0-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/dd55dc7e
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/dd55dc7e
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/dd55dc7e
Branch: refs/heads/1.6.0-SNAPSHOT
Commit: dd55dc7e242e4ecf48196812a718e608be7bac5b
Parents: 6c80fa5 11ba435
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:04:22 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:04:22 2013 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[04/10] git commit: ACCUMULO-1920 fix needs to be in 1.4 branch, too
Posted by ec...@apache.org.
ACCUMULO-1920 fix needs to be in 1.4 branch, too
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/51dd8050
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/51dd8050
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/51dd8050
Branch: refs/heads/master
Commit: 51dd805097eeca9404b78e5b332c9aebb09c9ed4
Parents: 6446ad5
Author: Eric Newton <er...@gmail.com>
Authored: Tue Nov 26 11:03:23 2013 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Tue Nov 26 11:03:23 2013 -0500
----------------------------------------------------------------------
.../accumulo/core/zookeeper/ZooSession.java | 13 -----------
.../apache/accumulo/server/monitor/Monitor.java | 24 ++++++++------------
2 files changed, 10 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
----------------------------------------------------------------------
diff --git a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
index 401be0a..b3db26f 100644
--- a/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
+++ b/src/core/src/main/java/org/apache/accumulo/core/zookeeper/ZooSession.java
@@ -18,10 +18,7 @@ package org.apache.accumulo.core.zookeeper;
import java.io.IOException;
import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.Collection;
import java.util.HashMap;
-import java.util.HashSet;
import java.util.Map;
import org.apache.accumulo.core.util.UtilWaitThread;
@@ -52,17 +49,7 @@ class ZooSession {
private static class AccumuloWatcher implements Watcher {
- private HashSet<Watcher> watchers = new HashSet<Watcher>();
-
public void process(WatchedEvent event) {
- // copy the watchers, in case the callback adds() more Watchers
- // otherwise we get a ConcurrentModificationException
- Collection<Watcher> watcherCopy = new ArrayList<Watcher>(watchers);
-
- for (Watcher watcher : watcherCopy) {
- watcher.process(event);
- }
-
if (event.getState() == KeeperState.Expired) {
log.debug("Session expired, state of current session : " + event.getState());
}
http://git-wip-us.apache.org/repos/asf/accumulo/blob/51dd8050/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
----------------------------------------------------------------------
diff --git a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
index 178d4f9..7a284f0 100644
--- a/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
+++ b/src/server/src/main/java/org/apache/accumulo/server/monitor/Monitor.java
@@ -397,21 +397,17 @@ public class Monitor {
try {
// Read the gc location from its lock
ZooReaderWriter zk = ZooReaderWriter.getInstance();
- try {
- String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
- List<String> locks = zk.getChildren(path, null);
- if (locks != null && locks.size() > 0) {
- Collections.sort(locks);
- InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
- GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
- try {
- result = client.getStatus(null, SecurityConstants.getSystemCredentials());
- } finally {
- ThriftUtil.returnClient(client);
- }
+ String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
+ List<String> locks = zk.getChildren(path, null);
+ if (locks != null && locks.size() > 0) {
+ Collections.sort(locks);
+ InetSocketAddress address = new ServerServices(new String(zk.getData(path + "/" + locks.get(0), null))).getAddress(Service.GC_CLIENT);
+ GCMonitorService.Iface client = ThriftUtil.getClient(new GCMonitorService.Client.Factory(), address, ServerConfiguration.getSystemConfiguration());
+ try {
+ result = client.getStatus(null, SecurityConstants.getSystemCredentials());
+ } finally {
+ ThriftUtil.returnClient(client);
}
- } finally {
- zk.close();
}
} catch (Exception ex) {
log.warn("Unable to contact the garbage collector", ex);