pradeepkth
Thu, 07 Jan 2010 10:09:02 -0800
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());