tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-942. Mrrsleep job with only maps fails with 'Illegal output to map'. (hitesh)
Date Tue, 18 Mar 2014 00:46:01 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master 98d5a31cb -> ba89a0847


TEZ-942. Mrrsleep job with only maps fails with 'Illegal output to map'. (hitesh)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/ba89a084
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/ba89a084
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/ba89a084

Branch: refs/heads/master
Commit: ba89a0847974e7e0d95e460720871888ac226512
Parents: 98d5a31
Author: Hitesh Shah <hitesh@apache.org>
Authored: Mon Mar 17 17:45:43 2014 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Mon Mar 17 17:45:43 2014 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java  | 2 +-
 .../java/org/apache/tez/mapreduce/processor/map/MapProcessor.java | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ba89a084/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
index 5f3b184..399a082 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
@@ -654,7 +654,7 @@ public class MRRSleepJob extends Configured implements Tool {
       vertices.add(finalReduceVertex);
     } else {
       // Map only job
-      MRHelpers.addMROutput(mapVertex, mapUserPayload);
+      MRHelpers.addMROutputLegacy(mapVertex, mapUserPayload);
     }
 
     for (int i = 0; i < vertices.size(); ++i) {

http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ba89a084/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java
b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java
index 27b52b2..a2dd7d1 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/processor/map/MapProcessor.java
@@ -126,7 +126,8 @@ public class MapProcessor extends MRTask implements LogicalIOProcessor
{
     } else if ((out instanceof OnFileSortedOutput)){
       kvWriter = ((OnFileSortedOutput)out).getWriter();
     } else {
-      throw new IOException("Illegal output to map: " + in.getClass());
+      throw new IOException("Illegal output to map, outputClass="
+          + out.getClass());
     }
 
     if (useNewApi) {


Mime
View raw message