You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2017/04/14 19:04:15 UTC
samza git commit: SAMZA-1195 fix bug in Samza application master on
Kerberos
Repository: samza
Updated Branches:
refs/heads/master 66cbac5c7 -> 34178a63f
SAMZA-1195 fix bug in Samza application master on Kerberos
Author: Chen Song <ch...@hotmail.com>
Reviewers: Yi Pan <ni...@apache.org>
Closes #119 from garlicbulb-puzhuo/SAMZA-1195
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/34178a63
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/34178a63
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/34178a63
Branch: refs/heads/master
Commit: 34178a63fad7103206da265bc25216cf15bb400a
Parents: 66cbac5
Author: Chen Song <ch...@hotmail.com>
Authored: Fri Apr 14 12:04:08 2017 -0700
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
Committed: Fri Apr 14 12:04:08 2017 -0700
----------------------------------------------------------------------
.../org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/34178a63/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala
----------------------------------------------------------------------
diff --git a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala
index 2eaa19f..8dba96a 100644
--- a/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala
+++ b/samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala
@@ -74,7 +74,6 @@ class SamzaAppMasterSecurityManager(config: Config, hadoopConf: Configuration) e
private def loginFromKeytab(principal: String, keytab: String, credentialsFile: String) = {
info(s"Logging to KDC using principal: $principal")
- UserGroupInformation.loginUserFromKeytab(principal, keytab)
val keytabUser = UserGroupInformation.loginUserFromKeytabAndReturnUGI(principal, keytab)
val credentials = keytabUser.getCredentials