Repository: samza Updated Branches: refs/heads/master 2227f9f1a -> 4c0e50581
SAMZA-929: Set initialDelay in tokenRenewExecutor schedule to 0 Changed initialDelay in tokenRenewExecutor scheduler to 0 so that it can re-login using the keytab as soon as the application master container starts. This way even if application master restarts after the delegation token in launcher context has expired, it will be able to use the new token to launch other containers. Author: Apoorva Sareen <asareen@MacBook-Pro-2.local> Reviewers: Jagadish<jagad...@apache.org> Closes #544 from apoorva121/master Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/4c0e5058 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/4c0e5058 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/4c0e5058 Branch: refs/heads/master Commit: 4c0e50581c3a9473fb4cb09103577e468b0fb439 Parents: 2227f9f Author: Apoorva Sareen <asareen@MacBook-Pro-2.local> Authored: Tue Jun 5 11:44:49 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Tue Jun 5 11:44:49 2018 -0700 ---------------------------------------------------------------------- .../org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/4c0e5058/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 185cda0..bb590c5 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,7 @@ class SamzaAppMasterSecurityManager(config: Config, hadoopConf: Configuration) e } } - tokenRenewExecutor.scheduleAtFixedRate(tokenRenewRunnable, renewalInterval, renewalInterval, TimeUnit.SECONDS) + tokenRenewExecutor.scheduleAtFixedRate(tokenRenewRunnable, 0, renewalInterval, TimeUnit.SECONDS) } private def loginFromKeytab(principal: String, keytab: String, credentialsFile: String) = {
