Merge branch 'trunk' into HDFS-7240
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/7d70e57a Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/7d70e57a Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/7d70e57a Branch: refs/heads/HDFS-7240 Commit: 7d70e57a137622043033d37e16d478e9bc98d60d Parents: ef84ac4 0a85d07 Author: Anu Engineer <aengin...@apache.org> Authored: Thu Oct 13 15:15:30 2016 -0700 Committer: Anu Engineer <aengin...@apache.org> Committed: Thu Oct 13 15:15:30 2016 -0700 ---------------------------------------------------------------------- .gitignore | 2 + .../server/KerberosAuthenticationHandler.java | 7 +- .../util/RolloverSignerSecretProvider.java | 2 +- .../util/TestZKSignerSecretProvider.java | 221 +- .../dev-support/findbugsExcludeFile.xml | 5 + hadoop-common-project/hadoop-common/pom.xml | 1 + .../org/apache/hadoop/conf/ConfServlet.java | 19 +- .../org/apache/hadoop/conf/Configuration.java | 307 ++- .../apache/hadoop/fs/CachingGetSpaceUsed.java | 3 +- .../apache/hadoop/fs/DFCachingGetSpaceUsed.java | 48 + .../src/main/java/org/apache/hadoop/fs/DU.java | 8 +- .../apache/hadoop/fs/FileEncryptionInfo.java | 21 + .../java/org/apache/hadoop/fs/FileSystem.java | 10 +- .../java/org/apache/hadoop/fs/TrashPolicy.java | 36 +- .../apache/hadoop/fs/TrashPolicyDefault.java | 15 + .../apache/hadoop/fs/permission/AclEntry.java | 24 +- .../hadoop/fs/permission/AclEntryScope.java | 2 +- .../hadoop/fs/permission/AclEntryType.java | 23 +- .../apache/hadoop/fs/permission/AclStatus.java | 2 +- .../org/apache/hadoop/fs/shell/AclCommands.java | 6 +- .../apache/hadoop/io/compress/SnappyCodec.java | 30 +- .../org/apache/hadoop/ipc/ExternalCall.java | 88 + .../main/java/org/apache/hadoop/ipc/Server.java | 63 +- .../apache/hadoop/ipc/WritableRpcEngine.java | 5 +- .../java/org/apache/hadoop/log/LogLevel.java | 9 +- .../org/apache/hadoop/net/NetworkTopology.java | 2 +- .../org/apache/hadoop/security/Credentials.java | 8 +- .../hadoop/security/KerberosAuthException.java | 118 + .../hadoop/security/UGIExceptionMessages.java | 46 + .../hadoop/security/UserGroupInformation.java | 203 +- .../org/apache/hadoop/security/token/Token.java | 60 +- .../src/main/resources/core-default.xml | 6 +- .../src/site/markdown/CommandsManual.md | 4 +- .../src/site/markdown/FileSystemShell.md | 3 +- .../src/site/markdown/filesystem/filesystem.md | 77 +- .../org/apache/hadoop/conf/TestConfServlet.java | 122 +- .../apache/hadoop/conf/TestConfiguration.java | 164 +- .../apache/hadoop/fs/FileContextURIBase.java | 4 +- .../hadoop/fs/TestDFCachingGetSpaceUsed.java | 75 + .../hadoop/fs/TestFileSystemInitialization.java | 12 +- .../java/org/apache/hadoop/fs/TestTrash.java | 4 + .../AbstractContractRootDirectoryTest.java | 34 +- .../hadoop/fs/contract/ContractTestUtils.java | 39 + .../hadoop/ha/TestZKFailoverController.java | 34 +- .../java/org/apache/hadoop/ipc/TestRPC.java | 87 + .../security/TestUserGroupInformation.java | 33 +- .../hadoop/crypto/key/kms/server/KMS.java | 665 +++-- .../java/org/apache/hadoop/hdfs/DFSClient.java | 4 +- .../hadoop/hdfs/DistributedFileSystem.java | 30 + .../apache/hadoop/hdfs/client/HdfsAdmin.java | 21 +- .../hdfs/shortcircuit/ShortCircuitCache.java | 88 +- .../hdfs/web/resources/AclPermissionParam.java | 23 +- hadoop-hdfs-project/hadoop-hdfs-httpfs/pom.xml | 1 - .../hadoop/fs/http/server/FSOperations.java | 9 +- .../service/hadoop/FileSystemAccessService.java | 6 +- .../src/main/native/libhdfs/include/hdfs/hdfs.h | 1 + .../src/contrib/bkjournal/README.txt | 66 - .../dev-support/findbugsExcludeFile.xml | 5 - .../hadoop-hdfs/src/contrib/bkjournal/pom.xml | 175 -- .../bkjournal/BookKeeperEditLogInputStream.java | 264 -- .../BookKeeperEditLogOutputStream.java | 188 -- .../bkjournal/BookKeeperJournalManager.java | 893 ------- .../contrib/bkjournal/CurrentInprogress.java | 160 -- .../bkjournal/EditLogLedgerMetadata.java | 217 -- .../hadoop/contrib/bkjournal/MaxTxId.java | 103 - .../bkjournal/src/main/proto/bkjournal.proto | 49 - .../hadoop/contrib/bkjournal/BKJMUtil.java | 184 -- .../bkjournal/TestBookKeeperAsHASharedDir.java | 414 --- .../bkjournal/TestBookKeeperConfiguration.java | 174 -- .../bkjournal/TestBookKeeperEditLogStreams.java | 92 - .../bkjournal/TestBookKeeperHACheckpoints.java | 109 - .../bkjournal/TestBookKeeperJournalManager.java | 984 ------- .../TestBookKeeperSpeculativeRead.java | 167 -- .../bkjournal/TestBootstrapStandbyWithBKJM.java | 170 -- .../bkjournal/TestCurrentInprogress.java | 160 -- .../hdfs/server/namenode/FSEditLogTestUtil.java | 40 - .../src/test/resources/log4j.properties | 55 - .../org/apache/hadoop/hdfs/DFSConfigKeys.java | 6 + .../java/org/apache/hadoop/hdfs/HAUtil.java | 5 +- .../server/blockmanagement/BlockManager.java | 37 +- .../BlockPlacementPolicyDefault.java | 5 +- .../blockmanagement/DecommissionManager.java | 29 +- .../hdfs/server/common/HdfsServerConstants.java | 2 +- .../hadoop/hdfs/server/common/Storage.java | 22 + .../server/datanode/BlockPoolSliceStorage.java | 20 +- .../hdfs/server/datanode/BlockScanner.java | 8 +- .../hadoop/hdfs/server/datanode/DataNode.java | 34 +- .../hdfs/server/datanode/DataStorage.java | 34 +- .../hdfs/server/datanode/DirectoryScanner.java | 320 +-- .../hdfs/server/datanode/DiskBalancer.java | 25 +- .../hdfs/server/datanode/LocalReplica.java | 2 +- .../hdfs/server/datanode/ReplicaInfo.java | 2 +- .../hdfs/server/datanode/StorageLocation.java | 32 +- .../hdfs/server/datanode/VolumeScanner.java | 27 +- .../erasurecode/StripedBlockReader.java | 2 +- .../server/datanode/fsdataset/FsDatasetSpi.java | 5 +- .../server/datanode/fsdataset/FsVolumeSpi.java | 234 +- .../impl/FsDatasetAsyncDiskService.java | 40 +- .../datanode/fsdataset/impl/FsDatasetImpl.java | 136 +- .../datanode/fsdataset/impl/FsVolumeImpl.java | 233 +- .../fsdataset/impl/FsVolumeImplBuilder.java | 65 + .../datanode/fsdataset/impl/FsVolumeList.java | 44 +- .../impl/RamDiskAsyncLazyPersistService.java | 79 +- .../fsdataset/impl/VolumeFailureInfo.java | 13 +- .../hdfs/server/namenode/CacheManager.java | 12 +- .../ContentSummaryComputationContext.java | 94 +- .../namenode/EncryptionFaultInjector.java | 6 + .../server/namenode/EncryptionZoneManager.java | 25 +- .../hadoop/hdfs/server/namenode/FSDirAclOp.java | 4 +- .../hdfs/server/namenode/FSDirAttrOp.java | 110 +- .../hdfs/server/namenode/FSDirDeleteOp.java | 67 +- .../server/namenode/FSDirEncryptionZoneOp.java | 148 +- .../server/namenode/FSDirErasureCodingOp.java | 2 +- .../hdfs/server/namenode/FSDirMkdirOp.java | 2 +- .../hdfs/server/namenode/FSDirRenameOp.java | 16 +- .../hdfs/server/namenode/FSDirSnapshotOp.java | 22 +- .../server/namenode/FSDirStatAndListingOp.java | 281 +- .../hdfs/server/namenode/FSDirSymlinkOp.java | 2 +- .../hdfs/server/namenode/FSDirWriteFileOp.java | 163 +- .../hdfs/server/namenode/FSDirXAttrOp.java | 27 +- .../hdfs/server/namenode/FSDirectory.java | 33 +- .../hdfs/server/namenode/FSEditLogLoader.java | 94 +- .../hdfs/server/namenode/FSNamesystem.java | 290 +-- .../hdfs/server/namenode/FSNamesystemLock.java | 187 +- .../hadoop/hdfs/server/namenode/INode.java | 1 + .../server/namenode/INodeAttributeProvider.java | 10 +- .../hdfs/server/namenode/INodeDirectory.java | 11 +- .../hadoop/hdfs/server/namenode/INodeFile.java | 1 + .../hdfs/server/namenode/INodeReference.java | 2 + .../hdfs/server/namenode/INodeSymlink.java | 1 + .../hdfs/server/namenode/INodesInPath.java | 7 +- .../hadoop/hdfs/server/namenode/NameNode.java | 12 +- .../hdfs/server/namenode/NameNodeRpcServer.java | 6 +- .../hdfs/server/namenode/NamenodeFsck.java | 23 +- .../hdfs/server/namenode/XAttrStorage.java | 7 +- .../ha/RequestHedgingProxyProvider.java | 25 +- .../snapshot/DirectorySnapshottableFeature.java | 9 +- .../snapshot/DirectoryWithSnapshotFeature.java | 14 +- .../hdfs/server/namenode/snapshot/Snapshot.java | 1 + .../server/namenode/top/metrics/TopMetrics.java | 67 +- .../web/resources/NamenodeWebHdfsMethods.java | 150 +- .../apache/hadoop/hdfs/tools/CryptoAdmin.java | 51 +- .../org/apache/hadoop/hdfs/tools/DFSAdmin.java | 10 +- .../org/apache/hadoop/hdfs/web/JsonUtil.java | 2 +- .../src/main/resources/hdfs-default.xml | 21 +- .../src/site/markdown/ExtendedAttributes.md | 4 +- .../src/site/markdown/HDFSCommands.md | 2 +- .../src/site/markdown/HDFSErasureCoding.md | 26 +- .../markdown/HDFSHighAvailabilityWithNFS.md | 114 - .../src/site/markdown/TransparentEncryption.md | 16 + .../hadoop-hdfs/src/site/markdown/WebHDFS.md | 2 +- .../hadoop/fs/TestEnhancedByteBufferAccess.java | 17 +- .../hadoop/hdfs/TestBalancerBandwidth.java | 57 +- .../hadoop/hdfs/TestDFSClientRetries.java | 4 +- .../org/apache/hadoop/hdfs/TestDFSShell.java | 2066 +++++++-------- .../apache/hadoop/hdfs/TestEncryptionZones.java | 109 +- .../org/apache/hadoop/hdfs/TestFileAppend4.java | 3 +- .../apache/hadoop/hdfs/TestFileCorruption.java | 61 + .../hadoop/hdfs/TestLeaseRecoveryStriped.java | 1 + .../blockmanagement/TestBlockTokenWithDFS.java | 3 +- .../TestNameNodePrunesMissingStorages.java | 15 +- ...constructStripedBlocksWithRackAwareness.java | 158 +- .../server/datanode/SimulatedFSDataset.java | 46 +- .../hdfs/server/datanode/TestBlockScanner.java | 3 +- .../datanode/TestDataNodeHotSwapVolumes.java | 15 +- .../datanode/TestDataNodeVolumeFailure.java | 12 +- .../TestDataNodeVolumeFailureReporting.java | 10 + .../server/datanode/TestDirectoryScanner.java | 76 +- .../hdfs/server/datanode/TestDiskError.java | 2 +- .../extdataset/ExternalDatasetImpl.java | 10 +- .../datanode/extdataset/ExternalVolumeImpl.java | 44 +- .../fsdataset/impl/FsDatasetImplTestUtils.java | 9 +- .../fsdataset/impl/TestFsDatasetImpl.java | 69 +- .../fsdataset/impl/TestFsVolumeList.java | 83 +- .../server/diskbalancer/TestDiskBalancer.java | 44 +- .../TestDiskBalancerWithMockMover.java | 4 +- .../server/namenode/TestCacheDirectives.java | 10 + .../hdfs/server/namenode/TestFSDirectory.java | 48 + .../hdfs/server/namenode/TestFSNamesystem.java | 292 --- .../server/namenode/TestFSNamesystemLock.java | 317 +++ .../hadoop/hdfs/server/namenode/TestFsck.java | 2403 +++++++++--------- .../server/namenode/TestNamenodeRetryCache.java | 25 +- .../server/namenode/TestSnapshotPathINodes.java | 22 + .../ha/TestRequestHedgingProxyProvider.java | 18 +- .../server/namenode/metrics/TestTopMetrics.java | 63 + .../snapshot/TestRenameWithSnapshots.java | 199 ++ .../web/resources/TestWebHdfsDataLocality.java | 25 +- .../shortcircuit/TestShortCircuitCache.java | 9 +- .../apache/hadoop/hdfs/tools/TestDFSAdmin.java | 166 +- .../src/test/resources/testCryptoConf.xml | 90 + hadoop-hdfs-project/pom.xml | 1 - .../hadoop/mapreduce/v2/app/MRAppMaster.java | 90 +- .../hadoop/mapreduce/v2/app/TestRecovery.java | 66 + .../mapreduce/v2/app/webapp/TestAMWebApp.java | 8 +- .../apache/hadoop/mapreduce/MRJobConfig.java | 2 +- .../src/main/resources/mapred-default.xml | 10 +- .../apache/hadoop/mapred/JobClientUnitTest.java | 34 +- .../hadoop/examples/terasort/TeraGen.java | 3 + .../examples/terasort/TeraOutputFormat.java | 20 +- .../hadoop/examples/terasort/TeraSort.java | 3 + .../plugin/versioninfo/VersionInfoMojo.java | 2 +- hadoop-project-dist/pom.xml | 17 - hadoop-project/pom.xml | 30 +- .../dev-support/findbugs-exclude.xml | 18 + hadoop-tools/hadoop-aliyun/pom.xml | 154 ++ .../aliyun/oss/AliyunCredentialsProvider.java | 87 + .../fs/aliyun/oss/AliyunOSSFileSystem.java | 580 +++++ .../fs/aliyun/oss/AliyunOSSFileSystemStore.java | 516 ++++ .../fs/aliyun/oss/AliyunOSSInputStream.java | 260 ++ .../fs/aliyun/oss/AliyunOSSOutputStream.java | 111 + .../hadoop/fs/aliyun/oss/AliyunOSSUtils.java | 167 ++ .../apache/hadoop/fs/aliyun/oss/Constants.java | 113 + .../hadoop/fs/aliyun/oss/package-info.java | 22 + .../site/markdown/tools/hadoop-aliyun/index.md | 294 +++ .../fs/aliyun/oss/AliyunOSSTestUtils.java | 77 + .../fs/aliyun/oss/TestAliyunCredentials.java | 78 + .../oss/TestAliyunOSSFileSystemContract.java | 239 ++ .../oss/TestAliyunOSSFileSystemStore.java | 125 + .../fs/aliyun/oss/TestAliyunOSSInputStream.java | 145 ++ .../aliyun/oss/TestAliyunOSSOutputStream.java | 91 + .../aliyun/oss/contract/AliyunOSSContract.java | 49 + .../contract/TestAliyunOSSContractCreate.java | 35 + .../contract/TestAliyunOSSContractDelete.java | 34 + .../contract/TestAliyunOSSContractDistCp.java | 44 + .../TestAliyunOSSContractGetFileStatus.java | 35 + .../contract/TestAliyunOSSContractMkdir.java | 34 + .../oss/contract/TestAliyunOSSContractOpen.java | 34 + .../contract/TestAliyunOSSContractRename.java | 35 + .../contract/TestAliyunOSSContractRootDir.java | 69 + .../oss/contract/TestAliyunOSSContractSeek.java | 34 + .../src/test/resources/contract/aliyun-oss.xml | 115 + .../src/test/resources/core-site.xml | 46 + .../src/test/resources/log4j.properties | 23 + hadoop-tools/hadoop-aws/pom.xml | 12 + .../org/apache/hadoop/fs/s3a/S3AFileSystem.java | 104 +- .../java/org/apache/hadoop/fs/s3a/S3AUtils.java | 17 + .../src/site/markdown/tools/hadoop-aws/index.md | 42 +- .../hadoop/fs/s3a/ITestS3AFailureHandling.java | 55 - .../hadoop/fs/s3a/ITestS3AMiscOperations.java | 63 + .../fs/s3a/TestS3AExceptionTranslation.java | 127 + hadoop-tools/hadoop-azure-datalake/pom.xml | 4 + ...ClientCredentialBasedAccesTokenProvider.java | 5 +- hadoop-tools/hadoop-azure/pom.xml | 6 +- .../hadoop/fs/azure/NativeAzureFileSystem.java | 16 +- .../apache/hadoop/tools/DistCpConstants.java | 12 +- .../hadoop/tools/mapred/CopyCommitter.java | 5 +- .../hadoop/tools/TestDistCpWithRawXAttrs.java | 45 +- .../hadoop/tools/util/DistCpTestUtils.java | 32 +- hadoop-tools/hadoop-kafka/pom.xml | 2 +- hadoop-tools/hadoop-openstack/pom.xml | 18 +- .../swift/auth/ApiKeyAuthenticationRequest.java | 2 +- .../fs/swift/auth/entities/AccessToken.java | 2 +- .../hadoop/fs/swift/auth/entities/Catalog.java | 2 +- .../hadoop/fs/swift/auth/entities/Endpoint.java | 2 +- .../hadoop/fs/swift/auth/entities/Tenant.java | 2 +- .../hadoop/fs/swift/auth/entities/User.java | 2 +- .../snative/SwiftNativeFileSystemStore.java | 3 +- .../apache/hadoop/fs/swift/util/JSONUtil.java | 24 +- hadoop-tools/hadoop-rumen/pom.xml | 9 + .../apache/hadoop/tools/rumen/Anonymizer.java | 23 +- .../hadoop/tools/rumen/HadoopLogsAnalyzer.java | 3 +- .../tools/rumen/JsonObjectMapperParser.java | 17 +- .../tools/rumen/JsonObjectMapperWriter.java | 21 +- .../apache/hadoop/tools/rumen/LoggedJob.java | 2 +- .../hadoop/tools/rumen/LoggedLocation.java | 2 +- .../tools/rumen/LoggedNetworkTopology.java | 2 +- .../rumen/LoggedSingleRelativeRanking.java | 4 +- .../apache/hadoop/tools/rumen/LoggedTask.java | 2 +- .../hadoop/tools/rumen/LoggedTaskAttempt.java | 2 +- .../hadoop/tools/rumen/datatypes/NodeName.java | 2 +- .../rumen/serializers/BlockingSerializer.java | 10 +- .../DefaultAnonymizingRumenSerializer.java | 8 +- .../serializers/DefaultRumenSerializer.java | 9 +- .../serializers/ObjectStringSerializer.java | 10 +- .../apache/hadoop/tools/rumen/state/State.java | 2 +- .../tools/rumen/state/StateDeserializer.java | 14 +- .../hadoop/tools/rumen/state/StatePool.java | 36 +- .../hadoop/tools/rumen/TestHistograms.java | 13 +- hadoop-tools/hadoop-sls/pom.xml | 4 + .../hadoop/yarn/sls/RumenToSLSConverter.java | 8 +- .../org/apache/hadoop/yarn/sls/SLSRunner.java | 7 +- .../apache/hadoop/yarn/sls/utils/SLSUtils.java | 10 +- hadoop-tools/hadoop-tools-dist/pom.xml | 6 + hadoop-tools/pom.xml | 1 + .../yarn/api/records/ReservationDefinition.java | 44 +- .../org/apache/hadoop/yarn/api/records/URL.java | 58 +- .../hadoop/yarn/conf/YarnConfiguration.java | 20 +- .../ReplaceLabelsOnNodeRequest.java | 8 + ..._server_resourcemanager_service_protos.proto | 2 +- .../src/main/proto/yarn_protos.proto | 1 + .../apache/hadoop/yarn/api/records/TestURL.java | 99 + .../yarn/client/api/impl/AMRMClientImpl.java | 10 +- .../impl/ContainerManagementProtocolProxy.java | 7 +- .../hadoop/yarn/client/cli/RMAdminCLI.java | 39 +- .../TestOpportunisticContainerAllocation.java | 398 +++ .../hadoop/yarn/client/cli/TestRMAdminCLI.java | 3 +- .../impl/pb/ReservationDefinitionPBImpl.java | 31 + .../pb/ReplaceLabelsOnNodeRequestPBImpl.java | 14 +- .../yarn/util/ProcfsBasedProcessTree.java | 26 +- .../hadoop/yarn/webapp/YarnWebParams.java | 1 + .../src/main/resources/yarn-default.xml | 4 +- .../hadoop/yarn/api/BasePBImplRecordsTest.java | 264 ++ .../hadoop/yarn/api/TestPBImplRecords.java | 259 +- .../yarn/util/TestProcfsBasedProcessTree.java | 46 +- ...pplicationHistoryManagerOnTimelineStore.java | 14 +- ...pplicationHistoryManagerOnTimelineStore.java | 14 +- .../OpportunisticContainerAllocator.java | 22 +- .../OpportunisticContainerContext.java | 49 +- .../yarn/server/nodemanager/NodeManager.java | 3 +- .../amrmproxy/DefaultRequestInterceptor.java | 4 +- .../scheduler/DistributedScheduler.java | 59 +- .../impl/container-executor.c | 46 +- .../impl/container-executor.h | 10 +- .../main/native/container-executor/impl/main.c | 264 +- .../server/resourcemanager/AdminService.java | 46 + .../resourcemanager/EmbeddedElectorService.java | 59 +- ...pportunisticContainerAllocatorAMService.java | 215 +- .../server/resourcemanager/RMAppManager.java | 2 +- .../server/resourcemanager/RMServerUtils.java | 5 +- .../server/resourcemanager/ResourceManager.java | 12 +- .../server/resourcemanager/rmapp/RMAppImpl.java | 2 +- .../scheduler/AbstractYarnScheduler.java | 416 +-- .../scheduler/SchedulerApplicationAttempt.java | 66 +- .../scheduler/capacity/CapacityScheduler.java | 1729 +++++++------ .../scheduler/capacity/LeafQueue.java | 16 + .../scheduler/common/fica/FiCaSchedulerApp.java | 4 + .../distributed/NodeQueueLoadMonitor.java | 45 +- .../scheduler/fair/FSLeafQueue.java | 2 +- .../scheduler/fair/FSParentQueue.java | 6 +- .../scheduler/fair/FairScheduler.java | 1047 ++++---- .../resourcemanager/webapp/ErrorBlock.java | 39 + .../server/resourcemanager/webapp/RMWebApp.java | 1 + .../webapp/RedirectionErrorPage.java | 47 + .../resourcemanager/webapp/RmController.java | 4 + .../webapp/dao/ReservationDefinitionInfo.java | 11 + ...pportunisticContainerAllocatorAMService.java | 10 +- .../resourcemanager/TestRMAdminService.java | 103 +- .../resourcemanager/TestRMEmbeddedElector.java | 191 ++ .../reservation/ReservationSystemTestUtil.java | 10 +- .../security/TestDelegationTokenRenewer.java | 24 +- .../webapp/TestRedirectionErrorPage.java | 68 + .../yarn/server/webproxy/ProxyUriUtils.java | 53 +- .../server/webproxy/WebAppProxyServlet.java | 274 +- .../server/webproxy/amfilter/AmIpFilter.java | 64 +- .../server/webproxy/TestWebAppProxyServlet.java | 24 +- .../server/webproxy/amfilter/TestAmFilter.java | 29 +- .../src/site/markdown/ResourceManagerRest.md | 3 + pom.xml | 1 - 348 files changed, 16384 insertions(+), 12702 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/7d70e57a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/HdfsServerConstants.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/7d70e57a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java ---------------------------------------------------------------------- --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org