|
@@ -235,7 +235,7 @@ public class TestDFSIO implements Tool {
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_WRITE, execTime);
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_WRITE, execTime);
|
|
}
|
|
}
|
|
|
|
|
|
- @Test (timeout = 3000)
|
|
|
|
|
|
+ @Test (timeout = 10000)
|
|
public void testRead() throws Exception {
|
|
public void testRead() throws Exception {
|
|
FileSystem fs = cluster.getFileSystem();
|
|
FileSystem fs = cluster.getFileSystem();
|
|
long tStart = System.currentTimeMillis();
|
|
long tStart = System.currentTimeMillis();
|
|
@@ -244,7 +244,7 @@ public class TestDFSIO implements Tool {
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ, execTime);
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ, execTime);
|
|
}
|
|
}
|
|
|
|
|
|
- @Test (timeout = 3000)
|
|
|
|
|
|
+ @Test (timeout = 10000)
|
|
public void testReadRandom() throws Exception {
|
|
public void testReadRandom() throws Exception {
|
|
FileSystem fs = cluster.getFileSystem();
|
|
FileSystem fs = cluster.getFileSystem();
|
|
long tStart = System.currentTimeMillis();
|
|
long tStart = System.currentTimeMillis();
|
|
@@ -254,7 +254,7 @@ public class TestDFSIO implements Tool {
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ_RANDOM, execTime);
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ_RANDOM, execTime);
|
|
}
|
|
}
|
|
|
|
|
|
- @Test (timeout = 3000)
|
|
|
|
|
|
+ @Test (timeout = 10000)
|
|
public void testReadBackward() throws Exception {
|
|
public void testReadBackward() throws Exception {
|
|
FileSystem fs = cluster.getFileSystem();
|
|
FileSystem fs = cluster.getFileSystem();
|
|
long tStart = System.currentTimeMillis();
|
|
long tStart = System.currentTimeMillis();
|
|
@@ -264,7 +264,7 @@ public class TestDFSIO implements Tool {
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ_BACKWARD, execTime);
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ_BACKWARD, execTime);
|
|
}
|
|
}
|
|
|
|
|
|
- @Test (timeout = 3000)
|
|
|
|
|
|
+ @Test (timeout = 10000)
|
|
public void testReadSkip() throws Exception {
|
|
public void testReadSkip() throws Exception {
|
|
FileSystem fs = cluster.getFileSystem();
|
|
FileSystem fs = cluster.getFileSystem();
|
|
long tStart = System.currentTimeMillis();
|
|
long tStart = System.currentTimeMillis();
|
|
@@ -274,7 +274,7 @@ public class TestDFSIO implements Tool {
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ_SKIP, execTime);
|
|
bench.analyzeResult(fs, TestType.TEST_TYPE_READ_SKIP, execTime);
|
|
}
|
|
}
|
|
|
|
|
|
- @Test (timeout = 6000)
|
|
|
|
|
|
+ @Test (timeout = 10000)
|
|
public void testAppend() throws Exception {
|
|
public void testAppend() throws Exception {
|
|
FileSystem fs = cluster.getFileSystem();
|
|
FileSystem fs = cluster.getFileSystem();
|
|
long tStart = System.currentTimeMillis();
|
|
long tStart = System.currentTimeMillis();
|