svn commit: r1064380 - /oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/engine/runner/HadoopRunner.java

[bfoster]

Author: bfoster
Date: Fri Jan 28 00:21:32 2011
New Revision: 1064380

URL: http://svn.apache.org/viewvc?rev=1064380&view=rev
Log:

- beginnings of pluggin in wengine into hadoop

------------------------

Modified:
    
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/engine/runner/HadoopRunner.java

Modified: 
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/engine/runner/HadoopRunner.java
URL: 
http://svn.apache.org/viewvc/oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/engine/runner/HadoopRunner.java?rev=1064380&r1=1064379&r2=1064380&view=diff
==============================================================================
--- 
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/engine/runner/HadoopRunner.java
 (original)
+++ 
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/engine/runner/HadoopRunner.java
 Fri Jan 28 00:21:32 2011
@@ -52,10 +52,7 @@ public class HadoopRunner extends Engine
                        job.setMapperClass(HadoopTaskInstance.class);
                        job.setNumReduceTasks(0);
                        XStream xstream = new XStream();
-                       String xstreamTask = "/temp/job-input/xstream/" + 
workflowInstance.getInstanceId() + "/" + workflowInstance.getModelId() + 
".xstream";
-                       String xmlTask = xstream.toXML(workflowInstance);
-                       //write xmlTask to xstreamTask;
-               FileInputFormat.addInputPath(job, new Path(xstreamTask));
+                       conf.set(HadoopTaskInstance.XSTREAM_TASK, 
xstream.toXML(workflowInstance));
                }
                
                job.submit();