FAQ
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;

Search Discussions

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupcommits @
categorieshive, hadoop
postedMar 26, '14 at 8:04a
activeMar 26, '14 at 8:04a
posts1
users1
websitehive.apache.org

1 user in discussion

Gunther: 1 post

People

Translate

site design / logo © 2021 Grokbase