Repository: bookkeeper Updated Branches: refs/heads/master 28c264c86 -> 32ebf0ad6
BOOKKEEPER-999: Stop leaking threads in BookKeeper client Author: Robert (Bobby) Evans <[email protected]> Reviewers: Sijie Guo <[email protected]>, Enrico Olivelli <[email protected]>, Jia Zhai <[email protected]>, Kai S <None>, Venkateswararao Jujjuri (JV) <None> Closes #105 from revans2/BOOKKEEPER-999 Project: http://git-wip-us.apache.org/repos/asf/bookkeeper/repo Commit: http://git-wip-us.apache.org/repos/asf/bookkeeper/commit/32ebf0ad Tree: http://git-wip-us.apache.org/repos/asf/bookkeeper/tree/32ebf0ad Diff: http://git-wip-us.apache.org/repos/asf/bookkeeper/diff/32ebf0ad Branch: refs/heads/master Commit: 32ebf0ad68f85daffdec571e28206339a4d09443 Parents: 28c264c Author: Robert (Bobby) Evans <[email protected]> Authored: Wed Mar 22 16:51:48 2017 -0700 Committer: Sijie Guo <[email protected]> Committed: Wed Mar 22 16:51:48 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/bookkeeper/client/BookKeeper.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bookkeeper/blob/32ebf0ad/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeper.java ---------------------------------------------------------------------- diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeper.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeper.java index 8959462..409a138 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeper.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeper.java @@ -248,11 +248,7 @@ public class BookKeeper implements AutoCloseable { public BookKeeper(ClientConfiguration conf, ZooKeeper zk) throws IOException, InterruptedException, KeeperException { - this(conf, validateZooKeeper(zk), new NioClientSocketChannelFactory( - Executors.newCachedThreadPool(new ThreadFactoryBuilder() - .setNameFormat("BookKeeper-NIOBoss-%d").build()), - Executors.newCachedThreadPool(new ThreadFactoryBuilder() - .setNameFormat("BookKeeper-NIOWorker-%d").build()))); + this(conf, validateZooKeeper(zk), null, NullStatsLogger.INSTANCE, null, null, null); } /**
