Home
last modified time | relevance | path

Searched refs:DFSConfigKeys (Results 1 – 25 of 565) sorted by relevance

12345678910>>...23

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/
H A DHdfsConfiguration.java74 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 DDFSClient.java447 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 DDFSUtil.java21 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 DDNConf.java57 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 DTestNameEditsConfigs.java38 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 DTestStartup.java47 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 DTestValidateConfigurationSettings.java23 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 DTestFsLimits.java35 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 DTestNameNodeResourceChecker.java32 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 DTestHDFSServerPorts.java100 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 DTestParallelShortCircuitReadUnCached.java41 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 DTestDatanodeConfig.java54 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 DTestParallelShortCircuitLegacyRead.java30 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 DNameNodeHttpServer.java30 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 DReplaceDatanodeOnFailure.java24 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 DTestFiHFlush.java86 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 DTestHAConfiguration.java20 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 DDatanodeManager.java31 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 DTestSecureNNWithQJM.java23 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 DTestNNWithQJM.java30 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 DTestDFSHAAdmin.java41 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 DJournalNodeHttpServer.java28 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 DTestStartSecureDataNode.java33 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 DTestFsDatasetCacheRevocation.java33 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 DSaslDataTransferTestCase.java21 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;

12345678910>>...23