You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ol...@apache.org on 2009/05/15 19:51:12 UTC
svn commit: r775259 - /hadoop/pig/trunk/src/org/apache/pig/PigServer.java
Author: olga
Date: Fri May 15 17:51:12 2009
New Revision: 775259
URL: http://svn.apache.org/viewvc?rev=775259&view=rev
Log:
trivial change - added log message (hagleitn via olgan)
Modified:
hadoop/pig/trunk/src/org/apache/pig/PigServer.java
Modified: hadoop/pig/trunk/src/org/apache/pig/PigServer.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/PigServer.java?rev=775259&r1=775258&r2=775259&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/PigServer.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/PigServer.java Fri May 15 17:51:12 2009
@@ -1083,12 +1083,14 @@
LoadFunc lFunc = (LoadFunc) pigContext.instantiateFuncFromSpec(load.getInputFile().getFuncSpec());
StoreFunc sFunc = (StoreFunc) pigContext.instantiateFuncFromSpec(store.getOutputFile().getFuncSpec());
if (lFunc.getClass() == sFunc.getClass() && lFunc instanceof ReversibleLoadStoreFunc) {
-
- // In this case we remember the input file
- // spec in the store. We might have to use it
- // in the MR compiler to recreate the load, if
- // the store happens on a job boundary.
- store.setInputSpec(load.getInputFile());
+
+ log.info("Removing unnecessary load operation from location: "+ifile);
+
+ // In this case we remember the input file
+ // spec in the store. We might have to use it
+ // in the MR compiler to recreate the load, if
+ // the store happens on a job boundary.
+ store.setInputSpec(load.getInputFile());
LogicalOperator storePred = lp.getPredecessors(store).get(0);