@@ -52,7 +52,8 @@ class ServiceCheckDefault(ServiceCheck):
unique = get_unique_id_and_date()
File("/tmp/wordCount.jar",
- content=StaticFile("wordCount.jar")
+ content=StaticFile("wordCount.jar"),
+ owner=params.storm_user
)
cmd = ""
@@ -39,6 +39,7 @@ class TestStormServiceCheck(TestStormBase):
self.assertResourceCalled('File', '/tmp/wordCount.jar',
content = StaticFile('wordCount.jar'),
+ owner="storm"
self.assertResourceCalled('Execute', 'storm jar /tmp/wordCount.jar storm.starter.WordCountTopology WordCount -c nimbus.host=c6402.ambari.apache.org',
logoutput = True,
@@ -38,6 +38,7 @@ class TestStormServiceCheck(TestStormBase):
self.assertResourceCalled('Execute', 'storm jar /tmp/wordCount.jar storm.starter.WordCountTopology WordCount',