[CARMEL-3500] Catch potential exception for renew kerberos ticket (#18)

Luan, Xuedong · mingmwang · commit dcd6c6a409e2 · 2020-08-11T17:05:21.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManager.scala b/core/src/main/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManager.scala
@@ -112,7 +112,12 @@ private[spark] class HadoopDelegationTokenManager(
       // not need to be renewed yet.
       val tgtRenewalTask = new Runnable() {
         override def run(): Unit = {
-          ugi.checkTGTAndReloginFromKeytab()
+          try {
+            ugi.checkTGTAndReloginFromKeytab()
+          } catch {
+            case e: Throwable =>
+              logWarning("Failed to renew TGT from keytab file", e)
+          }
         }
       }
       val tgtRenewalPeriod = sparkConf.get(KERBEROS_RELOGIN_PERIOD)

Original file line number	Diff line number	Diff line change
`@@ -112,7 +112,12 @@ private[spark] class HadoopDelegationTokenManager(`
`112`	`112`	`// not need to be renewed yet.`
`113`	`113`	`val tgtRenewalTask = new Runnable() {`
`114`	`114`	`override def run(): Unit = {`
`115`		`- ugi.checkTGTAndReloginFromKeytab()`
	`115`	`+ try {`
	`116`	`+ ugi.checkTGTAndReloginFromKeytab()`
	`117`	`+ } catch {`
	`118`	`+ case e: Throwable =>`
	`119`	`+ logWarning("Failed to renew TGT from keytab file", e)`
	`120`	`+ }`
`116`	`121`	`}`
`117`	`122`	`}`
`118`	`123`	`val tgtRenewalPeriod = sparkConf.get(KERBEROS_RELOGIN_PERIOD)`