hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ste...@apache.org
Subject [50/50] hadoop git commit: Merge branch 'trunk' into HADOOP-13345
Date Mon, 26 Jun 2017 12:50:24 GMT
Merge branch 'trunk' into HADOOP-13345


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/2b3c4b84
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/2b3c4b84
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/2b3c4b84

Branch: refs/heads/HADOOP-13345
Commit: 2b3c4b840cf52e15d05b23bf41c9064fc3337995
Parents: be922ba 48f4a22
Author: Steve Loughran <stevel@apache.org>
Authored: Mon Jun 26 13:48:28 2017 +0100
Committer: Steve Loughran <stevel@apache.org>
Committed: Mon Jun 26 13:48:28 2017 +0100

----------------------------------------------------------------------
 .../apache/hadoop/example/ITUseMiniCluster.java |   8 +-
 hadoop-common-project/hadoop-auth/pom.xml       |   5 +
 .../authentication/client/AuthenticatedURL.java |   8 +
 .../client/KerberosAuthenticator.java           |   4 +-
 .../server/AuthenticationFilter.java            |  12 +-
 .../server/KerberosAuthenticationHandler.java   | 204 +---
 .../MultiSchemeAuthenticationHandler.java       |  11 +-
 .../authentication/util/KerberosUtil.java       | 198 +++-
 .../util/RolloverSignerSecretProvider.java      |   2 +
 .../server/TestAuthenticationFilter.java        |   1 +
 .../TestMultiSchemeAuthenticationHandler.java   |   2 +-
 .../authentication/util/TestKerberosUtil.java   |  73 ++
 .../dev-support/findbugsExcludeFile.xml         |  26 +
 hadoop-common-project/hadoop-common/pom.xml     |   4 +-
 .../org/apache/hadoop/conf/Configuration.java   |   6 +-
 .../apache/hadoop/crypto/AesCtrCryptoCodec.java |   6 +
 .../org/apache/hadoop/crypto/CryptoCodec.java   |   3 +-
 .../apache/hadoop/crypto/CryptoInputStream.java |   1 +
 .../hadoop/crypto/CryptoOutputStream.java       |   1 +
 .../hadoop/crypto/OpensslAesCtrCryptoCodec.java |  22 +-
 .../crypto/key/KeyProviderCryptoExtension.java  |  27 +-
 .../crypto/key/kms/KMSClientProvider.java       |  10 +
 .../hadoop/crypto/random/OsSecureRandom.java    |   5 +
 .../org/apache/hadoop/fs/ContentSummary.java    |  16 +-
 .../hadoop/fs/FSDataOutputStreamBuilder.java    | 171 +++-
 .../java/org/apache/hadoop/fs/FileSystem.java   |  41 +-
 .../java/org/apache/hadoop/fs/FileUtil.java     |   6 +-
 .../org/apache/hadoop/fs/FilterFileSystem.java  |   9 +-
 .../org/apache/hadoop/fs/HarFileSystem.java     |   9 +-
 .../apache/hadoop/fs/RawLocalFileSystem.java    |  17 +-
 .../org/apache/hadoop/fs/ftp/FTPFileSystem.java |   9 +-
 .../apache/hadoop/fs/sftp/SFTPFileSystem.java   |   2 +-
 .../hadoop/fs/shell/CommandWithDestination.java |   2 +-
 .../java/org/apache/hadoop/fs/shell/Count.java  |  41 +-
 .../apache/hadoop/ha/ActiveStandbyElector.java  |   2 +-
 .../org/apache/hadoop/http/HttpRequestLog.java  |  23 +-
 .../org/apache/hadoop/io/DoubleWritable.java    |   4 +-
 .../org/apache/hadoop/io/FloatWritable.java     |   6 +-
 .../main/java/org/apache/hadoop/io/IOUtils.java |  32 +-
 .../apache/hadoop/io/erasurecode/ECSchema.java  |   4 +-
 .../rawcoder/AbstractNativeRawDecoder.java      |   8 +-
 .../rawcoder/AbstractNativeRawEncoder.java      |   8 +-
 .../org/apache/hadoop/io/file/tfile/Utils.java  |   2 +-
 .../org/apache/hadoop/ipc/CallQueueManager.java | 127 ++-
 .../main/java/org/apache/hadoop/ipc/Client.java |   3 +-
 .../org/apache/hadoop/ipc/FairCallQueue.java    |  90 +-
 .../main/java/org/apache/hadoop/ipc/Server.java |  22 +-
 .../hadoop/metrics2/lib/MetricsRegistry.java    |   9 +
 .../metrics2/lib/MutableMetricsFactory.java     |   4 +
 .../metrics2/lib/MutableRollingAverages.java    | 280 ++++++
 .../hadoop/metrics2/lib/RollingAverages.java    | 286 ------
 .../hadoop/metrics2/source/JvmMetrics.java      |  10 +
 .../hadoop/security/LdapGroupsMapping.java      |  41 +-
 .../AbstractDelegationTokenSecretManager.java   |   1 +
 .../ZKDelegationTokenSecretManager.java         |   8 +-
 .../web/DelegationTokenAuthenticatedURL.java    |  11 +
 .../DelegationTokenAuthenticationHandler.java   |   8 +
 .../web/DelegationTokenAuthenticator.java       |  11 +
 .../org/apache/hadoop/tracing/TraceAdmin.java   |   2 +-
 .../org/apache/hadoop/util/HostsFileReader.java |   4 +-
 .../apache/hadoop/util/InstrumentedLock.java    |  12 +-
 .../hadoop/util/InstrumentedReadLock.java       |   6 +-
 .../hadoop/util/InstrumentedReadWriteLock.java  |   4 +-
 .../hadoop/util/InstrumentedWriteLock.java      |   6 +-
 .../org/apache/hadoop/util/SysInfoWindows.java  |   6 +-
 .../src/main/resources/core-default.xml         |  20 +
 .../src/site/markdown/FileSystemShell.md        |   9 +-
 .../src/site/markdown/GroupsMapping.md          |   1 +
 .../src/site/markdown/filesystem/filesystem.md  |   4 +
 .../java/org/apache/hadoop/cli/TestCLI.java     |   2 +-
 .../apache/hadoop/conf/TestConfiguration.java   |  82 ++
 ...yptoStreamsWithOpensslAesCtrCryptoCodec.java |  32 +-
 .../apache/hadoop/fs/TestLocalFileSystem.java   |  10 +-
 .../fs/contract/AbstractContractCreateTest.java |  18 +
 .../apache/hadoop/fs/ftp/TestFTPFileSystem.java |  55 ++
 .../hadoop/fs/sftp/TestSFTPFileSystem.java      |  10 +
 .../hadoop/fs/shell/TestCopyPreserveFlag.java   |   4 +-
 .../org/apache/hadoop/fs/shell/TestCount.java   |   5 +-
 .../ha/TestActiveStandbyElectorRealZK.java      |  28 +
 .../apache/hadoop/ipc/TestCallQueueManager.java |  78 +-
 .../apache/hadoop/ipc/TestFairCallQueue.java    | 156 +++
 .../java/org/apache/hadoop/ipc/TestIPC.java     |   2 +-
 .../java/org/apache/hadoop/ipc/TestRPC.java     |   4 +-
 .../hadoop/metrics2/lib/MetricsTestHelper.java  |  49 +
 .../lib/TestMutableRollingAverages.java         | 192 ++++
 .../metrics2/lib/TestRollingAverages.java       | 124 ---
 .../hadoop/security/TestLdapGroupsMapping.java  |  64 +-
 .../apache/hadoop/test/GenericTestUtils.java    |  24 +-
 .../hadoop/test/TestGenericTestUtils.java       |  32 +
 .../hadoop/util/Crc32PerformanceTest.java       | 253 +++--
 .../hadoop/util/TestInstrumentedLock.java       |   6 +-
 .../util/TestInstrumentedReadWriteLock.java     |   7 +-
 .../src/test/resources/testConf.xml             |   2 +-
 .../hadoop/crypto/key/kms/server/KMS.java       |   2 +-
 .../key/kms/server/KMSExceptionsProvider.java   |   4 +
 .../src/test/resources/log4j.properties         |   5 +-
 .../java/org/apache/hadoop/minikdc/MiniKdc.java |   7 +-
 .../main/java/org/apache/hadoop/fs/Hdfs.java    |   2 +-
 .../java/org/apache/hadoop/hdfs/DFSClient.java  |  25 +-
 .../org/apache/hadoop/hdfs/DFSInputStream.java  |  38 +-
 .../hadoop/hdfs/DFSStripedInputStream.java      |   2 +-
 .../hadoop/hdfs/DistributedFileSystem.java      | 228 ++++-
 .../apache/hadoop/hdfs/client/HdfsAdmin.java    |  44 +-
 .../hdfs/client/HdfsClientConfigKeys.java       |   4 +
 .../hdfs/client/impl/BlockReaderLocal.java      |  52 +-
 .../hadoop/hdfs/client/impl/DfsClientConf.java  |  26 +
 .../impl/metrics/BlockReaderIoProvider.java     |  89 ++
 .../impl/metrics/BlockReaderLocalMetrics.java   |  78 ++
 .../hdfs/client/impl/metrics/package-info.java  |  27 +
 .../hadoop/hdfs/protocol/BlocksStats.java       |  90 ++
 .../hadoop/hdfs/protocol/ClientProtocol.java    |  57 +-
 .../hdfs/protocol/ECBlockGroupsStats.java       |  83 ++
 .../hdfs/protocol/ErasureCodingPolicy.java      |   2 +
 .../hadoop/hdfs/protocol/OpenFileEntry.java     |  58 ++
 .../hadoop/hdfs/protocol/OpenFilesIterator.java |  59 ++
 .../datatransfer/sasl/DataTransferSaslUtil.java |   1 +
 .../ClientNamenodeProtocolTranslatorPB.java     |  70 ++
 .../hadoop/hdfs/protocolPB/PBHelperClient.java  |  78 +-
 .../src/main/proto/ClientNamenodeProtocol.proto |  47 +
 .../src/main/proto/erasurecoding.proto          |   7 +
 .../src/main/proto/hdfs.proto                   |   1 +
 .../hdfs/protocol/TestErasureCodingPolicy.java  |  22 +
 .../libhdfs-tests/test_libhdfs_threaded.c       |  26 +
 .../src/main/native/libhdfs/os/posix/mutexes.c  |   9 +-
 .../org/apache/hadoop/hdfs/DFSConfigKeys.java   |  22 +-
 ...tNamenodeProtocolServerSideTranslatorPB.java |  60 ++
 .../hdfs/server/balancer/NameNodeConnector.java |   8 +-
 .../AvailableSpaceBlockPlacementPolicy.java     |  21 +
 .../server/blockmanagement/BlockManager.java    |  62 +-
 .../blockmanagement/BlockManagerSafeMode.java   |  29 +-
 .../blockmanagement/CorruptReplicasMap.java     | 103 +-
 .../blockmanagement/InvalidateBlocks.java       | 198 +++-
 .../blockmanagement/LowRedundancyBlocks.java    | 125 ++-
 .../apache/hadoop/hdfs/server/common/Util.java  |   6 +-
 .../hdfs/server/datanode/BPOfferService.java    |  12 +-
 .../hdfs/server/datanode/BPServiceActor.java    |   6 +-
 .../server/datanode/BlockRecoveryWorker.java    |  14 +-
 .../hdfs/server/datanode/BlockSender.java       |  13 +-
 .../hadoop/hdfs/server/datanode/DataNode.java   |   2 +-
 .../server/datanode/DataNodeFaultInjector.java  |   4 +
 .../datanode/fsdataset/impl/BlockPoolSlice.java |   3 +-
 .../datanode/fsdataset/impl/FsDatasetImpl.java  |  10 +-
 .../datanode/metrics/DataNodePeerMetrics.java   |  42 +-
 .../apache/hadoop/hdfs/server/mover/Mover.java  |   1 +
 .../ContentSummaryComputationContext.java       |  48 +
 .../namenode/ErasureCodingPolicyManager.java    |  25 +
 .../server/namenode/FSDirErasureCodingOp.java   |  13 +
 .../hdfs/server/namenode/FSNamesystem.java      | 270 +++++-
 .../hdfs/server/namenode/FSNamesystemLock.java  |   5 +-
 .../hadoop/hdfs/server/namenode/INode.java      |   1 +
 .../hdfs/server/namenode/LeaseManager.java      |  78 +-
 .../hadoop/hdfs/server/namenode/NameNode.java   |  11 +-
 .../hdfs/server/namenode/NameNodeRpcServer.java |  32 +-
 .../hdfs/server/namenode/TransferFsImage.java   |  23 +-
 .../metrics/ECBlockGroupsStatsMBean.java        |  59 ++
 .../namenode/metrics/FSNamesystemMBean.java     |  26 +-
 .../namenode/metrics/NameNodeMetrics.java       |  38 +-
 .../metrics/ReplicatedBlocksStatsMBean.java     |  63 ++
 .../org/apache/hadoop/hdfs/tools/DFSAdmin.java  |  67 +-
 .../org/apache/hadoop/hdfs/tools/ECAdmin.java   |  54 +-
 .../FileDistributionCalculator.java             |   4 +-
 .../offlineImageViewer/OfflineImageViewer.java  |   2 +-
 .../src/main/resources/hdfs-default.xml         |  22 +-
 .../src/site/markdown/HDFSCommands.md           |   9 +-
 .../src/site/markdown/HDFSErasureCoding.md      |   7 +-
 .../hadoop-hdfs/src/site/markdown/HdfsDesign.md |  33 +-
 .../src/site/markdown/HdfsImageViewer.md        |   2 +-
 .../org/apache/hadoop/hdfs/DFSTestUtil.java     | 133 ++-
 .../hadoop/hdfs/TestDistributedFileSystem.java  | 150 ++-
 .../hadoop/hdfs/TestErasureCodingPolicies.java  |  85 +-
 ...ErasureCodingPoliciesWithRandomECPolicy.java |  48 +
 .../TestErasureCodingPolicyWithSnapshot.java    |  50 +-
 ...ingPolicyWithSnapshotWithRandomECPolicy.java |  49 +
 .../apache/hadoop/hdfs/TestFileCorruption.java  |   2 +-
 .../org/apache/hadoop/hdfs/TestFileStatus.java  |  27 +-
 .../org/apache/hadoop/hdfs/TestHdfsAdmin.java   |  59 ++
 .../apache/hadoop/hdfs/TestLeaseRecovery2.java  |  12 +-
 .../hadoop/hdfs/TestMaintenanceState.java       |   2 +-
 .../apache/hadoop/hdfs/TestMiniDFSCluster.java  |   2 +-
 .../hadoop/hdfs/TestMissingBlocksAlert.java     |   4 +-
 .../java/org/apache/hadoop/hdfs/TestPread.java  | 146 +++
 .../java/org/apache/hadoop/hdfs/TestQuota.java  |  13 +-
 .../org/apache/hadoop/hdfs/TestSafeMode.java    |   4 +-
 .../client/impl/TestBlockReaderIoProvider.java  |  75 ++
 .../impl/TestBlockReaderLocalMetrics.java       | 227 +++++
 .../hdfs/server/balancer/TestBalancer.java      |  46 +-
 .../TestComputeInvalidateWork.java              | 151 ++-
 .../blockmanagement/TestCorruptReplicaInfo.java | 199 ++--
 .../TestLowRedundancyBlockQueues.java           |  73 +-
 .../TestPendingReconstruction.java              |  44 +
 .../TestReplicationPolicyWithNodeGroup.java     |   4 +
 .../TestUnderReplicatedBlocks.java              |  42 +-
 .../server/datanode/TestBlockReplacement.java   |  40 +-
 .../datanode/TestDataNodeFaultInjector.java     |   2 +-
 .../server/datanode/TestDataNodeMetrics.java    |  62 ++
 .../datanode/TestDataNodePeerMetrics.java       |  10 +-
 .../datanode/TestReadOnlySharedStorage.java     |   4 +-
 .../fsdataset/impl/TestLazyPersistFiles.java    |   2 +-
 .../TestDataNodeOutlierDetectionViaMetrics.java |  18 +-
 .../server/namenode/TestAddStripedBlocks.java   |   2 +
 .../hdfs/server/namenode/TestCheckpoint.java    |   4 +-
 .../namenode/TestDecommissioningStatus.java     |   8 +-
 .../server/namenode/TestFSNamesystemLock.java   |   7 +-
 .../namenode/TestFavoredNodesEndToEnd.java      |   2 +-
 .../hdfs/server/namenode/TestFileTruncate.java  |   2 +-
 .../hdfs/server/namenode/TestLeaseManager.java  |  26 +-
 .../hdfs/server/namenode/TestListOpenFiles.java | 234 +++++
 .../server/namenode/TestNameNodeMXBean.java     |  52 +-
 .../namenode/TestReconstructStripedBlocks.java  |  83 ++
 .../namenode/ha/TestStandbyCheckpoints.java     |   8 +-
 .../namenode/metrics/TestNameNodeMetrics.java   | 366 +++++++-
 .../apache/hadoop/hdfs/tools/TestDFSAdmin.java  | 108 +++
 .../TestOfflineImageViewer.java                 |   7 +-
 .../hadoop/tools/TestHdfsConfigFields.java      |   4 -
 .../org/apache/hadoop/tools/TestJMXGet.java     |   2 +-
 .../apache/hadoop/tracing/TestTraceAdmin.java   |   8 +
 .../test/resources/testErasureCodingConf.xml    |  41 +
 .../hadoop/mapreduce/v2/app/JobEndNotifier.java |   5 -
 .../hadoop/mapreduce/v2/app/MRAppMaster.java    |  51 +-
 .../mapreduce/v2/app/TestJobEndNotifier.java    |  25 +-
 .../apache/hadoop/mapreduce/CryptoUtils.java    |  14 +-
 .../java/org/apache/hadoop/hdfs/NNBench.java    |  10 +-
 .../apache/hadoop/test/MapredTestDriver.java    |   2 +-
 hadoop-project/pom.xml                          |  10 +-
 .../apache/hadoop/tools/TestHadoopArchives.java |  12 +-
 .../NativeS3FileSystemContractBaseTest.java     |   8 +-
 .../fs/azure/AzureNativeFileSystemStore.java    |  58 +-
 .../hadoop/fs/azure/NativeAzureFileSystem.java  |  41 +-
 .../fs/azure/SecureStorageInterfaceImpl.java    |  30 +-
 .../hadoop/fs/azure/StorageInterfaceImpl.java   |  28 +-
 .../hadoop-azure/src/site/markdown/index.md     | 233 ++---
 .../fs/azure/AzureBlobStorageTestAccount.java   |  37 +-
 .../TestAzureFileSystemErrorConditions.java     |  13 +-
 ...estFileSystemOperationExceptionHandling.java |   1 +
 ...TestFileSystemOperationExceptionMessage.java |  13 +-
 ...perationsExceptionHandlingMultiThreaded.java |   1 +
 .../TestFileSystemOperationsWithThreads.java    |   8 +-
 .../TestNativeAzureFileSystemClientLogging.java |  12 +-
 .../TestReadAndSeekPageBlobAfterWrite.java      |  10 -
 .../org/apache/hadoop/tools/OptionsParser.java  |   3 +
 .../apache/hadoop/tools/TestOptionsParser.java  |   2 +-
 .../org/apache/hadoop/tools/TestDistCh.java     |  12 +-
 .../mapred/gridmix/TestGridmixSubmission.java   |  10 +-
 .../hadoop/mapred/gridmix/TestLoadJob.java      |  19 +-
 .../hadoop/mapred/gridmix/TestSleepJob.java     |  14 +-
 hadoop-tools/hadoop-sls/pom.xml                 |   2 +
 .../org/apache/hadoop/yarn/sls/SLSRunner.java   |  56 +-
 .../hadoop/yarn/sls/appmaster/AMSimulator.java  |  16 +-
 .../yarn/sls/appmaster/MRAMSimulator.java       |  68 +-
 .../yarn/sls/nodemanager/NMSimulator.java       |  30 +-
 .../yarn/sls/scheduler/SchedulerMetrics.java    |   8 +-
 .../hadoop/yarn/sls/BaseSLSRunnerTest.java      |  41 +-
 .../sls/TestReservationSystemInvariants.java    |   4 +
 .../apache/hadoop/yarn/sls/TestSLSRunner.java   |  17 +-
 .../src/test/resources/exit-invariants.txt      |   8 +
 .../src/test/resources/log4j.properties         |  19 +
 .../src/test/resources/ongoing-invariants.txt   |  54 ++
 .../hadoop/yarn/api/records/Resource.java       |  53 +-
 .../hadoop/yarn/conf/YarnConfiguration.java     |   5 +
 .../yarn/client/api/impl/YarnClientImpl.java    |   2 +-
 .../yarn/client/api/impl/TestYarnClient.java    |   2 +-
 .../impl/pb/AllocateResponsePBImpl.java         |   2 +-
 .../pb/GetNewApplicationResponsePBImpl.java     |   9 +-
 ...RegisterApplicationMasterResponsePBImpl.java |   2 +-
 .../ApplicationResourceUsageReportPBImpl.java   |  14 +-
 .../pb/ApplicationSubmissionContextPBImpl.java  |   6 +-
 .../api/records/impl/pb/ContainerPBImpl.java    |   6 +-
 .../records/impl/pb/ContainerReportPBImpl.java  |   6 +-
 .../records/impl/pb/ContainerStatusPBImpl.java  |   2 +-
 .../api/records/impl/pb/NodeReportPBImpl.java   |  10 +-
 .../yarn/api/records/impl/pb/ProtoUtils.java    |   2 +-
 .../impl/pb/ReservationRequestPBImpl.java       |   2 +-
 .../pb/ResourceAllocationRequestPBImpl.java     |   2 +-
 .../records/impl/pb/ResourceOptionPBImpl.java   |   2 +-
 .../api/records/impl/pb/ResourcePBImpl.java     |  26 +-
 .../records/impl/pb/ResourceRequestPBImpl.java  |   2 +-
 .../logaggregation/AggregatedLogFormat.java     |  11 +-
 .../nodelabels/CommonNodeLabelsManager.java     |   8 +-
 .../yarn/security/ContainerTokenIdentifier.java |   2 +-
 .../pb/AddToClusterNodeLabelsRequestPBImpl.java |   7 +
 .../resource/DefaultResourceCalculator.java     |   6 +
 .../resource/DominantResourceCalculator.java    |   8 +
 .../yarn/util/resource/ResourceCalculator.java  |  23 +
 .../hadoop/yarn/util/resource/Resources.java    |  16 +-
 .../src/main/resources/yarn-default.xml         |   8 +
 .../client/api/impl/TestTimelineClient.java     |   8 +-
 .../impl/pb/ContainerStartDataPBImpl.java       |   7 +-
 .../impl/pb/NMContainerStatusPBImpl.java        |   6 +-
 .../impl/pb/NodeHeartbeatResponsePBImpl.java    |   2 +-
 .../pb/RegisterNodeManagerRequestPBImpl.java    |   3 +-
 .../pb/RegisterNodeManagerResponsePBImpl.java   |   3 +-
 .../protocolrecords/TestProtocolRecords.java    |  20 +
 .../AMRMProxyApplicationContextImpl.java        |  17 +-
 .../nodemanager/amrmproxy/AMRMProxyService.java | 179 +++-
 .../amrmproxy/AMRMProxyTokenSecretManager.java  |  93 +-
 .../amrmproxy/AbstractRequestInterceptor.java   |  37 +-
 .../amrmproxy/RequestInterceptor.java           |  20 +-
 .../containermanager/ContainerManagerImpl.java  |   4 +
 .../recovery/NMLeveldbStateStoreService.java    | 185 +++-
 .../recovery/NMNullStateStoreService.java       |  29 +
 .../recovery/NMStateStoreService.java           |  86 ++
 .../amrmproxy/BaseAMRMProxyTest.java            |  78 +-
 .../amrmproxy/TestAMRMProxyService.java         | 119 ++-
 .../TestAMRMProxyTokenSecretManager.java        |  62 +-
 .../recovery/NMMemoryStateStoreService.java     |  65 +-
 .../TestNMLeveldbStateStoreService.java         | 105 ++-
 .../resourcemanager/ResourceTrackerService.java |   6 +-
 .../nodelabels/RMNodeLabelsManager.java         |   8 +-
 .../resourcemanager/recovery/RMStateStore.java  |  13 +-
 .../recovery/StoreLimitException.java           |  33 +
 .../recovery/ZKRMStateStore.java                |  23 +-
 .../rmapp/RMAppCollectorUpdateEvent.java        |  40 -
 .../resourcemanager/rmapp/RMAppEvent.java       |  25 +
 .../server/resourcemanager/rmapp/RMAppImpl.java |  42 +-
 .../scheduler/AppSchedulingInfo.java            |  69 +-
 .../resourcemanager/scheduler/QueueMetrics.java | 194 ++--
 .../scheduler/ResourceUsage.java                |  14 +-
 .../scheduler/SchedulerApplicationAttempt.java  |  12 +-
 .../scheduler/capacity/AbstractCSQueue.java     |  23 +
 .../scheduler/capacity/CSQueue.java             |   7 +
 .../scheduler/capacity/CSQueueMetrics.java      |  56 +-
 .../scheduler/capacity/CSQueueUtils.java        |  16 +-
 .../CapacitySchedulerConfiguration.java         |  34 +
 .../scheduler/capacity/LeafQueue.java           |  45 +-
 .../scheduler/capacity/UserInfo.java            |  15 +-
 .../scheduler/capacity/UsersManager.java        | 172 +++-
 .../scheduler/common/AssignmentInformation.java |  60 +-
 .../scheduler/common/fica/FiCaSchedulerApp.java |  37 +-
 .../scheduler/fair/FSAppAttempt.java            |  28 +-
 .../scheduler/fair/FairSchedulerEventLog.java   |   4 +-
 .../webapp/CapacitySchedulerPage.java           |   9 +-
 .../resourcemanager/webapp/RMWSConsts.java      | 202 ++++
 .../webapp/RMWebServiceProtocol.java            | 635 +++++++++++++
 .../resourcemanager/webapp/RMWebServices.java   | 937 +++++++++----------
 .../yarn/server/resourcemanager/MockRM.java     |  27 +-
 .../resourcemanager/TestRMAdminService.java     |  59 ++
 .../invariants/TestMetricsInvariantChecker.java |   7 +-
 .../nodelabels/TestRMNodeLabelsManager.java     |  49 +
 .../recovery/TestZKRMStateStore.java            |  37 +
 .../scheduler/TestQueueMetrics.java             |  61 +-
 .../TestSchedulerApplicationAttempt.java        |   7 +-
 .../capacity/TestCapacityScheduler.java         |   6 +-
 .../scheduler/capacity/TestLeafQueue.java       | 123 +++
 .../TestNodeLabelContainerAllocation.java       |  10 +-
 .../resourcemanager/webapp/TestRMWebApp.java    |   8 +-
 .../server/ContainerTokenIdentifierForTest.java |   5 +-
 .../hadoop/yarn/server/MiniYARNCluster.java     |   6 +-
 .../storage/TimelineSchemaCreator.java          |  36 +-
 .../src/site/markdown/CapacityScheduler.md      |   1 +
 349 files changed, 11360 insertions(+), 3118 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/2b3c4b84/hadoop-common-project/hadoop-common/pom.xml
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/hadoop/blob/2b3c4b84/hadoop-common-project/hadoop-common/src/main/resources/core-default.xml
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/hadoop/blob/2b3c4b84/hadoop-project/pom.xml
----------------------------------------------------------------------


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message