[storm] branch 2.1.x-branch updated: [STORM-3607] Add warnings about exceptions from hadoop TGT renewal thread

[ethanli]

This is an automated email from the ASF dual-hosted git repository.

ethanli pushed a commit to branch 2.1.x-branch
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/2.1.x-branch by this push:
     new 0dd7373  [STORM-3607] Add warnings about exceptions from hadoop TGT 
renewal thread
0dd7373 is described below

commit 0dd737359e2c8a012e3b0a06f756fe2065e3957d
Author: Ethan Li <ethanopensou...@gmail.com>
AuthorDate: Wed Mar 25 13:22:49 2020 -0500

    [STORM-3607] Add warnings about exceptions from hadoop TGT renewal thread
---
 .../jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java   | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git 
a/storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java 
b/storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java
index ff51ad0..2e3851c 100644
--- a/storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java
+++ b/storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java
@@ -206,8 +206,18 @@ public class AutoTGT implements IAutoCredentials, 
ICredentialsRenewer, IMetricsR
                          + "in your jar");
                 return;
             }
+
+            LOG.info("Invoking Hadoop 
UserGroupInformation.loginUserFromSubject.");
             Method login = ugi.getMethod("loginUserFromSubject", 
Subject.class);
             login.invoke(null, subject);
+
+            //Refer to STORM-3606 for details
+            LOG.warn("UserGroupInformation.loginUserFromSubject will spawn a 
TGT renewal thread (\"TGT Renewer for <username>\") "
+                + "to execute \"kinit -R\" command some time before the 
current TGT expires. "
+                + "It will fail because TGT is not in the local TGT cache and 
the thread will eventually abort. "
+                + "Exceptions from this TGT renewal thread can be ignored. 
Note: TGT for the Worker is kept in memory. "
+                + "Please refer to STORM-3606 for detailed explanations");
+
         } catch (Exception e) {
             LOG.warn("Something went wrong while trying to initialize Hadoop 
through reflection. This version of hadoop "
                      + "may not be compatible.", e);