svn commit: r1581731 - in /hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez: MapRecordProcessor.java ReduceRecordProcessor.java

[gunther]

Author: gunther
Date: Wed Mar 26 08:04:13 2014
New Revision: 1581731

URL: http://svn.apache.org/r1581731
Log:
HIVE-6742: Tez Outputs need to be started before accessing the writer 
(Siddharth Seth via Gunther Hagleitner)

Modified:
    
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
    
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java

Modified: 
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
URL: 
http://svn.apache.org/viewvc/hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java?rev=1581731&r1=1581730&r2=1581731&view=diff
==============================================================================
--- 
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
 (original)
+++ 
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
 Wed Mar 26 08:04:13 2014
@@ -83,8 +83,8 @@ public class MapRecordProcessor extends 
     // Start all the Outputs.
     for (Entry<String, LogicalOutput> outputEntry : outputs.entrySet()) {
       l4j.info("Starting Output: " + outputEntry.getKey());
-      ((TezKVOutputCollector) outMap.get(outputEntry.getKey())).initialize();
       outputEntry.getValue().start();
+      ((TezKVOutputCollector) outMap.get(outputEntry.getKey())).initialize();
     }
 
     ObjectCache cache = ObjectCacheFactory.getCache(jconf);

Modified: 
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java
URL: 
http://svn.apache.org/viewvc/hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java?rev=1581731&r1=1581730&r2=1581731&view=diff
==============================================================================
--- 
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java
 (original)
+++ 
hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java
 Wed Mar 26 08:04:13 2014
@@ -200,8 +200,8 @@ public class ReduceRecordProcessor  exte
 
     for (Entry<String, LogicalOutput> outputEntry : outputs.entrySet()) {
       l4j.info("Starting Output: " + outputEntry.getKey());
-      ((TezKVOutputCollector) outMap.get(outputEntry.getKey())).initialize();
       outputEntry.getValue().start();
+      ((TezKVOutputCollector) outMap.get(outputEntry.getKey())).initialize();
     }
 
     KeyValuesReader kvsReader;