hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gunt...@apache.org
Subject svn commit: r1581731 - in /hive/branches/branch-0.13/ql/src/java/org/apache/hadoop/hive/ql/exec/tez: MapRecordProcessor.java ReduceRecordProcessor.java
Date Wed, 26 Mar 2014 08:04:13 GMT
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;



Mime
View raw message