Home
last modified time | relevance | path

Searched refs:REPL_FACTOR (Results 1 – 13 of 13) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/
H A DTestHDFSConcat.java56 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 DTestFsck.java934 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 DTestBlockReaderLocalLegacy.java84 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 DTestPipelines.java46 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 DTestDFSClientRetries.java1158 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 DTestHDFSConcat.java50 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 DBlockReportTestBase.java84 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 DTestDataNodeRollingUpgrade.java60 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 DTestDnRespectsBlockReportSplitThreshold.java56 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 DTestStorageReport.java52 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 DLazyPersistTestCase.java83 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 DTestScrLazyPersistFiles.java73 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 DTestFiPipelines.java45 private static short REPL_FACTOR = 3; field in TestFiPipelines
60 cluster = new MiniDFSCluster.Builder(conf).numDataNodes(REPL_FACTOR).build(); in startUpCluster()