[storm] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/master by this push:
     new 171c0b3  [STORM-3607] Add warnings about exceptions from hadoop TGT 
renewal thread
     new 5dac9de  Merge pull request #3236 from Ethanlm/STORM-3607
171c0b3 is described below

commit 171c0b3b82c826feb959cc1f06b027a7d7649160
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 668d4b3..44eebe1 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
@@ -205,8 +205,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);