hawq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject incubator-hawq git commit: HAWQ-635. QE process does not exit in libhdfs
Date Thu, 07 Apr 2016 10:18:02 GMT
Repository: incubator-hawq
Updated Branches:
  refs/heads/master af11648c4 -> 47f0d4508


HAWQ-635. QE process does not exit in libhdfs


Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/47f0d450
Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/47f0d450
Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/47f0d450

Branch: refs/heads/master
Commit: 47f0d450838fd5a329dfd94be106a10e6e382afc
Parents: af11648
Author: Ming LI <mli@pivotal.io>
Authored: Thu Apr 7 18:16:49 2016 +0800
Committer: Ming LI <mli@pivotal.io>
Committed: Thu Apr 7 18:16:49 2016 +0800

----------------------------------------------------------------------
 depends/libhdfs3/src/rpc/RpcClient.cpp | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/47f0d450/depends/libhdfs3/src/rpc/RpcClient.cpp
----------------------------------------------------------------------
diff --git a/depends/libhdfs3/src/rpc/RpcClient.cpp b/depends/libhdfs3/src/rpc/RpcClient.cpp
index a2fe8da..531471e 100644
--- a/depends/libhdfs3/src/rpc/RpcClient.cpp
+++ b/depends/libhdfs3/src/rpc/RpcClient.cpp
@@ -155,8 +155,6 @@ RpcChannel & RpcClientImpl::getChannel(const RpcAuth & auth,
             allChannels[key] = rc;
         }
 
-        rc->addRef();
-
         if (!cleaning) {
             cleaning = true;
 
@@ -166,6 +164,8 @@ RpcChannel & RpcClientImpl::getChannel(const RpcAuth & auth,
 
             CREATE_THREAD(cleaner, bind(&RpcClientImpl::clean, this));
         }
+        // increase ref count after successfully done without any exception
+        rc->addRef();
     } catch (const HdfsRpcException & e) {
         throw;
     } catch (...) {


Mime
View raw message