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

HADOOP-16909 Typo in distcp counters.

Browse Source 
Contributed by Sebastian Nagel.
This commit is contained in:
Sebastian Nagel 2020-03-09 15:37:08 +01:00 committed by GitHub
parent c6b8a30386
commit 18050bc583
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/file/tfile/TestTFile.java
View File

@ -109,7 +109,7 @@ private int readAndCheckbytes(Scanner scanner, int start, int n)
byte[] val = readValue(scanner); byte[] val = readValue(scanner);
String keyStr = String.format(localFormatter, i); String keyStr = String.format(localFormatter, i);
String valStr = value + keyStr; String valStr = value + keyStr;
assertTrue("btyes for keys do not match " + keyStr + " " assertTrue("bytes for keys do not match " + keyStr + " "
+ new String(key), Arrays.equals(keyStr.getBytes(), key)); + new String(key), Arrays.equals(keyStr.getBytes(), key));
assertTrue("bytes for vals do not match " + valStr + " " assertTrue("bytes for vals do not match " + valStr + " "
+ new String(val), Arrays.equals( + new String(val), Arrays.equals(
@ -117,7 +117,7 @@ private int readAndCheckbytes(Scanner scanner, int start, int n)
assertTrue(scanner.advance()); assertTrue(scanner.advance());
key = readKey(scanner); key = readKey(scanner);
val = readValue(scanner); val = readValue(scanner);
assertTrue("btyes for keys do not match", Arrays.equals( assertTrue("bytes for keys do not match", Arrays.equals(
keyStr.getBytes(), key)); keyStr.getBytes(), key));
assertTrue("bytes for vals do not match", Arrays.equals( assertTrue("bytes for vals do not match", Arrays.equals(
valStr.getBytes(), val)); valStr.getBytes(), val));
@ -146,11 +146,11 @@ private int readLargeRecords(Scanner scanner, int start, int n)
for (int i = start; i < (start + n); i++) { for (int i = start; i < (start + n); i++) {
byte[] key = readKey(scanner); byte[] key = readKey(scanner);
String keyStr = String.format(localFormatter, i); String keyStr = String.format(localFormatter, i);
assertTrue("btyes for keys do not match", Arrays.equals( assertTrue("bytes for keys do not match", Arrays.equals(
keyStr.getBytes(), key)); keyStr.getBytes(), key));
scanner.advance(); scanner.advance();
key = readKey(scanner); key = readKey(scanner);
assertTrue("btyes for keys do not match", Arrays.equals( assertTrue("bytes for keys do not match", Arrays.equals(
keyStr.getBytes(), key)); keyStr.getBytes(), key));
scanner.advance(); scanner.advance();
} }

2
hadoop-tools/hadoop-distcp/src/main/resources/org/apache/hadoop/tools/mapred/CopyMapper_Counter.properties
View File

@ -21,4 +21,4 @@ BYTESCOPIED.name= Bytes Copied
BYTESEXPECTED.name= Bytes Expected BYTESEXPECTED.name= Bytes Expected
BYTESFAILED.name= Bytes Failed BYTESFAILED.name= Bytes Failed
BYTESSKIPPED.name= Bytes Skipped BYTESSKIPPED.name= Bytes Skipped
BANDWIDTH_IN_BYTES.name= Bandwidth in Btyes BANDWIDTH_IN_BYTES.name= Bandwidth in Bytes