diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java index 15716fc496574fb2376cccc39d5531fe261ac3e1..9ec816e0d6f7a791197b9dc7a883555703b93130 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/SecureCmdDoAs.java @@ -45,14 +45,13 @@ public SecureCmdDoAs(HiveConf conf) throws HiveException, IOException{ // metastore tokens into a file String uname = UserGroupInformation.getLoginUser().getShortUserName(); FileSystem fs = FileSystem.get(conf); - Token fsToken = fs.getDelegationToken(uname); + Credentials cred = new Credentials(); + fs.addDelegationTokens(uname, cred); tokenFile = File.createTempFile("hive_hadoop_delegation_token", null); tokenPath = new Path(tokenFile.toURI()); //write credential with token to file - Credentials cred = new Credentials(); - cred.addToken(fsToken.getService(), fsToken); cred.writeTokenStorageFile(tokenPath, conf); }