svn commit: r1221550 - /incubator/ambari/trunk/controller/src/main/java/org/apache/ambari/controller/HeartbeatHandler.java

[dd...@apache.org]

Author: ddas
Date: Wed Dec 21 01:20:37 2011
New Revision: 1221550

URL: http://svn.apache.org/viewvc?rev=1221550&view=rev
Log:
AMBARI-169. Workaround patch that hardcodes the user to hdfs

Modified:
    incubator/ambari/trunk/controller/src/main/java/org/apache/ambari/controller/HeartbeatHandler.java

Modified: incubator/ambari/trunk/controller/src/main/java/org/apache/ambari/controller/HeartbeatHandler.java
URL: http://svn.apache.org/viewvc/incubator/ambari/trunk/controller/src/main/java/org/apache/ambari/controller/HeartbeatHandler.java?rev=1221550&r1=1221549&r2=1221550&view=diff
==============================================================================
--- incubator/ambari/trunk/controller/src/main/java/org/apache/ambari/controller/HeartbeatHandler.java (original)
+++ incubator/ambari/trunk/controller/src/main/java/org/apache/ambari/controller/HeartbeatHandler.java Wed Dec 21 01:20:37 2011
@@ -63,6 +63,8 @@ public class HeartbeatHandler {
   private final Nodes nodes;
   private StateMachineInvokerInterface stateMachineInvoker;
   private FSMDriverInterface driver;
+  
+  static final String DEFAULT_USER = "hdfs"; //TBD: this needs to come from the stack definition or something
     
   @Inject
   HeartbeatHandler(Clusters clusters, Nodes nodes, 
@@ -258,6 +260,7 @@ public class HeartbeatHandler {
       List<Action> allActions) {
     ConfigFile file = new ConfigFile();
     file.setData(script);
+    file.setOwner(DEFAULT_USER);
     
     Action action = new Action();
     action.setFile(file);
@@ -465,6 +468,7 @@ public class HeartbeatHandler {
     action.setClusterDefinitionRevision(clusterDefRev);
     action.setComponent(component);
     action.setRole(role);
+    action.setUser(DEFAULT_USER);
     action.setCleanUpCommand(new Command("foobar","",new String[]{"foobar"}));//TODO: this needs fixing at some point
     String workDir = role.equals(component + "-client") ? 
         (clusterId + "-client") : (clusterId + "-" + role);