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

Fixing bug : https://issues.apache.org/jira/browse/MAPREDUCE-7089

This commit is contained in:
schalyanagaraju 2018-12-28 10:47:51 -08:00
parent 128f340f4f
commit dec6a28462
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java
View File

@ -547,6 +547,9 @@ public class TestDFSIO implements Tool {
String name,
long totalSize // in bytes
) throws IOException {
if (bufferSize <= 0) {
throw new IllegalArgumentException("Buffer size must be greater than 0");
}
InputStream in = (InputStream)this.stream;
long actualSize = 0;
while (actualSize < totalSize) {