/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | TestHDFSConcat.java | 56 private static final short REPL_FACTOR = 2; field in TestHDFSConcat 108 DFSTestUtil.createFile(dfs, trgPath, fileLen, REPL_FACTOR, 1); in testConcat() 128 DFSTestUtil.createFile(dfs, path, fileLen, REPL_FACTOR, i); in testConcat() 210 DFSTestUtil.createFile(dfs, p, fileLen, REPL_FACTOR, 1); in testConcat() 375 DFSTestUtil.createFile(dfs, trg, fileLen, REPL_FACTOR, 1); in testIllegalArg() 383 DFSTestUtil.createFile(dfs, src, fileLen, REPL_FACTOR, 1); in testIllegalArg() 414 dfs.getDefaultBlockSize(trg) * 2, REPL_FACTOR, 0L); in testIllegalArg() 445 Assert.assertEquals(blockSize * REPL_FACTOR + in testConcatWithQuotaDecrease() 452 blockSize * REPL_FACTOR + blockSize * 2 * REPL_FACTOR * srcNum, in testConcatWithQuotaDecrease() 500 DFSTestUtil.createFile(dfs, trg, blockSize, REPL_FACTOR, 1); in testConcatRelativeTargetPath() [all …]
|
H A D | TestFsck.java | 934 final short REPL_FACTOR = 2; in testFsckMissingReplicas() local 961 DFSTestUtil.createFile(dfs, path, fileLen, REPL_FACTOR, 1); in testFsckMissingReplicas() 983 (NUM_BLOCKS*REPL_FACTOR) - (NUM_BLOCKS*NUM_REPLICAS)); in testFsckMissingReplicas() 1002 final short REPL_FACTOR = 2; in testFsckMisPlacedReplicas() local 1033 DFSTestUtil.createFile(dfs, path, fileLen, REPL_FACTOR, 1); in testFsckMisPlacedReplicas() 1203 final short REPL_FACTOR = 2; in testBlockIdCK() local 1230 util.createFile(dfs, path, 1024, REPL_FACTOR , 1000L); in testBlockIdCK() 1231 util.waitReplication(dfs, path, REPL_FACTOR); in testBlockIdCK() 1264 final short REPL_FACTOR = 1; in testBlockIdCKDecommission() local 1291 util.createFile(dfs, path, 1024, REPL_FACTOR, 1000L); in testBlockIdCKDecommission() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
H A D | TestBlockReaderLocalLegacy.java | 84 final short REPL_FACTOR = 1; in testStablePositionAfterCorruptRead() local 95 DFSTestUtil.createFile(fs, path, FILE_LENGTH, REPL_FACTOR, 12345L); in testStablePositionAfterCorruptRead() 96 DFSTestUtil.waitReplication(fs, path, REPL_FACTOR); in testStablePositionAfterCorruptRead() 100 assertEquals("All replicas not corrupted", REPL_FACTOR, blockFilesCorrupted); in testStablePositionAfterCorruptRead() 133 final short REPL_FACTOR = 1; in testBothOldAndNewShortCircuitConfigured() local 152 DFSTestUtil.waitReplication(fs, path, REPL_FACTOR); in testBothOldAndNewShortCircuitConfigured() 164 final short REPL_FACTOR = 1; in testBlockReaderLocalLegacyWithAppend() local 174 DFSTestUtil.createFile(dfs, path, 10, REPL_FACTOR, 0); in testBlockReaderLocalLegacyWithAppend() 175 DFSTestUtil.waitReplication(dfs, path, REPL_FACTOR); in testBlockReaderLocalLegacyWithAppend()
|
H A D | TestPipelines.java | 46 private static final short REPL_FACTOR = 3; field in TestPipelines 62 cluster = new MiniDFSCluster.Builder(conf).numDataNodes(REPL_FACTOR).build(); in startUpCluster() 93 DFSTestUtil.createFile(fs, filePath, FILE_SIZE, REPL_FACTOR, rand.nextLong()); in pipeline_01()
|
H A D | TestDFSClientRetries.java | 1158 final short REPL_FACTOR = 1; in testRetryOnChecksumFailure() local 1165 DFSTestUtil.createFile(fs, path, FILE_LENGTH, REPL_FACTOR, 12345L); in testRetryOnChecksumFailure() 1166 DFSTestUtil.waitReplication(fs, path, REPL_FACTOR); in testRetryOnChecksumFailure() 1170 assertEquals("All replicas not corrupted", REPL_FACTOR, in testRetryOnChecksumFailure()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/server/namenode/ |
H A D | TestHDFSConcat.java | 50 private static final short REPL_FACTOR = 2; field in TestHDFSConcat 68 cluster = new MiniDFSCluster(conf, REPL_FACTOR, true, null); in startUpCluster() 103 DFSTestUtil.createFile(dfs, trgPath, fileLen, REPL_FACTOR, 1); in testConcat() 119 DFSTestUtil.createFile(dfs, path, fileLen, REPL_FACTOR, 1); in testConcat() 191 DFSTestUtil.createFile(dfs, p, fileLen, REPL_FACTOR, 1); in testConcat() 200 DFSTestUtil.createFile(dfs, smallFile, sFileLen, REPL_FACTOR, 1); in testConcat() 244 DFSTestUtil.createFile(dfs, filePath1, trgFileLen, REPL_FACTOR, 1); in testConcatNotCompleteBlock() 259 DFSTestUtil.createFile(dfs, filePath2, srcFileLen, REPL_FACTOR, 1); in testConcatNotCompleteBlock() 317 DFSTestUtil.createFile(dfs, trg, fileLen, REPL_FACTOR, 1); in testIllegalArg() 325 DFSTestUtil.createFile(dfs, src, fileLen, REPL_FACTOR, 1); in testIllegalArg()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | BlockReportTestBase.java | 84 private static short REPL_FACTOR = 1; field in BlockReportTestBase 109 REPL_FACTOR = 1; //Reset if case a test has modified the value in startUpCluster() 110 cluster = new MiniDFSCluster.Builder(conf).numDataNodes(REPL_FACTOR).build(); in startUpCluster() 265 FILE_SIZE, REPL_FACTOR, rand.nextLong()); in blockReport_02() 368 FILE_SIZE, REPL_FACTOR, rand.nextLong()); in blockReport_04() 597 REPL_FACTOR = 2; in testOneReplicaRbwReportArrivesAfterBlockCompleted() 602 FSDataOutputStream out = fs.create(filePath, REPL_FACTOR); in testOneReplicaRbwReportArrivesAfterBlockCompleted() 708 REPL_FACTOR = 2; in writeFile() 735 DFSTestUtil.waitReplication(fs, filePath, REPL_FACTOR); in startDNandWait() 745 REPL_FACTOR, rand.nextLong()); in prepareForRide()
|
H A D | TestDataNodeRollingUpgrade.java | 60 private static final short REPL_FACTOR = 1; field in TestDataNodeRollingUpgrade 75 cluster = new Builder(conf).numDataNodes(REPL_FACTOR).build(); in startCluster() 228 DFSTestUtil.createFile(fs, testFile3, FILE_SIZE, REPL_FACTOR, SEED); in testDatanodeRUwithRegularUpgrade() 239 DFSTestUtil.createFile(fs, testFile1, FILE_SIZE, REPL_FACTOR, SEED); in rollingUpgradeAndFinalize() 240 DFSTestUtil.createFile(fs, testFile2, FILE_SIZE, REPL_FACTOR, SEED); in rollingUpgradeAndFinalize() 262 DFSTestUtil.createFile(fs, testFile1, FILE_SIZE, REPL_FACTOR, SEED); in testDatanodeRollingUpgradeWithRollback()
|
H A D | TestDnRespectsBlockReportSplitThreshold.java | 56 private static final short REPL_FACTOR = 1; field in TestDnRespectsBlockReportSplitThreshold 69 .numDataNodes(REPL_FACTOR) in startUpCluster() 88 blockCount * BLOCK_SIZE, BLOCK_SIZE, REPL_FACTOR, seed); in createFile()
|
H A D | TestStorageReport.java | 52 private static final short REPL_FACTOR = 1; field in TestStorageReport 64 .numDataNodes(REPL_FACTOR) in startUpCluster()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ |
H A D | LazyPersistTestCase.java | 83 protected static final short REPL_FACTOR = 1; field in LazyPersistTestCase 179 BLOCK_SIZE, REPL_FACTOR, seed, true); in makeRandomTestFile() 198 REPL_FACTOR, in makeTestFile() 264 .numDataNodes(REPL_FACTOR) in startUpCluster()
|
H A D | TestScrLazyPersistFiles.java | 73 startUpCluster(REPL_FACTOR, in testRamDiskShortCircuitRead() 114 startUpCluster(REPL_FACTOR, new StorageType[] { RAM_DISK, DEFAULT }, in testRamDiskEvictionWithShortCircuitReadHandle()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/aop/org/apache/hadoop/hdfs/ |
H A D | TestFiPipelines.java | 45 private static short REPL_FACTOR = 3; field in TestFiPipelines 60 cluster = new MiniDFSCluster.Builder(conf).numDataNodes(REPL_FACTOR).build(); in startUpCluster()
|