Repository: oozie Updated Branches: refs/heads/master c22364554 -> 901616b21
OOZIE-2567 HCat connection is not closed while getting hcat cred Project: http://git-wip-us.apache.org/repos/asf/oozie/repo Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/901616b2 Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/901616b2 Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/901616b2 Branch: refs/heads/master Commit: 901616b21974da291e6538d545f7849a9ecb8adf Parents: c223645 Author: Purshotam Shah <[email protected]> Authored: Fri Jun 10 14:21:23 2016 -0700 Committer: Purshotam Shah <[email protected]> Committed: Fri Jun 10 14:21:23 2016 -0700 ---------------------------------------------------------------------- .../org/apache/oozie/action/hadoop/HCatCredentialHelper.java | 8 +++++++- release-log.txt | 1 + 2 files changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oozie/blob/901616b2/core/src/main/java/org/apache/oozie/action/hadoop/HCatCredentialHelper.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/action/hadoop/HCatCredentialHelper.java b/core/src/main/java/org/apache/oozie/action/hadoop/HCatCredentialHelper.java index 428975e..36ad1df 100644 --- a/core/src/main/java/org/apache/oozie/action/hadoop/HCatCredentialHelper.java +++ b/core/src/main/java/org/apache/oozie/action/hadoop/HCatCredentialHelper.java @@ -52,8 +52,9 @@ public class HCatCredentialHelper { * @throws Exception */ public void set(JobConf launcherJobConf, String principal, String server) throws Exception { + HCatClient client = null; try { - HCatClient client = getHCatClient(launcherJobConf, principal, server); + client = getHCatClient(launcherJobConf, principal, server); XLog.getLog(getClass()).debug( "HCatCredentialHelper: set: User name for which token will be asked from HCat: " + launcherJobConf.get(USER_NAME)); @@ -68,6 +69,11 @@ public class HCatCredentialHelper { XLog.getLog(getClass()).debug("set Exception" + ex.getMessage()); throw ex; } + finally { + if (client != null) { + client.close(); + } + } } /** http://git-wip-us.apache.org/repos/asf/oozie/blob/901616b2/release-log.txt ---------------------------------------------------------------------- diff --git a/release-log.txt b/release-log.txt index 88f66e9..fba302b 100644 --- a/release-log.txt +++ b/release-log.txt @@ -1,5 +1,6 @@ -- Oozie 4.3.0 release (trunk - unreleased) +OOZIE-2567 HCat connection is not closed while getting hcat cred (puru) OOZIE-2547 Add mapreduce.job.cache.files to spark action (satishsaley via rohini) OOZIE-2550 Flaky tests in TestZKUUIDService.java (pbacsko via rkanter) OOZIE-2445 Doc for - Specifying coordinator input datasets in more logical ways (puru)
