big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-2629. Workaround a JVM class loading quirk which prevents JIT compilation of inner classes methods in ReduceContextImpl. Contributed by Eric Caspole.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1187183 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2011-10-21 05:20:27 +00:00
parent 7c48130d41
commit 5945a05eee
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/CHANGES.txt
View File

@ -428,6 +428,9 @@ Release 0.23.0 - Unreleased
MAPREDUCE-901. Efficient framework counters. (llu via acmurthy) MAPREDUCE-901. Efficient framework counters. (llu via acmurthy)
MAPREDUCE-2629. Workaround a JVM class loading quirk which prevents
JIT compilation of inner classes methods in ReduceContextImpl.
BUG FIXES BUG FIXES
MAPREDUCE-2603. Disable High-Ram emulation in system tests. MAPREDUCE-2603. Disable High-Ram emulation in system tests.

12
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java
View File

@ -176,11 +176,15 @@ public VALUEIN getCurrentValue() {
return value; return value;
} }
BackupStore<KEYIN,VALUEIN> getBackupStore() {
return backupStore;
}
protected class ValueIterator implements ReduceContext.ValueIterator<VALUEIN> { protected class ValueIterator implements ReduceContext.ValueIterator<VALUEIN> {
private boolean inReset = false; private boolean inReset = false;
private boolean clearMarkFlag = false; private boolean clearMarkFlag = false;
@Override @Override
public boolean hasNext() { public boolean hasNext() {
try { try {
@ -247,7 +251,7 @@ public void remove() {
@Override @Override
public void mark() throws IOException { public void mark() throws IOException {
if (backupStore == null) { if (getBackupStore() == null) {
backupStore = new BackupStore<KEYIN,VALUEIN>(conf, taskid); backupStore = new BackupStore<KEYIN,VALUEIN>(conf, taskid);
} }
isMarked = true; isMarked = true;
@ -290,7 +294,7 @@ public void reset() throws IOException {
@Override @Override
public void clearMark() throws IOException { public void clearMark() throws IOException {
if (backupStore == null) { if (getBackupStore() == null) {
return; return;
} }
if (inReset) { if (inReset) {
@ -308,7 +312,7 @@ public void clearMark() throws IOException {
* @throws IOException * @throws IOException
*/ */
public void resetBackupStore() throws IOException { public void resetBackupStore() throws IOException {
if (backupStore == null) { if (getBackupStore() == null) {
return; return;
} }
inReset = isMarked = false; inReset = isMarked = false;