/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/ |
H A D | HdfsConfiguration.java | 74 DFSConfigKeys.DFS_DATANODE_DATA_DIR_KEY), in addDeprecatedKeys() 80 DFSConfigKeys.DFS_NAMENODE_MAX_OBJECTS_KEY), in addDeprecatedKeys() 82 DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY), in addDeprecatedKeys() 86 DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY), in addDeprecatedKeys() 110 DFSConfigKeys.DFS_DATANODE_HOST_NAME_KEY), in addDeprecatedKeys() 112 DFSConfigKeys.DFS_METRICS_SESSION_ID_KEY), in addDeprecatedKeys() 126 DFSConfigKeys.DFS_PERMISSIONS_ENABLED_KEY), in addDeprecatedKeys() 132 DFSConfigKeys.DFS_BLOCK_SIZE_KEY), in addDeprecatedKeys() 136 DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY), in addDeprecatedKeys() 138 DFSConfigKeys.DFS_NAMESERVICES), in addDeprecatedKeys() [all …]
|
H A D | DFSClient.java | 447 DFSConfigKeys.DFS_CLIENT_READ_SHORTCIRCUIT_KEY, in Conf() 453 DFSConfigKeys.DFS_DOMAIN_SOCKET_PATH_KEY, in Conf() 454 DFSConfigKeys.DFS_DOMAIN_SOCKET_PATH_DEFAULT); in Conf() 467 DFSConfigKeys.DFS_DOMAIN_SOCKET_PATH_KEY in Conf() 484 DFSConfigKeys.DFS_CLIENT_MMAP_ENABLED, in Conf() 485 DFSConfigKeys.DFS_CLIENT_MMAP_ENABLED_DEFAULT); in Conf() 487 DFSConfigKeys.DFS_CLIENT_MMAP_CACHE_SIZE, in Conf() 532 DFSConfigKeys.DFS_CHECKSUM_TYPE_KEY, in getChecksumType() 533 DFSConfigKeys.DFS_CHECKSUM_TYPE_DEFAULT); in getChecksumType() 538 + DFSConfigKeys.DFS_CHECKSUM_TYPE_DEFAULT); in getChecksumType() [all …]
|
H A D | DFSUtil.java | 21 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_ADMIN; 749 DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY); 752 DFSConfigKeys.DFS_NAMENODE_HTTPS_ADDRESS_KEY); 854 (DFSConfigKeys.DFS_INTERNAL_NAMESERVICES_KEY); 858 (DFSConfigKeys.DFS_NAMESERVICES); 979 DFSConfigKeys.DFS_NAMENODE_SERVICE_RPC_ADDRESS_KEY, 980 DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY); 1109 DFSConfigKeys.DFS_NAMENODE_SERVICE_RPC_ADDRESS_KEY, 1110 DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY); 1610 DFSConfigKeys.DFS_HTTPS_ENABLE_DEFAULT); [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | DNConf.java | 57 import org.apache.hadoop.hdfs.DFSConfigKeys; 114 DFSConfigKeys.DFS_DATANODE_SOCKET_REUSE_KEEPALIVE_KEY, in DNConf() 127 DFSConfigKeys.DFS_DATANODE_READAHEAD_BYTES_KEY, in DNConf() 128 DFSConfigKeys.DFS_DATANODE_READAHEAD_BYTES_DEFAULT); in DNConf() 130 DFSConfigKeys.DFS_DATANODE_DROP_CACHE_BEHIND_WRITES_KEY, in DNConf() 133 DFSConfigKeys.DFS_DATANODE_SYNC_BEHIND_WRITES_KEY, in DNConf() 134 DFSConfigKeys.DFS_DATANODE_SYNC_BEHIND_WRITES_DEFAULT); in DNConf() 139 DFSConfigKeys.DFS_DATANODE_DROP_CACHE_BEHIND_READS_KEY, in DNConf() 142 DFSConfigKeys.DFS_DATANODE_USE_DN_HOSTNAME, in DNConf() 143 DFSConfigKeys.DFS_DATANODE_USE_DN_HOSTNAME_DEFAULT); in DNConf() [all …]
|
/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 | TestNameEditsConfigs.java | 38 import org.apache.hadoop.hdfs.DFSConfigKeys; 286 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, nameAndEdits + in testNameEditsConfigs() 344 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testNameEditsRequiredConfigs() 347 DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_REQUIRED_KEY, in testNameEditsRequiredConfigs() 350 DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testNameEditsRequiredConfigs() 371 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testNameEditsRequiredConfigs() 374 DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testNameEditsRequiredConfigs() 378 DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_REQUIRED_KEY, in testNameEditsRequiredConfigs() 395 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testNameEditsRequiredConfigs() 398 DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testNameEditsRequiredConfigs() [all …]
|
H A D | TestStartup.java | 47 import org.apache.hadoop.hdfs.DFSConfigKeys; 113 config.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in setUp() 115 config.set(DFSConfigKeys.DFS_DATANODE_DATA_DIR_KEY, in setUp() 120 config.set(DFSConfigKeys.DFS_NAMENODE_CHECKPOINT_DIR_KEY, in setUp() 311 config.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testChkpointStartup2() 313 config.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testChkpointStartup2() 338 config.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testChkpointStartup1() 340 config.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testChkpointStartup1() 363 config.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testSNNStartup() 365 config.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testSNNStartup() [all …]
|
H A D | TestValidateConfigurationSettings.java | 23 import org.apache.hadoop.hdfs.DFSConfigKeys; 60 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testThatMatchingRPCandHttpPortsThrowException() 68 conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, "127.0.0.1:" + port); in testThatMatchingRPCandHttpPortsThrowException() 88 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testThatDifferentRPCandHttpPortsAreOK() 99 conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, "127.0.0.1:" + port2); in testThatDifferentRPCandHttpPortsAreOK() 126 conf.set(DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY, in testGenericKeysForNameNodeFormat() 128 conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, in testGenericKeysForNameNodeFormat() 131 conf.set(DFSConfigKeys.DFS_NAMESERVICES, "ns1"); in testGenericKeysForNameNodeFormat() 139 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY + ".ns1", in testGenericKeysForNameNodeFormat()
|
H A D | TestFsLimits.java | 35 import org.apache.hadoop.hdfs.DFSConfigKeys; 65 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in setUp() 86 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_COMPONENT_LENGTH_KEY, 2); in testMaxComponentLength() 96 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_COMPONENT_LENGTH_KEY, 2); in testMaxComponentLengthRename() 109 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_DIRECTORY_ITEMS_KEY, 2); in testMaxDirItems() 119 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_DIRECTORY_ITEMS_KEY, 2); in testMaxDirItemsRename() 138 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_DIRECTORY_ITEMS_KEY, 0); in testMaxDirItemsLimits() 154 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_COMPONENT_LENGTH_KEY, 3); in testMaxComponentsAndMaxDirItems() 155 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_DIRECTORY_ITEMS_KEY, 2); in testMaxComponentsAndMaxDirItems() 165 conf.setInt(DFSConfigKeys.DFS_NAMENODE_MAX_COMPONENT_LENGTH_KEY, 3); in testDuringEditLogs() [all …]
|
H A D | TestNameNodeResourceChecker.java | 32 import org.apache.hadoop.hdfs.DFSConfigKeys; 53 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, nameDir.getAbsolutePath()); in setUp() 63 conf.setLong(DFSConfigKeys.DFS_NAMENODE_DU_RESERVED_KEY, 0); in testCheckAvailability() 77 conf.setLong(DFSConfigKeys.DFS_NAMENODE_DU_RESERVED_KEY, Long.MAX_VALUE); in testCheckAvailabilityNeg() 95 conf.setLong(DFSConfigKeys.DFS_NAMENODE_RESOURCE_CHECK_INTERVAL_KEY, 1); in testCheckThatNameNodeResourceMonitorIsRunning() 149 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testChecking2NameDirsOnOneVolume() 151 conf.setLong(DFSConfigKeys.DFS_NAMENODE_DU_RESERVED_KEY, Long.MAX_VALUE); in testChecking2NameDirsOnOneVolume() 168 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, nameDir.getAbsolutePath()); in testCheckingExtraVolumes() 170 conf.setLong(DFSConfigKeys.DFS_NAMENODE_DU_RESERVED_KEY, Long.MAX_VALUE); in testCheckingExtraVolumes() 191 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testLowResourceVolumePolicy() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
H A D | TestHDFSServerPorts.java | 100 config.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in startNameNode() 131 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in startBackupNode() 133 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in startBackupNode() 134 "${" + DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY + "}"); in startBackupNode() 263 conf2.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in runTestNameNodePorts() 308 conf2.set(DFSConfigKeys.DFS_DATANODE_ADDRESS_KEY, in testDataNodePorts() 315 conf2.set(DFSConfigKeys.DFS_DATANODE_ADDRESS_KEY, THIS_HOST); in testDataNodePorts() 316 conf2.set(DFSConfigKeys.DFS_DATANODE_HTTP_ADDRESS_KEY, in testDataNodePorts() 322 conf2.set(DFSConfigKeys.DFS_DATANODE_ADDRESS_KEY, THIS_HOST); in testDataNodePorts() 378 DFSConfigKeys.DFS_NAMENODE_BACKUP_HTTP_ADDRESS_KEY)); in testBackupNodePorts() [all …]
|
H A D | TestParallelShortCircuitReadUnCached.java | 41 conf.set(DFSConfigKeys.DFS_DOMAIN_SOCKET_PATH_KEY, in setupCluster() 44 conf.setBoolean(DFSConfigKeys.DFS_CLIENT_READ_SHORTCIRCUIT_KEY, true); in setupCluster() 47 conf.setBoolean(DFSConfigKeys.DFS_ENCRYPT_DATA_TRANSFER_KEY, true); in setupCluster() 48 conf.setBoolean(DFSConfigKeys.DFS_BLOCK_ACCESS_TOKEN_ENABLE_KEY, true); in setupCluster() 49 conf.setBoolean(DFSConfigKeys. in setupCluster() 51 conf.setBoolean(DFSConfigKeys. in setupCluster() 54 conf.setInt(DFSConfigKeys.DFS_DATANODE_SOCKET_REUSE_KEEPALIVE_KEY, 1); in setupCluster() 55 conf.setLong(DFSConfigKeys.DFS_CLIENT_SOCKET_CACHE_EXPIRY_MSEC_KEY, in setupCluster() 57 conf.setInt(DFSConfigKeys.DFS_CLIENT_SOCKET_CACHE_CAPACITY_KEY, 32); in setupCluster() 59 conf.setInt(DFSConfigKeys. in setupCluster()
|
H A D | TestDatanodeConfig.java | 54 conf.setInt(DFSConfigKeys.DFS_DATANODE_HTTPS_PORT_KEY, 0); in setUp() 55 conf.set(DFSConfigKeys.DFS_DATANODE_ADDRESS_KEY, "localhost:0"); in setUp() 56 conf.set(DFSConfigKeys.DFS_DATANODE_IPC_ADDRESS_KEY, "localhost:0"); in setUp() 86 conf.set(DFSConfigKeys.DFS_DATANODE_DATA_DIR_KEY, dnDir); in testDataDirectories() 105 conf.set(DFSConfigKeys.DFS_DATANODE_DATA_DIR_KEY, in testDataDirectories() 138 conf.set(DFSConfigKeys.DFS_DATANODE_DATA_DIR_KEY, in testMemlockLimit() 141 getLong(DFSConfigKeys.DFS_DATANODE_MAX_LOCKED_MEMORY_KEY, in testMemlockLimit() 142 DFSConfigKeys.DFS_DATANODE_MAX_LOCKED_MEMORY_DEFAULT); in testMemlockLimit() 146 conf.setLong(DFSConfigKeys.DFS_DATANODE_MAX_LOCKED_MEMORY_KEY, in testMemlockLimit() 152 conf.setLong(DFSConfigKeys.DFS_DATANODE_MAX_LOCKED_MEMORY_KEY, in testMemlockLimit() [all …]
|
H A D | TestParallelShortCircuitLegacyRead.java | 30 conf.set(DFSConfigKeys.DFS_DOMAIN_SOCKET_PATH_KEY, ""); in setupCluster() 31 conf.setBoolean(DFSConfigKeys.DFS_CLIENT_USE_LEGACY_BLOCKREADERLOCAL, true); in setupCluster() 32 conf.setBoolean(DFSConfigKeys.DFS_CLIENT_DOMAIN_SOCKET_DATA_TRAFFIC, false); in setupCluster() 33 conf.setBoolean(DFSConfigKeys.DFS_CLIENT_READ_SHORTCIRCUIT_KEY, true); in setupCluster() 34 conf.setBoolean(DFSConfigKeys. in setupCluster() 36 conf.set(DFSConfigKeys.DFS_BLOCK_LOCAL_PATH_ACCESS_USER_KEY, in setupCluster()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | NameNodeHttpServer.java | 30 import org.apache.hadoop.hdfs.DFSConfigKeys; 73 DFSConfigKeys.DFS_WEBHDFS_USER_PATTERN_KEY, in initWebHdfs() 74 DFSConfigKeys.DFS_WEBHDFS_USER_PATTERN_DEFAULT)); in initWebHdfs() 78 DFSConfigKeys.DFS_WEBHDFS_AUTHENTICATION_FILTER_KEY, in initWebHdfs() 107 DFSConfigKeys.DFS_NAMENODE_HTTPS_ADDRESS_KEY, in start() 108 DFSConfigKeys.DFS_NAMENODE_HTTPS_ADDRESS_DEFAULT); in start() 124 DFSConfigKeys.DFS_NAMENODE_KEYTAB_FILE_KEY); in start() 132 + DFSConfigKeys.DFS_DATANODE_HTTPS_DEFAULT_PORT)); in start() 147 conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, in start() 153 conf.set(DFSConfigKeys.DFS_NAMENODE_HTTPS_ADDRESS_KEY, in start() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/datatransfer/ |
H A D | ReplaceDatanodeOnFailure.java | 24 import org.apache.hadoop.hdfs.DFSConfigKeys; 118 + DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_ENABLE_KEY in checkEnabled() 159 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_BEST_EFFORT_KEY, in get() 167 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_ENABLE_KEY, in getPolicy() 168 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_ENABLE_DEFAULT); in getPolicy() 174 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_POLICY_KEY, in getPolicy() 175 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_POLICY_DEFAULT); in getPolicy() 183 + DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_POLICY_KEY in getPolicy() 191 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_ENABLE_KEY, in write() 194 DFSConfigKeys.DFS_CLIENT_WRITE_REPLACE_DATANODE_ON_FAILURE_POLICY_KEY, in write() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/aop/org/apache/hadoop/hdfs/ |
H A D | TestFiHFlush.java | 86 conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize); in hFlushFi01_b() 87 conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize); in hFlushFi01_b() 101 conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize); in hFlushFi01_c() 102 conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize); in hFlushFi01_c() 124 conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize); in hFlushFi02_b() 125 conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize); in hFlushFi02_b() 138 conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize); in hFlushFi02_c() 139 conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize); in hFlushFi02_c() 161 conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize); in hFlushFi03_b() 162 conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize); in hFlushFi03_b() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/ |
H A D | TestHAConfiguration.java | 20 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY; 21 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_SHARED_EDITS_DIR_KEY; 31 import org.apache.hadoop.hdfs.DFSConfigKeys; 63 conf.set(DFSConfigKeys.DFS_NAMESERVICES, nsId); in getHAConf() 65 DFSConfigKeys.DFS_HA_NAMENODES_KEY_PREFIX, nsId), in getHAConf() 67 conf.set(DFSConfigKeys.DFS_HA_NAMENODE_ID_KEY, "nn1"); in getHAConf() 69 DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY, nsId, "nn1"), in getHAConf() 72 DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY, nsId, "nn2"), in getHAConf() 81 conf.set(DFSConfigKeys.DFS_NAMESERVICE_ID, "ns1"); in testGetOtherNNHttpAddress() 91 DFSConfigKeys.DFS_NAMENODE_HTTP_PORT_DEFAULT, ""), in testGetOtherNNHttpAddress()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
H A D | DatanodeManager.java | 31 import org.apache.hadoop.hdfs.DFSConfigKeys; 203 conf.get(DFSConfigKeys.DFS_HOSTS_EXCLUDE, "")); in DatanodeManager() 228 DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_KEY, in DatanodeManager() 229 DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_DEFAULT); in DatanodeManager() 239 LOG.info(DFSConfigKeys.DFS_BLOCK_INVALIDATE_LIMIT_KEY in DatanodeManager() 283 DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_KEY, in getStaleIntervalFromConf() 284 DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_DEFAULT); in getStaleIntervalFromConf() 1030 conf.get(DFSConfigKeys.DFS_HOSTS_EXCLUDE, "")); in refreshHostsReader() 1225 port = DFSConfigKeys.DFS_DATANODE_DEFAULT_PORT; in parseDNFromHostsEntry() 1234 DFSConfigKeys.DFS_DATANODE_HTTP_DEFAULT_PORT, in parseDNFromHostsEntry() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/qjournal/ |
H A D | TestSecureNNWithQJM.java | 23 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_BLOCK_ACCESS_TOKEN_ENABLE_KEY; 24 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATA_TRANSFER_PROTECTION_KEY; 25 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_HTTPS_ADDRESS_KEY; 26 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_KERBEROS_PRINCIPAL_KEY; 27 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_KEYTAB_FILE_KEY; 28 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_HTTP_POLICY_KEY; 29 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_JOURNALNODE_HTTPS_ADDRESS_KEY; 32 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_JOURNALNODE_KEYTAB_FILE_KEY; 33 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY; 34 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HTTPS_ADDRESS_KEY; [all …]
|
H A D | TestNNWithQJM.java | 30 import org.apache.hadoop.hdfs.DFSConfigKeys; 67 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testLogAndRestart() 69 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testLogAndRestart() 102 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testNewNamenodeTakesOverWriter() 104 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testNewNamenodeTakesOverWriter() 138 conf2.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testNewNamenodeTakesOverWriter() 140 conf2.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testNewNamenodeTakesOverWriter() 171 conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY, in testMismatchedNNIsRejected() 173 String defaultEditsDir = conf.get(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY); in testMismatchedNNIsRejected() 174 conf.set(DFSConfigKeys.DFS_NAMENODE_EDITS_DIR_KEY, in testMismatchedNNIsRejected() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/ |
H A D | TestDFSHAAdmin.java | 41 import org.apache.hadoop.hdfs.DFSConfigKeys; 90 conf.set(DFSConfigKeys.DFS_NAMESERVICES, NSID); in getHAConf() 91 conf.set(DFSConfigKeys.DFS_NAMESERVICE_ID, NSID); in getHAConf() 93 DFSConfigKeys.DFS_HA_NAMENODES_KEY_PREFIX, NSID), "nn1,nn2"); in getHAConf() 94 conf.set(DFSConfigKeys.DFS_HA_NAMENODE_ID_KEY, "nn1"); in getHAConf() 96 DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY, NSID, "nn1"), in getHAConf() 99 DFSConfigKeys.DFS_NAMENODE_RPC_ADDRESS_KEY, NSID, "nn2"), in getHAConf() 198 conf.setBoolean(DFSConfigKeys.DFS_HA_AUTO_FAILOVER_ENABLED_KEY, true); in testMutativeOperationsWithAutoHaEnabled() 250 conf.setBoolean(DFSConfigKeys.DFS_HA_AUTO_FAILOVER_ENABLED_KEY, true); in testMonitoringOperationsWithAutoHaEnabled() 327 conf.set(DFSConfigKeys.DFS_HA_FENCE_METHODS_KEY, "foobar!"); in testFailoverWithFenceAndBadFencer() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/ |
H A D | JournalNodeHttpServer.java | 28 import org.apache.hadoop.hdfs.DFSConfigKeys; 55 DFSConfigKeys.DFS_JOURNALNODE_HTTPS_ADDRESS_KEY, in start() 56 DFSConfigKeys.DFS_JOURNALNODE_HTTPS_ADDRESS_DEFAULT); in start() 61 DFSConfigKeys.DFS_JOURNALNODE_KERBEROS_INTERNAL_SPNEGO_PRINCIPAL_KEY, in start() 62 DFSConfigKeys.DFS_JOURNALNODE_KEYTAB_FILE_KEY); in start() 105 String addr = conf.get(DFSConfigKeys.DFS_JOURNALNODE_HTTP_ADDRESS_KEY, in getAddress() 106 DFSConfigKeys.DFS_JOURNALNODE_HTTP_ADDRESS_DEFAULT); in getAddress() 108 DFSConfigKeys.DFS_JOURNALNODE_HTTP_PORT_DEFAULT, in getAddress() 109 DFSConfigKeys.DFS_JOURNALNODE_HTTP_ADDRESS_KEY); in getAddress()
|
/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 | TestStartSecureDataNode.java | 33 import org.apache.hadoop.hdfs.DFSConfigKeys; 91 conf.set(DFSConfigKeys.DFS_NAMENODE_KERBEROS_PRINCIPAL_KEY, nnPrincipal); in testSecureNameNode() 92 conf.set(DFSConfigKeys.DFS_NAMENODE_KERBEROS_INTERNAL_SPNEGO_PRINCIPAL_KEY, in testSecureNameNode() 94 conf.set(DFSConfigKeys.DFS_NAMENODE_KEYTAB_FILE_KEY, nnKeyTab); in testSecureNameNode() 95 conf.set(DFSConfigKeys.DFS_DATANODE_KERBEROS_PRINCIPAL_KEY, dnPrincipal); in testSecureNameNode() 96 conf.set(DFSConfigKeys.DFS_DATANODE_KEYTAB_FILE_KEY, dnKeyTab); in testSecureNameNode() 98 conf.set(DFSConfigKeys.DFS_DATANODE_ADDRESS_KEY, "127.0.0.1:1004"); in testSecureNameNode() 99 conf.set(DFSConfigKeys.DFS_DATANODE_HTTP_ADDRESS_KEY, "127.0.0.1:1006"); in testSecureNameNode() 100 conf.set(DFSConfigKeys.DFS_DATANODE_DATA_DIR_KEY, "700"); in testSecureNameNode()
|
H A D | TestFsDatasetCacheRevocation.java | 33 import org.apache.hadoop.hdfs.DFSConfigKeys; 81 DFSConfigKeys.DFS_NAMENODE_PATH_BASED_CACHE_REFRESH_INTERVAL_MS, 50); in getDefaultConf() 82 conf.setLong(DFSConfigKeys.DFS_CACHEREPORT_INTERVAL_MSEC_KEY, 250); in getDefaultConf() 83 conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, BLOCK_SIZE); in getDefaultConf() 84 conf.setLong(DFSConfigKeys.DFS_DATANODE_MAX_LOCKED_MEMORY_KEY, in getDefaultConf() 86 conf.setLong(DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_KEY, 1); in getDefaultConf() 87 conf.setBoolean(DFSConfigKeys.DFS_CLIENT_READ_SHORTCIRCUIT_KEY, true); in getDefaultConf() 88 conf.set(DFSConfigKeys.DFS_DOMAIN_SOCKET_PATH_KEY, in getDefaultConf() 104 conf.setLong(DFSConfigKeys.DFS_DATANODE_CACHE_REVOCATION_TIMEOUT_MS, in testPinning() 107 conf.setLong(DFSConfigKeys.DFS_DATANODE_CACHE_REVOCATION_POLLING_MS, 2L); in testPinning() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/protocol/datatransfer/sasl/ |
H A D | SaslDataTransferTestCase.java | 21 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_BLOCK_ACCESS_TOKEN_ENABLE_KEY; 22 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATA_TRANSFER_PROTECTION_KEY; 23 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_HTTPS_ADDRESS_KEY; 24 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_KERBEROS_PRINCIPAL_KEY; 25 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_KEYTAB_FILE_KEY; 26 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_HTTP_POLICY_KEY; 27 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_HTTPS_ADDRESS_KEY; 28 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_KERBEROS_PRINCIPAL_KEY; 29 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_KEYTAB_FILE_KEY; 30 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_WEB_AUTHENTICATION_KERBEROS_PRINCIPAL_KEY;
|