Author: pradeepkth
Date: Thu Jan 7 18:08:38 2010
New Revision: 896948
URL: http://svn.apache.org/viewvc?rev=896948&view=rev
Log:
removed FIXME comment for log dir setup in streaming since there is no change
in behavior from before
Modified:
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
Modified:
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java?rev=896948&r1=896947&r2=896948&view=diff
==============================================================================
---
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
(original)
+++
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
Thu Jan 7 18:08:38 2010
@@ -494,9 +494,7 @@
tmpLocation = new Path(tmpLocationStr);
nwJob.setOutputFormatClass(PigOutputFormat.class);
- // XXX: FIXME - we can no longer set these due to the new load
- // store redesign changes - need to handle this when streaming
is
- // changed for the new load-store redesign
+
conf.set("pig.streaming.log.dir",
new Path(tmpLocation, LOG_DIR).toString());
conf.set("pig.streaming.task.output.dir",
tmpLocation.toString());