You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2014/03/26 09:03:13 UTC
svn commit: r1581729 - in
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez:
MapRecordProcessor.java ReduceRecordProcessor.java
Author: gunther
Date: Wed Mar 26 08:03:13 2014
New Revision: 1581729
URL: http://svn.apache.org/r1581729
Log:
HIVE-6742: Tez Outputs need to be started before accessing the writer (Siddharth Seth via Gunther Hagleitner)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java?rev=1581729&r1=1581728&r2=1581729&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java Wed Mar 26 08:03: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/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java?rev=1581729&r1=1581728&r2=1581729&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java Wed Mar 26 08:03: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;