Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MAPREDUCE-7430 FileSystemCount enumeration changes will cause mapreduce application failure during upgrade

This commit is contained in:
Daniel-009497 2022-12-23 15:33:55 +08:00
parent ca3526da92
commit a58011dd86
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/counters/FileSystemCounterGroup.java
View File

@ -311,11 +311,14 @@ public abstract class FileSystemCounterGroup<C extends Counter>
String scheme = WritableUtils.readString(in); // scheme String scheme = WritableUtils.readString(in); // scheme
int numCounters = WritableUtils.readVInt(in); // #counter int numCounters = WritableUtils.readVInt(in); // #counter
for (int j = 0; j < numCounters; ++j) { for (int j = 0; j < numCounters; ++j) {
findCounter(scheme, enums[WritableUtils.readVInt(in)]) // key int countTypeIndex = WritableUtils.readVInt(in);
if (countTypeIndex < enums.length) {
findCounter(scheme, enums[countTypeIndex]) // key
.setValue(WritableUtils.readVLong(in)); // value .setValue(WritableUtils.readVLong(in)); // value
} }
} }
} }
}
@Override @Override
public Iterator<C> iterator() { public Iterator<C> iterator() {