|
@@ -88,6 +88,8 @@ import org.apache.log4j.LogManager;
|
|
|
import com.google.common.base.Supplier;
|
|
|
import com.google.common.primitives.Ints;
|
|
|
|
|
|
+import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_FSDATASETCACHE_MAX_THREADS_PER_VOLUME_KEY;
|
|
|
+
|
|
|
public class TestFsDatasetCache {
|
|
|
private static final Log LOG = LogFactory.getLog(TestFsDatasetCache.class);
|
|
|
|
|
@@ -124,6 +126,7 @@ public class TestFsDatasetCache {
|
|
|
conf.setLong(DFSConfigKeys.DFS_DATANODE_MAX_LOCKED_MEMORY_KEY,
|
|
|
CACHE_CAPACITY);
|
|
|
conf.setLong(DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_KEY, 1);
|
|
|
+ conf.setInt(DFS_DATANODE_FSDATASETCACHE_MAX_THREADS_PER_VOLUME_KEY, 10);
|
|
|
|
|
|
prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
|
|
|
NativeIO.POSIX.setCacheManipulator(new NoMlockCacheManipulator());
|
|
@@ -454,7 +457,7 @@ public class TestFsDatasetCache {
|
|
|
}, 100, 10000);
|
|
|
}
|
|
|
|
|
|
- @Test(timeout=60000)
|
|
|
+ @Test(timeout=600000)
|
|
|
public void testPageRounder() throws Exception {
|
|
|
// Write a small file
|
|
|
Path fileName = new Path("/testPageRounder");
|