From 5448f8af8bd0e81fce459f8696ec3367bdc86ea9 Mon Sep 17 00:00:00 2001
From: gss2002 <greg@senia.org>
Date: Tue, 3 Apr 2018 11:16:25 -0400
Subject: [PATCH] ZEPPELIN-3356: Zeppelin FileSystemStorage reloginFromKeytab
 needed

---
 .../org/apache/zeppelin/notebook/FileSystemStorage.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/FileSystemStorage.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/FileSystemStorage.java
index 24bab570d9b..f15a56d02b4 100644
--- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/FileSystemStorage.java
+++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/FileSystemStorage.java
@@ -12,6 +12,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import jline.internal.Log;
+
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
@@ -156,6 +158,11 @@ private interface HdfsOperation<T> {
   public synchronized <T> T callHdfsOperation(final HdfsOperation<T> func) throws IOException {
     if (isSecurityEnabled) {
       try {
+    	    if (isSecurityEnabled) {
+    	      if (UserGroupInformation.isLoginKeytabBased()) {
+            UserGroupInformation.getCurrentUser().checkTGTAndReloginFromKeytab();
+    	      } 
+    	    }
         return UserGroupInformation.getCurrentUser().doAs(new PrivilegedExceptionAction<T>() {
           @Override
           public T run() throws Exception {