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

fix checkstyle

Browse Source
This commit is contained in:
wenxin he 2017-06-17 11:30:18 +08:00 committed by 何文鑫10087558
parent 9a50dfedd9
commit 2039eb7e86
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -337,9 +337,10 @@ public void testSequentialReadSkip() throws Exception {
@Test(timeout = 60000) @Test(timeout = 60000)
public void testSequentialTruncate() throws Exception { public void testSequentialTruncate() throws Exception {
FileSystem fs = cluster.getFileSystem(); FileSystem fs = cluster.getFileSystem();
// given DEFAULT_NR_BYTES files to be truncated
bench.sequentialTest(fs, TestType.TEST_TYPE_WRITE, bench.sequentialTest(fs, TestType.TEST_TYPE_WRITE,
DEFAULT_NR_BYTES, DEFAULT_NR_BYTES, DEFAULT_NR_FILES);
DEFAULT_NR_FILES); // make sure the length of files to be truncated is DEFAULT_NR_BYTES // test truncate
bench.sequentialTest(fs, TestType.TEST_TYPE_TRUNCATE, bench.sequentialTest(fs, TestType.TEST_TYPE_TRUNCATE,
DEFAULT_NR_BYTES, DEFAULT_NR_FILES); DEFAULT_NR_BYTES, DEFAULT_NR_FILES);
} }
@ -774,14 +775,16 @@ private void sequentialTest(FileSystem fs,
default: default:
return; return;
} }
for(int i=0; i < nrFiles; i++) { for (int i = 0; i < nrFiles; i++) {
ioer.configure(new JobConf(config, TestDFSIO.class)); ioer.configure(new JobConf(config, TestDFSIO.class));
String fileName = getFileName(i); String fileName = getFileName(i);
ioer.stream = ioer.getIOStream(fileName); ioer.stream = ioer.getIOStream(fileName);
try { try {
ioer.doIO(Reporter.NULL, fileName, fileSize); ioer.doIO(Reporter.NULL, fileName, fileSize);
} finally { } finally {
if(ioer.stream != null) ioer.stream.close(); if (ioer.stream != null) {
ioer.stream.close();
}
} }
} }
} }