You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mrunit.apache.org by db...@apache.org on 2012/12/04 17:57:18 UTC
git commit: MRUNIT-163: getTaskAttemptID is missing from context
Updated Branches:
refs/heads/trunk 92ad229da -> 59aa9dc18
MRUNIT-163: getTaskAttemptID is missing from context
Fix for hadoop2 as interface of TaskAttemptID has been changed
Project: http://git-wip-us.apache.org/repos/asf/mrunit/repo
Commit: http://git-wip-us.apache.org/repos/asf/mrunit/commit/59aa9dc1
Tree: http://git-wip-us.apache.org/repos/asf/mrunit/tree/59aa9dc1
Diff: http://git-wip-us.apache.org/repos/asf/mrunit/diff/59aa9dc1
Branch: refs/heads/trunk
Commit: 59aa9dc1871d99495196f11f6014e34557b46b85
Parents: 92ad229
Author: Dave Beech <db...@apache.org>
Authored: Tue Dec 4 16:56:46 2012 +0000
Committer: Dave Beech <db...@apache.org>
Committed: Tue Dec 4 16:56:46 2012 +0000
----------------------------------------------------------------------
.../internal/mapreduce/MockMapContextWrapper.java | 2 +-
.../mapreduce/MockReduceContextWrapper.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mrunit/blob/59aa9dc1/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapContextWrapper.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapContextWrapper.java b/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapContextWrapper.java
index b61f8e6..0febe85 100644
--- a/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapContextWrapper.java
+++ b/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockMapContextWrapper.java
@@ -105,7 +105,7 @@ public class MockMapContextWrapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>
@Override
public TaskAttemptID answer(InvocationOnMock invocation)
throws Throwable {
- return new TaskAttemptID("", 0, true, 0, 0);
+ return TaskAttemptID.forName("attempt__0000_m_000000_0");
}
});
} catch (IOException e) {
http://git-wip-us.apache.org/repos/asf/mrunit/blob/59aa9dc1/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockReduceContextWrapper.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockReduceContextWrapper.java b/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockReduceContextWrapper.java
index dbd06e8..4996074 100644
--- a/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockReduceContextWrapper.java
+++ b/src/main/java/org/apache/hadoop/mrunit/internal/mapreduce/MockReduceContextWrapper.java
@@ -105,7 +105,7 @@ public class MockReduceContextWrapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>
@Override
public TaskAttemptID answer(InvocationOnMock invocation)
throws Throwable {
- return new TaskAttemptID("", 0, false, 0, 0);
+ return TaskAttemptID.forName("attempt__0000_r_000000_0");
}
});
} catch (IOException e) {