You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/03/18 01:46:01 UTC
git commit: TEZ-942. Mrrsleep job with only maps fails with 'Illegal
output to map'. (hitesh)
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 <hi...@apache.org>
Authored: Mon Mar 17 17:45:43 2014 -0700
Committer: Hitesh Shah <hi...@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) {