ソースを参照

AMBARI-8690. Storm service check in secured mode fails (aonishuk)

Andrew Onishuk 10 年 前
コミット
9338767f2d

+ 5 - 2
ambari-server/src/main/resources/stacks/HDP/2.1/services/STORM/package/scripts/service_check.py

@@ -36,11 +36,14 @@ class ServiceCheck(Script):
 
     Execute(cmd,
             logoutput=True,
-            path=params.storm_bin_dir
+            path=params.storm_bin_dir,
+            user=params.storm_user
     )
 
     Execute(format("env JAVA_HOME={java64_home} storm kill WordCount{unique}"),
-            path=params.storm_bin_dir)
+            path=params.storm_bin_dir,
+            user=params.storm_user
+    )
 
 if __name__ == "__main__":
   ServiceCheck().execute()

+ 4 - 2
ambari-server/src/test/python/stacks/2.1/STORM/test_service_check.py

@@ -38,9 +38,11 @@ class TestStormServiceCheck(RMFTestCase):
     )
     self.assertResourceCalled('Execute', 'env JAVA_HOME=/usr/jdk64/jdk1.7.0_45 storm jar /tmp/wordCount.jar storm.starter.WordCountTopology WordCount -c nimbus.host=c6402.ambari.apache.org',
       logoutput = True,
-      path = ['/usr/bin']
+      path = ['/usr/bin'],
+      user = 'storm'
     )
     self.assertResourceCalled('Execute', 'env JAVA_HOME=/usr/jdk64/jdk1.7.0_45 storm kill WordCount',
-      path = ['/usr/bin']
+      path = ['/usr/bin'],
+      user = 'storm'
     )