Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-5663. Small refactor in ZKRMStateStore. Contributed by Oleksii Dymytrov.

This commit is contained in:
Akira Ajisaka 2016-09-26 15:00:01 +09:00
parent 5707f88d85
commit 14a696f369
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java
View File

@ -748,17 +748,14 @@ public class ZKRMStateStore extends RMStateStore {
String nodeCreatePath = String nodeCreatePath =
getNodePath(dtMasterKeysRootPath, DELEGATION_KEY_PREFIX getNodePath(dtMasterKeysRootPath, DELEGATION_KEY_PREFIX
+ delegationKey.getKeyId()); + delegationKey.getKeyId());
ByteArrayOutputStream os = new ByteArrayOutputStream();
DataOutputStream fsOut = new DataOutputStream(os);
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("Storing RMDelegationKey_" + delegationKey.getKeyId()); LOG.debug("Storing RMDelegationKey_" + delegationKey.getKeyId());
} }
delegationKey.write(fsOut); ByteArrayOutputStream os = new ByteArrayOutputStream();
try { try(DataOutputStream fsOut = new DataOutputStream(os)) {
delegationKey.write(fsOut);
safeCreate(nodeCreatePath, os.toByteArray(), zkAcl, safeCreate(nodeCreatePath, os.toByteArray(), zkAcl,
CreateMode.PERSISTENT); CreateMode.PERSISTENT);
} finally {
os.close();
} }
} }