Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 a8b3a03ef -> 07dd49674
PHOENIX-2671 System.STATS table getting truncated every time on new client connection(addendum) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/07dd4967 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/07dd4967 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/07dd4967 Branch: refs/heads/4.x-HBase-0.98 Commit: 07dd49674630353dfb0e6310187a341806191250 Parents: a8b3a03 Author: Ankit Singhal <ankitsingha...@gmail.com> Authored: Mon Feb 15 22:48:53 2016 +0530 Committer: Ankit Singhal <ankitsingha...@gmail.com> Committed: Mon Feb 15 22:48:53 2016 +0530 ---------------------------------------------------------------------- .../apache/phoenix/query/ConnectionQueryServicesImpl.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/07dd4967/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java index a9af8ea..f7a72a0 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java @@ -201,6 +201,12 @@ import com.google.common.collect.Maps; import com.google.common.collect.Sets; import com.google.common.util.concurrent.ThreadFactoryBuilder; +import co.cask.tephra.TransactionSystemClient; +import co.cask.tephra.TxConstants; +import co.cask.tephra.distributed.PooledClientProvider; +import co.cask.tephra.distributed.TransactionServiceClient; + + public class ConnectionQueryServicesImpl extends DelegateQueryServices implements ConnectionQueryServices { private static final Logger logger = LoggerFactory.getLogger(ConnectionQueryServicesImpl.class); private static final int INITIAL_CHILD_SERVICES_CAPACITY = 100; @@ -668,10 +674,6 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement }); } -import co.cask.tephra.TransactionSystemClient; -import co.cask.tephra.TxConstants; -import co.cask.tephra.distributed.PooledClientProvider; -import co.cask.tephra.distributed.TransactionServiceClient; @Override
