This is an automated email from the ASF dual-hosted git repository. jinglun pushed a change to branch HADOOP-19236-01 in repository https://gitbox.apache.org/repos/asf/hadoop.git
discard dc1087a179f HADOOP-19236. Incorporate VolcanoEngine Cloud TOS File System Implementation. add 833725193f2 HADOOP-19487. Upgrade libopenssl to 3.1.1 for rsync on Windows (#7487) add 1416c94d7cc HDFS-17750. [ARR] RouterWebHdfsMethods adapts to async rpc. (#7462). Contributed by hfutatzhanghb. add affb8c36aac HDFS-17746. [ARR] The behavior of throwing exception in getListing should be consistent with sync mode. (#7464). Contributed by hfutatzhanghb. add 2b32e46f666 HDFS-17754. Add uriparser2 to notices (#7481) add e0d739a7ff2 HADOOP-19444: ABFS: [FnsOverBlob][Tests] Add Tests For Negative Scenarios Identified for Ingress Operations (#7424) add 32da0d6d144 HADOOP-19400: Expand specification and contract test coverage for InputStream reads. add ef9043fcc00 HDFS-17743: Added support for random datanode ordering in getBlockLocations() (#7447) add 49d4c734b0e YARN-11765. Refactor: Move Clock Class from hadoop-mapreduce-project to hadoop-common-project for Reusability (#7352) Contributed by Jiandan Yang. add f65e9476f75 HADOOP-19446. ABFS: [FnsOverBlob][Tests] Add Tests For Negative Scenarios Identified for Delete Operation (#7376) add 7d143b7fb1c YARN-11262. [JDK17] Upgrade JUnit from 4 to 5 in hadoop-yarn-server-resourcemanager Part1. (#7474) add baf393d6c6e YARN-11262. [JDK17] Upgrade JUnit from 4 to 5 in hadoop-yarn-server-resourcemanager Part2. (#7484) add f910b11614f HDFS-17735. [ARR] LocalResolver#getDatanodesSubcluster adapts to async rpc. (#7422). Contributed by hfutatzhanghb. add b73796a43c7 HADOOP-19452. Client#call decrease asyncCallCounter incorrectlly when exceptions occur. (#7384). Contributed by hfutatzhanghb. add cd8f18b71d2 MAPREDUCE-7503. Fix ByteBuf leaks in TestShuffleChannelHandler (#7500) Contributed by Istvan Toth. add 4d8ac20fd42 HADOOP-19500. Skip tests that require JavaScript engine when it's not available (#7503) add 9ca1052d00c YARN-11799. Remove PrintStream write counting from TestYarnCLI (#7518) add 7005bcb4c9a HADOOP-18940. [ABFS] Remove commons IOUtils.close() from AbfsOutputStream (#7506) add fba01e69556 YARN-11797. Fix tests trying to connect to 0.0.0.0 (#7515) Contributed by Istvan Toth. add f9f9aeefc6c HADOOP-19506. Fix TestThrottledInputStream when bandwidth is equal to throttle limit (#7517) Contributed by Istvan Toth. add 71a945ac869 MAPREDUCE-7504. Remove terminally deprecated Thread.suspend from TestMergeManager (#7519) Contributed by Istvan Toth. add 6e844030c9e YARN-11262. [JDK17] Upgrade JUnit from 4 to 5 in hadoop-yarn-server-resourcemanager Part3. (#7485) add 069eff9ecd2 HADOOP-19475. Update Boost to 1.86.0 add af6a64f7631 HADOOP-19499. Handle JDK-8225499 IpAddr.toString() format changes in tests add 758f3a04638 HDFS-17759. Explicitly depend on jackson-core in hadoop-hdfs (#7508) Contributed by Istvan Toth. add 1f640aa02a2 YARN-11787. [Federation] Enhance Exception Handling in FederationClientInterceptor#forceKillApplication. (#7465) Contributed by Shilun Fan. add df5e2054525 HDFS-17713. [ARR] Throtting asynchronous calls for each nameservice. (#7304). Contributed by hfutatzhanghb. add 26b9affe046 HDFS-17714. MockResolver#removeLocation should also remove src path. (#7313). Contributed by hfutatzhanghb. add e5c901823d6 YARN-11788 - Remove unused unit tests. (#7476) Contributed by Shilun Fan. add d26f4fdf3a8 HADOOP-19509. Add a config entry to make IPC.Client checkAsyncCall off by default. (#7521) add 3e8f1f65bdd HDFS-17720.[JDK17] Upgrade JUnit from 4 to 5 in hadoop-hdfs-rbf Part1. add 65f656738aa HADOOP-19488 fix the temporary direction creation on Windows (#7511) add 2af914b5d91 HADOOP-18991 Remove commons-beanutils dependency from Hadoop 3 (#7524) Contributed by Istvan Toth. add 05167ea06af YARN-11795. Skip BaseFederationPoliciesTest.testReinitilializeBad3() on JVMs where Mockito cannot mock ByteBuffers (#7510) Contributed by Istvan Toth. add b64ad9b682d HADOOP-19508. Set charsetEncoder in HadoopArchiveLogs (#7520) Contributed by Istvan Toth. add 68fcde01fba YARN-11262. Upgrade JUnit from 4 to 5 in hadoop-yarn-server-resourcemanager Part4. (#7488) add fb30082948c HDFS-17749. [ARR] Fix wrong results due to the wrong usage of asyncComplete in getListing. (#7466). Contributed by hfutatzhanghb. add ae9cd7576d9 YARN-11262. [JDK17] Upgrade JUnit from 4 to 5 in hadoop-yarn-server-resourcemanager Part5. (#7489) add 488376c13b1 HADOOP-19502. Add RegexpSingleline module to checkstyle.xml. (#7505) Contributed by hfutatzhanghb. add c94b41848bd Revert "HADOOP-19502. Add RegexpSingleline module to checkstyle.xml. (#7505) …" (#7534) add 3fd404f2eff HADOOP-19495. Add JDK 24 to Ubuntu 20.04 docker development images add 26940713fc5 YARN-11796. Accept extra JDK 17 options in tests (#7512) Contributed by Istvan Toth. add 9f7aa7223f6 HADOOP-19514: SecretManager logs at INFO in bin/hadoop calls add 18f761785a2 HDFS-17720.[JDK17] Upgrade JUnit from 4 to 5 in hadoop-hdfs-rbf Part2. add cc9e5485727 YARN-11266. [JDK17] Upgrade JUnit from 4 to 5 in hadoop-yarn-server-timelineservice-hbase-tests. (#7538) add a314a1d7148 YARN-11798. Precheck request separately to avoid redundant node checks and optimize performance for global scheduler. (#7516) Contributed by Tao Yang. add a31289df7ac HADOOP-19236. Incorporate VolcanoEngine Cloud TOS File System Implementation. This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (dc1087a179f) \ N -- N -- N refs/heads/HADOOP-19236-01 (a31289df7ac) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: BUILDING.txt | 14 +- NOTICE-binary | 9 +- dev-support/docker/Dockerfile | 5 + dev-support/docker/Dockerfile_aarch64 | 5 + dev-support/docker/Dockerfile_windows_10 | 8 +- dev-support/docker/pkg-resolver/install-boost.sh | 14 +- dev-support/docker/pkg-resolver/packages.json | 2 + hadoop-common-project/hadoop-common/pom.xml | 11 - .../main/java/org/apache/hadoop/ipc/Client.java | 28 +- .../org/apache/hadoop/net/NetworkTopology.java | 18 + .../hadoop/security/token/SecretManager.java | 4 +- .../main/java/org/apache/hadoop}/util/Clock.java | 2 +- .../org/apache/hadoop}/util/MonotonicClock.java | 3 +- .../main/java/org/apache/hadoop/util/RunJar.java | 72 +- .../java/org/apache/hadoop}/util/SystemClock.java | 7 +- .../java/org/apache/hadoop}/util/UTCClock.java | 3 +- .../src/main/resources/core-default.xml | 1 + .../site/markdown/filesystem/fsdatainputstream.md | 22 +- .../fs/contract/AbstractContractOpenTest.java | 136 +++ .../hadoop/fs/contract/ContractTestUtils.java | 53 + .../java/org/apache/hadoop/ipc/TestAsyncIPC.java | 53 +- .../java/org/apache/hadoop/util/TestRunJar.java | 19 + .../src/main/native/libhdfspp/CMakeLists.txt | 2 +- .../uriparser2/uriparser2/uriparser/UriQuery.c | 1 + .../src/main/native/libhdfspp/tools/CMakeLists.txt | 2 +- .../RouterAsyncRpcFairnessPolicyController.java | 91 ++ .../MultipleDestinationMountTableResolver.java | 7 +- .../federation/resolver/order/LocalResolver.java | 18 +- .../server/federation/router/RBFConfigKeys.java | 3 + .../federation/router/RouterClientProtocol.java | 4 +- .../server/federation/router/RouterRpcClient.java | 18 +- .../federation/router/RouterWebHdfsMethods.java | 12 +- .../router/async/RouterAsyncClientProtocol.java | 158 ++- .../router/async/RouterAsyncRpcClient.java | 63 +- .../federation/router/async/utils/AsyncUtil.java | 2 +- .../src/main/resources/hdfs-rbf-default.xml | 9 + .../fs/contract/router/RouterHDFSContract.java | 4 +- .../fs/contract/router/SecurityConfUtil.java | 6 +- .../contract/router/web/RouterWebHDFSContract.java | 4 +- .../protocolPB/TestAsyncRpcProtocolPBUtil.java | 14 +- .../TestRouterClientSideTranslatorPB.java | 24 +- .../hdfs/rbfbalance/TestMountTableProcedure.java | 20 +- .../server/federation/FederationTestUtils.java | 17 +- .../server/federation/MiniRouterDFSCluster.java | 4 +- .../hdfs/server/federation/MockResolver.java | 1 + ...roportionRouterRpcFairnessPolicyController.java | 6 +- ...estRouterAsyncRpcFairnessPolicyController.java} | 143 +-- .../fairness/TestRouterHandlersFairness.java | 73 +- .../TestRouterRefreshFairnessPolicyController.java | 16 +- .../TestRouterRpcFairnessPolicyController.java | 11 +- .../server/federation/metrics/TestMetricsBase.java | 16 +- .../metrics/TestNameserviceRPCMetrics.java | 14 +- .../server/federation/metrics/TestRBFMetrics.java | 12 +- .../metrics/TestRouterClientMetrics.java | 14 +- .../resolver/TestFederationNamespaceInfo.java | 2 +- .../resolver/TestInitializeMountTableResolver.java | 10 +- .../resolver/TestMountTableResolver.java | 16 +- .../resolver/TestMultipleDestinationResolver.java | 10 +- .../federation/resolver/TestNamenodeResolver.java | 32 +- .../resolver/order/TestAvailableSpaceResolver.java | 8 +- .../resolver/order/TestLeaderFollowerResolver.java | 4 +- .../resolver/order/TestLocalResolver.java | 4 +- .../federation/router/TestConnectionManager.java | 38 +- .../server/federation/router/TestDFSRouter.java | 10 +- .../federation/router/TestDisableNameservices.java | 24 +- .../federation/router/TestDisableRouterQuota.java | 18 +- .../federation/router/TestFederationUtil.java | 4 +- .../router/TestNoNamenodesAvailableLongTime.java | 12 +- .../federation/router/TestObserverWithRouter.java | 136 +-- .../router/TestRenewLeaseWithSameINodeId.java | 12 +- .../hdfs/server/federation/router/TestRouter.java | 14 +- .../server/federation/router/TestRouterAdmin.java | 22 +- .../federation/router/TestRouterAdminCLI.java | 152 ++- .../router/TestRouterAdminGenericRefresh.java | 35 +- .../federation/router/TestRouterAllResolver.java | 28 +- .../router/TestRouterClientRejectOverload.java | 97 +- .../federation/router/TestRouterFaultTolerant.java | 60 +- .../router/TestRouterFederatedState.java | 4 +- .../router/TestRouterFederationRename.java | 24 +- .../TestRouterFederationRenameInKerberosEnv.java | 22 +- .../TestRouterFederationRenamePermission.java | 18 +- .../server/federation/router/TestRouterFsck.java | 22 +- .../router/TestRouterHeartbeatService.java | 18 +- .../router/TestRouterHttpServerXFrame.java | 8 +- .../router/TestRouterMissingFolderMulti.java | 12 +- .../federation/router/TestRouterMountTable.java | 95 +- .../router/TestRouterMountTableCacheRefresh.java | 86 +- .../TestRouterMountTableCacheRefreshSecure.java | 23 +- .../TestRouterMountTableWithoutDefaultNS.java | 22 +- .../federation/router/TestRouterMultiRack.java | 14 +- .../router/TestRouterNamenodeHeartbeat.java | 64 +- .../router/TestRouterNamenodeMonitoring.java | 28 +- .../router/TestRouterNamenodeWebScheme.java | 16 +- .../router/TestRouterNetworkTopologyServlet.java | 10 +- .../router/TestRouterPolicyProvider.java | 41 +- .../server/federation/router/TestRouterQuota.java | 22 +- .../federation/router/TestRouterQuotaManager.java | 16 +- .../router/TestRouterRPCClientRetries.java | 25 +- ...erRPCMultipleDestinationMountTableResolver.java | 44 +- ...tRouterRefreshSuperUserGroupsConfiguration.java | 14 +- .../federation/router/TestRouterRetryCache.java | 16 +- .../server/federation/router/TestRouterRpc.java | 57 +- .../router/TestRouterRpcMultiDestination.java | 36 +- .../federation/router/TestRouterRpcSingleNS.java | 18 +- .../TestRouterRpcStoragePolicySatisfier.java | 12 +- .../federation/router/TestRouterSafemode.java | 32 +- .../server/federation/router/TestRouterTrash.java | 24 +- .../federation/router/TestRouterUserMappings.java | 30 +- .../router/TestRouterWebHdfsMethods.java | 21 +- .../router/TestRouterWithSecureStartup.java | 16 +- .../server/federation/router/TestSafeMode.java | 10 +- .../router/async/RouterAsyncProtocolTestBase.java | 18 +- .../router/async/TestAsyncRouterAdmin.java | 4 +- .../router/async/TestRouterAsyncCacheAdmin.java | 8 +- .../async/TestRouterAsyncClientProtocol.java | 12 +- .../router/async/TestRouterAsyncErasureCoding.java | 26 +- .../router/async/TestRouterAsyncMountTable.java | 109 +- .../async/TestRouterAsyncNamenodeProtocol.java | 10 +- .../router/async/TestRouterAsyncQuota.java | 28 +- ...ncRPCMultipleDestinationMountTableResolver.java | 66 +- .../router/async/TestRouterAsyncRpc.java | 27 +- .../router/async/TestRouterAsyncRpcClient.java | 24 +- .../async/TestRouterAsyncRpcMultiDestination.java | 15 +- .../router/async/TestRouterAsyncRpcServer.java | 13 +- .../router/async/TestRouterAsyncSnapshot.java | 8 +- .../router/async/TestRouterAsyncStoragePolicy.java | 12 +- .../router/async/TestRouterAsyncUserProtocol.java | 8 +- .../async/TestRouterAsyncWebHdfsMethods.java | 54 + .../router/async/utils/TestAsyncUtil.java | 14 +- .../TestSQLDelegationTokenSecretManagerImpl.java | 86 +- .../security/TestRouterHttpDelegationToken.java | 19 +- .../security/TestRouterSecurityManager.java | 42 +- .../store/FederationStateStoreTestUtils.java | 2 +- .../federation/store/TestStateStoreBase.java | 14 +- .../store/TestStateStoreDisabledNameservice.java | 10 +- .../store/TestStateStoreMembershipState.java | 20 +- .../federation/store/TestStateStoreMountTable.java | 18 +- .../store/TestStateStoreRouterState.java | 18 +- .../store/driver/TestStateStoreDriverBase.java | 40 +- .../store/driver/TestStateStoreFile.java | 69 +- .../store/driver/TestStateStoreFileBase.java | 6 +- .../store/driver/TestStateStoreFileSystem.java | 74 +- .../store/driver/TestStateStoreMySQL.java | 14 +- .../federation/store/driver/TestStateStoreZK.java | 20 +- .../store/records/TestMembershipState.java | 4 +- .../federation/store/records/TestMountTable.java | 14 +- .../federation/store/records/TestRouterState.java | 4 +- hadoop-hdfs-project/hadoop-hdfs/pom.xml | 4 + .../java/org/apache/hadoop/hdfs/DFSConfigKeys.java | 6 + .../server/blockmanagement/DatanodeManager.java | 19 +- .../src/main/resources/hdfs-default.xml | 9 + .../org/apache/hadoop/net/TestNetworkTopology.java | 36 + .../apache/hadoop/mapred/MapTaskAttemptImpl.java | 2 +- .../hadoop/mapred/ReduceTaskAttemptImpl.java | 2 +- .../apache/hadoop/mapreduce/v2/app/AppContext.java | 2 +- .../hadoop/mapreduce/v2/app/MRAppMaster.java | 4 +- .../v2/app/TaskAttemptFinishingMonitor.java | 2 +- .../mapreduce/v2/app/TaskHeartbeatHandler.java | 2 +- .../hadoop/mapreduce/v2/app/job/impl/JobImpl.java | 2 +- .../mapreduce/v2/app/job/impl/MapTaskImpl.java | 2 +- .../mapreduce/v2/app/job/impl/ReduceTaskImpl.java | 2 +- .../mapreduce/v2/app/job/impl/TaskAttemptImpl.java | 2 +- .../hadoop/mapreduce/v2/app/job/impl/TaskImpl.java | 2 +- .../mapreduce/v2/app/rm/RMContainerAllocator.java | 2 +- .../v2/app/speculate/DefaultSpeculator.java | 2 +- .../mapred/TestTaskAttemptFinishingMonitor.java | 2 +- .../hadoop/mapred/TestTaskAttemptListenerImpl.java | 2 +- .../org/apache/hadoop/mapreduce/v2/app/MRApp.java | 4 +- .../hadoop/mapreduce/v2/app/MockAppContext.java | 2 +- .../mapreduce/v2/app/TestJobEndNotifier.java | 47 +- .../hadoop/mapreduce/v2/app/TestRecovery.java | 4 +- .../mapreduce/v2/app/TestRuntimeEstimators.java | 4 +- .../mapreduce/v2/app/TestTaskHeartbeatHandler.java | 4 +- .../v2/app/commit/TestCommitterEventHandler.java | 4 +- .../mapreduce/v2/app/job/impl/TestJobImpl.java | 2 +- .../v2/app/job/impl/TestShuffleProvider.java | 2 +- .../mapreduce/v2/app/job/impl/TestTaskAttempt.java | 4 +- .../job/impl/TestTaskAttemptContainerRequest.java | 2 +- .../mapreduce/v2/app/job/impl/TestTaskImpl.java | 4 +- .../mapreduce/v2/app/rm/TestRMCommunicator.java | 2 +- .../v2/app/rm/TestRMContainerAllocator.java | 4 +- .../main/java/org/apache/hadoop/mapred/Clock.java | 28 - .../jobhistory/MapAttemptFinishedEvent.java | 2 +- .../jobhistory/ReduceAttemptFinishedEvent.java | 2 +- .../jobhistory/TaskAttemptFinishedEvent.java | 2 +- .../TaskAttemptUnsuccessfulCompletionEvent.java | 2 +- .../mapreduce/jobhistory/TaskFailedEvent.java | 2 +- .../mapreduce/jobhistory/TaskFinishedEvent.java | 2 +- .../java/org/apache/hadoop/mapred/TestClock.java | 39 - .../mapreduce/task/reduce/TestMergeManager.java | 46 +- .../hadoop/mapreduce/v2/hs/HistoryFileManager.java | 4 +- .../apache/hadoop/mapreduce/v2/hs/JobHistory.java | 2 +- .../mapreduce/v2/hs/TestHistoryFileManager.java | 4 +- .../org/apache/hadoop/mapred/MiniMRCluster.java | 4 +- .../org/apache/hadoop/mapred/UtilsForTests.java | 5 +- .../hadoop/mapred/TestShuffleChannelHandler.java | 37 +- .../hadoop/mapred/TestShuffleHandlerBase.java | 7 + hadoop-project/pom.xml | 10 - .../org/apache/hadoop/tools/HadoopArchiveLogs.java | 1 + .../hadoop/fs/azurebfs/AbfsConfiguration.java | 5 + .../fs/azurebfs/services/AbfsBlobClient.java | 38 +- .../hadoop/fs/azurebfs/services/AbfsErrors.java | 1 + .../fs/azurebfs/services/AbfsOutputStream.java | 8 +- .../azurebfs/services/AzureBlobBlockManager.java | 31 +- .../azurebfs/services/AzureBlobIngressHandler.java | 7 +- .../fs/azurebfs/services/AzureBlockManager.java | 8 + .../fs/azurebfs/services/AzureDFSBlockManager.java | 6 + .../AzureDfsToBlobIngressFallbackHandler.java | 2 +- .../fs/azurebfs/services/RenameAtomicity.java | 6 +- .../fs/azurebfs/ITestAbfsCustomEncryption.java | 3 +- .../azurebfs/ITestAzureBlobFileSystemAppend.java | 132 ++- .../azurebfs/ITestAzureBlobFileSystemDelete.java | 142 ++- .../ITestAzureBlobFileSystemInitAndCreate.java | 39 +- .../tools/util/TestThrottledInputStream.java | 2 +- .../java/org/apache/hadoop/yarn/sls/AMRunner.java | 5 +- .../apache/hadoop/yarn/sls/BaseSLSRunnerTest.java | 10 + .../distributedshell/ApplicationMaster.java | 2 +- .../hadoop/yarn/service/ServiceScheduler.java | 4 +- .../apache/hadoop/yarn/client/TestRMFailover.java | 10 +- .../yarn/client/api/impl/TestYarnClient.java | 316 +++-- .../yarn/client/api/impl/TestYarnClientImpl.java | 73 +- .../api/impl/TestYarnClientWithReservation.java | 4 +- .../apache/hadoop/yarn/client/cli/TestYarnCLI.java | 18 - .../apache/hadoop/yarn/event/AsyncDispatcher.java | 4 +- .../apache/hadoop/yarn/event/EventDispatcher.java | 4 +- .../ifile/LogAggregationIndexedFileController.java | 4 +- .../yarn/util/AbstractLivelinessMonitor.java | 2 + .../java/org/apache/hadoop/yarn/util/Clock.java | 4 + .../apache/hadoop/yarn/util/MonotonicClock.java | 4 + .../hadoop/yarn/util/ProcfsBasedProcessTree.java | 2 + .../org/apache/hadoop/yarn/util/SystemClock.java | 6 +- .../java/org/apache/hadoop/yarn/util/UTCClock.java | 5 +- .../hadoop/yarn/util/WindowsBasedProcessTree.java | 2 + .../TestLogAggregationIndexedFileController.java | 2 +- .../apache/hadoop/yarn/util/ControlledClock.java | 2 + .../yarn/util/TestProcfsBasedProcessTree.java | 2 + .../yarn/util/TestWindowsBasedProcessTree.java | 1 + .../store/impl/MemoryFederationStateStore.java | 2 +- .../store/impl/SQLFederationStateStore.java | 4 +- .../store/impl/ZookeeperFederationStateStore.java | 4 +- .../policies/BaseFederationPoliciesTest.java | 11 +- .../store/impl/FederationStateStoreBaseTest.java | 3 +- .../utils/FederationStateStoreTestUtil.java | 2 +- .../nodemanager/amrmproxy/AMRMProxyService.java | 4 +- .../amrmproxy/FederationInterceptor.java | 2 +- .../containermanager/ContainerManagerImpl.java | 2 +- .../containermanager/container/ContainerImpl.java | 4 +- .../container/SlidingWindowRetryPolicy.java | 2 +- .../linux/resources/AbstractCGroupsHandler.java | 4 +- .../AbstractCGroupsResourceCalculator.java | 4 +- .../resources/CGroupElasticMemoryController.java | 4 +- .../util/CgroupsLCEResourcesHandler.java | 4 +- .../TestLinuxContainerExecutorWithMocks.java | 8 + .../localizer/TestContainerLocalizer.java | 22 + .../hadoop-yarn-server-resourcemanager/pom.xml | 6 +- .../server/resourcemanager/ClientRMService.java | 4 +- .../DecommissioningNodesWatcher.java | 2 +- .../server/resourcemanager/NodesListManager.java | 4 +- .../resourcemanager/RMActiveServiceContext.java | 4 +- .../yarn/server/resourcemanager/RMContextImpl.java | 2 +- .../yarn/server/resourcemanager/RMServerUtils.java | 4 +- .../federation/FederationClientMethod.java | 2 +- .../federation/FederationStateStoreService.java | 4 +- .../ProportionalCapacityPreemptionPolicy.java | 4 +- .../invariants/ReservationInvariantsChecker.java | 2 +- .../resourcemanager/recovery/ZKRMStateStore.java | 4 +- .../reservation/AbstractReservationSystem.java | 4 +- .../reservation/AbstractSchedulerPlanFollower.java | 2 +- .../reservation/CapacitySchedulerPlanFollower.java | 2 +- .../reservation/FairSchedulerPlanFollower.java | 2 +- .../resourcemanager/reservation/InMemoryPlan.java | 4 +- .../resourcemanager/reservation/PlanFollower.java | 2 +- .../reservation/ReservationInputValidator.java | 2 +- .../planning/SimpleCapacityReplanner.java | 4 +- .../server/resourcemanager/rmapp/RMAppImpl.java | 4 +- .../rmapp/attempt/AMLivelinessMonitor.java | 2 +- .../rmapp/monitor/RMAppLifetimeMonitor.java | 2 +- .../scheduler/AbstractYarnScheduler.java | 4 +- .../scheduler/SchedulerApplicationAttempt.java | 2 +- .../scheduler/activities/ActivitiesManager.java | 2 +- .../scheduler/capacity/AbstractLeafQueue.java | 2 +- .../capacity/AutoCreatedQueueDeletionPolicy.java | 2 +- .../capacity/CapacitySchedulerContext.java | 2 +- .../QueueConfigurationAutoRefreshPolicy.java | 4 +- .../capacity/QueueManagementDynamicEditPolicy.java | 4 +- .../allocator/RegularContainerAllocator.java | 90 +- .../GuaranteedOrZeroCapacityOverTimePolicy.java | 4 +- .../fair/AllocationFileLoaderService.java | 4 +- .../webapp/dao/AppActivitiesInfo.java | 2 +- .../yarn/server/resourcemanager/ACLsTestBase.java | 4 +- .../yarn/server/resourcemanager/HATestUtil.java | 2 +- .../ParameterizedSchedulerTestBase.java | 14 +- .../server/resourcemanager/QueueACLsTestBase.java | 6 +- .../resourcemanager/TestApplicationACLs.java | 111 +- .../resourcemanager/TestClientRMService.java | 4 +- .../hadoop/yarn/server/resourcemanager/TestRM.java | 175 +-- .../yarn/server/resourcemanager/TestRMRestart.java | 715 ++++++----- .../TestReservationSystemWithRMHA.java | 4 +- .../TestWorkPreservingRMRestart.java | 275 +++-- .../TestWorkPreservingUnmanagedAM.java | 67 +- .../ahs/TestRMApplicationHistoryWriter.java | 84 +- .../applicationsmanager/TestAMLaunchFailure.java | 234 ---- .../TestAMRMRPCNodeUpdates.java | 86 +- .../applicationsmanager/TestAMRMRPCResponseId.java | 27 +- .../applicationsmanager/TestAMRestart.java | 236 ++-- .../applicationsmanager/TestASMStateMachine.java | 217 ---- .../TestApplicationMasterExpiry.java | 174 --- .../TestSchedulerNegotiator.java | 164 --- .../blacklist/TestBlacklistManager.java | 53 +- .../TestFederationRMStateStoreService.java | 112 +- .../TestFederationStateStoreServiceMetrics.java | 4 +- .../TestRMAppLogAggregationStatus.java | 129 +- .../TestCombinedSystemMetricsPublisher.java | 77 +- .../metrics/TestSystemMetricsPublisher.java | 224 ++-- .../metrics/TestSystemMetricsPublisherForV2.java | 74 +- .../monitor/TestSchedulingMonitor.java | 16 +- .../TestPreemptionForQueueWithPriorities.java | 6 +- .../TestProportionalCapacityPreemptionPolicy.java | 43 +- ...lCapacityPreemptionPolicyForNodePartitions.java | 6 +- ...acityPreemptionPolicyForReservedContainers.java | 6 +- ...lCapacityPreemptionPolicyInterQueueWithDRF.java | 6 +- ...ortionalCapacityPreemptionPolicyIntraQueue.java | 6 +- ...cityPreemptionPolicyIntraQueueFairOrdering.java | 6 +- ...apacityPreemptionPolicyIntraQueueUserLimit.java | 6 +- ...lCapacityPreemptionPolicyIntraQueueWithDRF.java | 6 +- ...ionalCapacityPreemptionPolicyMockFramework.java | 51 +- ...alCapacityPreemptionPolicyPreemptToBalance.java | 4 +- ...ionalCapacityPreemptionPolicyMockFramework.java | 26 +- .../invariants/TestMetricsInvariantChecker.java | 22 +- .../TestFileSystemNodeAttributeStore.java | 65 +- .../nodelabels/TestNodeAttributesManager.java | 82 +- .../nodelabels/TestNodeLabelFileReplication.java | 10 +- .../TestRMDelegatedNodeLabelsUpdater.java | 15 +- .../nodelabels/TestRMNodeLabelsManager.java | 205 ++-- .../placement/TestAppNameMappingPlacementRule.java | 10 +- .../placement/TestFairQueuePlacementUtils.java | 110 +- .../placement/TestPlacementFactory.java | 25 +- .../placement/TestPlacementManager.java | 23 +- .../placement/TestPlacementRuleFS.java | 52 +- .../TestUserGroupMappingPlacementRule.java | 16 +- .../csmappingrule/TestCSMappingPlacementRule.java | 76 +- .../placement/csmappingrule/TestMappingRule.java | 6 +- .../csmappingrule/TestMappingRuleActions.java | 7 +- .../csmappingrule/TestMappingRuleMatchers.java | 66 +- .../TestMappingRuleValidationContextImpl.java | 7 +- .../csmappingrule/TestVariableContext.java | 70 +- .../preprocessor/TestContextProcessor.java | 6 +- .../preprocessor/TestNodeLabelProcessor.java | 2 +- .../preprocessor/TestQueueProcessor.java | 7 +- .../preprocessor/TestTagAddProcessor.java | 8 +- .../recovery/RMStateStoreTestBase.java | 139 +-- .../TestCheckRemoveZKNodeRMStateStore.java | 89 +- .../recovery/TestFSRMStateStore.java | 46 +- .../recovery/TestLeveldbRMStateStore.java | 47 +- .../recovery/TestMemoryRMStateStore.java | 12 +- .../resourcemanager/recovery/TestProtos.java | 8 +- .../recovery/TestRMStateStoreUtils.java | 8 +- .../recovery/TestZKRMStateStore.java | 346 +++--- .../recovery/TestZKRMStateStorePerf.java | 10 +- .../TestZKRMStateStoreZKClientConnections.java | 28 +- .../reservation/BaseSharingPolicyTest.java | 18 +- .../reservation/ReservationSystemTestUtil.java | 25 +- .../reservation/TestCapacityOverTimePolicy.java | 28 +- .../TestCapacitySchedulerPlanFollower.java | 33 +- .../reservation/TestFairSchedulerPlanFollower.java | 29 +- .../reservation/TestInMemoryPlan.java | 206 ++-- .../TestInMemoryReservationAllocation.java | 47 +- .../reservation/TestNoOverCommitPolicy.java | 28 +- .../TestPeriodicRLESparseResourceAllocation.java | 73 +- .../TestRLESparseResourceAllocation.java | 127 +- .../reservation/TestReservationInputValidator.java | 269 ++--- .../reservation/TestReservationSystem.java | 49 +- .../reservation/TestReservationSystemUtil.java | 20 +- .../reservation/TestSchedulerPlanFollowerBase.java | 50 +- .../reservation/planning/TestAlignedPlanner.java | 314 ++--- .../planning/TestGreedyReservationAgent.java | 287 ++--- .../planning/TestReservationAgents.java | 31 +- .../planning/TestSimpleCapacityReplanner.java | 65 +- .../resource/TestResourceProfiles.java | 55 +- .../resourcetracker/TestNMExpiry.java | 12 +- .../resourcetracker/TestNMReconnect.java | 70 +- .../resourcetracker/TestRMNMRPCResponseId.java | 24 +- .../rmapp/TestApplicationLifetimeMonitor.java | 170 +-- .../rmapp/TestNodesListManager.java | 47 +- .../rmapp/TestRMAppTransitions.java | 339 +++--- .../rmapp/attempt/TestAMLivelinessMonitor.java | 13 +- .../attempt/TestRMAppAttemptImplDiagnostics.java | 31 +- .../rmapp/attempt/TestRMAppAttemptTransitions.java | 477 +++++--- .../rmcontainer/TestRMContainerImpl.java | 56 +- .../scheduler/TestAbstractYarnScheduler.java | 255 ++-- .../scheduler/TestAppSchedulingInfo.java | 69 +- .../scheduler/TestClusterNodeTracker.java | 93 +- .../TestConfigurationMutationACLPolicies.java | 10 +- .../scheduler/TestPartitionQueueMetrics.java | 98 +- .../scheduler/TestQueueMetrics.java | 24 +- .../TestQueueMetricsForCustomResources.java | 24 +- .../scheduler/TestResourceUsage.java | 24 +- .../scheduler/TestSchedulerApplicationAttempt.java | 80 +- .../scheduler/TestSchedulerHealth.java | 124 +- .../scheduler/TestSchedulerOvercommit.java | 52 +- .../scheduler/TestSchedulerUtils.java | 206 ++-- .../TestSchedulingWithAllocationRequestId.java | 54 +- .../activities/TestActivitiesManager.java | 111 +- .../CapacitySchedulerPreemptionTestBase.java | 15 +- .../CapacitySchedulerQueueCalculationTestBase.java | 4 +- .../capacity/CapacitySchedulerQueueHelpers.java | 17 +- .../capacity/CapacitySchedulerTestUtilities.java | 11 +- .../scheduler/capacity/QueueAssertionBuilder.java | 15 +- .../TestAMAllocatedToNonExclusivePartition.java | 11 +- .../TestAbsoluteResourceConfiguration.java | 628 +++++----- .../TestAbsoluteResourceWithAutoQueue.java | 45 +- .../scheduler/capacity/TestApplicationLimits.java | 35 +- .../capacity/TestApplicationLimitsByPartition.java | 171 +-- .../capacity/TestApplicationPriority.java | 142 +-- .../TestApplicationPriorityACLConfiguration.java | 11 +- .../capacity/TestApplicationPriorityACLs.java | 14 +- .../TestAutoCreatedQueueDeletionPolicy.java | 79 +- .../capacity/TestAutoCreatedQueueTemplate.java | 90 +- .../capacity/TestCSAllocateCustomResource.java | 50 +- .../capacity/TestCSMaxRunningAppsEnforcer.java | 8 +- .../scheduler/capacity/TestCSQueueStore.java | 15 +- .../scheduler/capacity/TestCapacityScheduler.java | 433 +++---- .../TestCapacitySchedulerAmbiguousLeafs.java | 2 +- .../capacity/TestCapacitySchedulerApps.java | 283 ++--- .../TestCapacitySchedulerAsyncScheduling.java | 188 +-- .../TestCapacitySchedulerAutoCreatedQueueBase.java | 19 +- ...apacitySchedulerAutoCreatedQueuePreemption.java | 13 +- .../TestCapacitySchedulerAutoQueueCreation.java | 97 +- .../TestCapacitySchedulerConfigValidator.java | 224 ++-- .../TestCapacitySchedulerConfiguration.java | 8 +- .../TestCapacitySchedulerDynamicBehavior.java | 22 +- .../TestCapacitySchedulerLazyPreemption.java | 125 +- .../TestCapacitySchedulerMaxParallelApps.java | 49 +- .../capacity/TestCapacitySchedulerMultiNodes.java | 220 +++- ...tCapacitySchedulerMultiNodesWithPreemption.java | 37 +- .../TestCapacitySchedulerNewQueueAutoCreation.java | 508 ++++---- ...lerNewQueueAutoCreationWithCapacityVectors.java | 101 +- .../TestCapacitySchedulerNodeLabelUpdate.java | 131 +- .../capacity/TestCapacitySchedulerNodes.java | 84 +- .../capacity/TestCapacitySchedulerPerf.java | 28 +- .../capacity/TestCapacitySchedulerQueueACLs.java | 8 +- .../TestCapacitySchedulerQueueMappingFactory.java | 36 +- .../capacity/TestCapacitySchedulerQueues.java | 440 ++++--- ...stCapacitySchedulerSchedulingRequestUpdate.java | 2 +- .../TestCapacitySchedulerSurgicalPreemption.java | 139 +-- .../capacity/TestCapacitySchedulerWeightMode.java | 69 +- ...estCapacitySchedulerWithMultiResourceTypes.java | 74 +- ...stCapacitySchedulerWorkflowPriorityMapping.java | 8 +- .../scheduler/capacity/TestChildQueueOrder.java | 12 +- .../capacity/TestConfigurationProperties.java | 88 +- .../capacity/TestContainerAllocation.java | 268 +++-- .../scheduler/capacity/TestContainerResizing.java | 219 ++-- .../capacity/TestIncreaseAllocationExpirer.java | 83 +- .../scheduler/capacity/TestLeafQueue.java | 157 ++- .../TestMixedQueueResourceCalculation.java | 28 +- .../capacity/TestNodeLabelContainerAllocation.java | 363 +++--- .../scheduler/capacity/TestParentQueue.java | 140 +-- .../scheduler/capacity/TestQueueCapacities.java | 38 +- .../capacity/TestQueueCapacityVector.java | 44 +- .../TestQueueConfigurationAutoRefreshPolicy.java | 36 +- .../TestQueueManagementDynamicEditPolicy.java | 8 +- .../scheduler/capacity/TestQueueMappings.java | 42 +- .../scheduler/capacity/TestQueueParsing.java | 388 +++--- .../scheduler/capacity/TestQueuePath.java | 106 +- .../scheduler/capacity/TestQueueState.java | 78 +- .../scheduler/capacity/TestQueueStateManager.java | 52 +- .../scheduler/capacity/TestReservationQueue.java | 16 +- .../scheduler/capacity/TestReservations.java | 45 +- .../scheduler/capacity/TestResourceVector.java | 55 +- .../TestSchedulingRequestContainerAllocation.java | 232 ++-- ...tSchedulingRequestContainerAllocationAsync.java | 67 +- .../TestUniformQueueResourceCalculation.java | 2 +- .../scheduler/capacity/TestUsersManager.java | 21 +- .../TestWorkPreservingRMRestartForNodeLabel.java | 25 +- .../capacity/conf/ConfigurationStoreBaseTest.java | 14 +- .../conf/PersistentConfigurationStoreBaseTest.java | 12 +- .../conf/TestConfigurationUpdateAssembler.java | 14 +- .../conf/TestFSSchedulerConfigurationStore.java | 36 +- .../conf/TestInMemoryConfigurationStore.java | 4 +- .../conf/TestLeveldbConfigurationStore.java | 41 +- .../conf/TestMutableCSConfigurationProvider.java | 16 +- .../conf/TestQueueCapacityConfigParser.java | 81 +- .../capacity/conf/TestZKConfigurationStore.java | 187 +-- .../capacity/placement/TestMappingRuleCreator.java | 119 +- .../converter/TestLegacyMappingRuleToJson.java | 18 +- ...TestPriorityUtilizationQueueOrderingPolicy.java | 6 +- .../TestDeactivatedLeafQueuesByLabel.java | 5 +- .../constraint/TestAllocationTagsManager.java | 158 +-- .../constraint/TestAllocationTagsNamespace.java | 75 +- .../constraint/TestBatchedRequestsIterators.java | 11 +- .../TestPlacementConstraintManagerService.java | 116 +- .../constraint/TestPlacementConstraintsUtil.java | 194 +-- .../constraint/TestPlacementProcessor.java | 118 +- .../constraint/algorithm/TestCircularIterator.java | 16 +- .../algorithm/TestLocalAllocationTagsManager.java | 30 +- ...CentralizedOpportunisticContainerAllocator.java | 35 +- .../distributed/TestNodeQueueLoadMonitor.java | 228 ++-- .../scheduler/fair/FairSchedulerTestBase.java | 7 +- .../fair/TestAllocationFileLoaderService.java | 231 ++-- .../scheduler/fair/TestAppRunnability.java | 18 +- .../fair/TestApplicationMasterServiceWithFS.java | 37 +- .../scheduler/fair/TestComputeFairShares.java | 26 +- .../scheduler/fair/TestConfigurableResource.java | 17 +- .../scheduler/fair/TestContinuousScheduling.java | 52 +- .../scheduler/fair/TestFSAppAttempt.java | 91 +- .../scheduler/fair/TestFSAppStarvation.java | 56 +- .../scheduler/fair/TestFSLeafQueue.java | 55 +- .../scheduler/fair/TestFSParentQueue.java | 10 +- .../scheduler/fair/TestFSQueueMetrics.java | 214 ++-- .../scheduler/fair/TestFSSchedulerNode.java | 137 +-- .../scheduler/fair/TestFairScheduler.java | 1245 ++++++++++---------- .../fair/TestFairSchedulerConfiguration.java | 363 +++--- .../scheduler/fair/TestFairSchedulerFairShare.java | 12 +- .../fair/TestFairSchedulerPreemption.java | 135 ++- .../scheduler/fair/TestFairSchedulerUtilities.java | 8 +- .../TestFairSchedulerWithMultiResourceTypes.java | 12 +- .../scheduler/fair/TestMaxRunningAppsEnforcer.java | 8 +- .../scheduler/fair/TestQueueManager.java | 295 ++--- .../fair/TestQueueManagerRealScheduler.java | 12 +- .../scheduler/fair/TestQueuePlacementPolicy.java | 34 +- .../scheduler/fair/TestSchedulingPolicy.java | 104 +- .../scheduler/fair/TestSchedulingUpdate.java | 53 +- .../fair/TestVisitedResourceRequestTracker.java | 31 +- .../converter/FSConfigConverterTestCommons.java | 4 +- .../converter/TestConvertedConfigValidator.java | 24 +- .../TestFSConfigToCSConfigArgumentHandler.java | 158 ++- .../converter/TestFSConfigToCSConfigConverter.java | 389 +++--- .../TestFSConfigToCSConfigConverterMain.java | 60 +- .../TestFSConfigToCSConfigRuleHandler.java | 45 +- .../fair/converter/TestFSQueueConverter.java | 314 +++-- .../fair/converter/TestFSYarnSiteConverter.java | 212 ++-- .../converter/TestQueuePlacementConverter.java | 82 +- .../TestWeightToPercentageConverter.java | 101 +- .../TestWeightToWeightConverter.java | 49 +- .../TestDominantResourceFairnessPolicy.java | 183 +-- .../scheduler/fair/policies/TestEmptyQueues.java | 16 +- .../scheduler/fifo/TestFifoScheduler.java | 202 ++-- .../TestSingleConstraintAppPlacementAllocator.java | 63 +- .../scheduler/policy/MockSchedulableEntity.java | 2 +- .../scheduler/policy/TestFairOrderingPolicy.java | 61 +- .../scheduler/policy/TestFifoOrderingPolicy.java | 59 +- .../TestFifoOrderingPolicyForPendingApps.java | 6 +- ...tFifoOrderingPolicyWithExclusivePartitions.java | 46 +- .../resourcemanager/security/TestAMRMTokens.java | 90 +- .../security/TestClientToAMTokens.java | 70 +- .../security/TestDelegationTokenRenewer.java | 194 +-- .../TestDelegationTokenRenewerLifecycle.java | 2 +- .../security/TestProxyCAManager.java | 30 +- .../security/TestRMAuthenticationFilter.java | 16 +- .../security/TestRMDelegationTokens.java | 35 +- .../volume/csi/TestVolumeCapabilityRange.java | 51 +- .../volume/csi/TestVolumeLifecycle.java | 62 +- .../volume/csi/TestVolumeMetaData.java | 147 +-- .../volume/csi/TestVolumeProcessor.java | 57 +- .../webapp/ActivitiesTestUtils.java | 33 +- .../server/resourcemanager/webapp/TestAppPage.java | 2 +- .../webapp/TestApplicationsRequestBuilder.java | 186 +-- .../resourcemanager/webapp/TestNodesPage.java | 41 +- .../resourcemanager/webapp/TestRMWebApp.java | 24 +- .../webapp/TestRMWebAppFairScheduler.java | 6 +- .../webapp/TestRMWebServiceAppsNodelabel.java | 36 +- .../resourcemanager/webapp/TestRMWebServices.java | 225 ++-- .../webapp/TestRMWebServicesAppAttempts.java | 55 +- .../TestRMWebServicesAppCustomResourceTypes.java | 8 +- .../webapp/TestRMWebServicesApps.java | 513 ++++---- .../TestRMWebServicesAppsCustomResourceTypes.java | 14 +- .../webapp/TestRMWebServicesAppsModification.java | 155 +-- .../webapp/TestRMWebServicesCapacitySched.java | 47 +- ...TestRMWebServicesCapacitySchedDefaultLabel.java | 27 +- ...estRMWebServicesCapacitySchedDynamicConfig.java | 30 +- ...icesCapacitySchedDynamicConfigAbsoluteMode.java | 30 +- ...rvicesCapacitySchedDynamicConfigWeightMode.java | 30 +- ...cesCapacitySchedDynamicConfigWeightModeDQC.java | 30 +- ...ebServicesCapacitySchedLegacyQueueCreation.java | 30 +- ...pacitySchedLegacyQueueCreationAbsoluteMode.java | 32 +- ...WebServicesCapacitySchedulerConfigMutation.java | 40 +- ...estRMWebServicesCapacitySchedulerMixedMode.java | 6 +- ...itySchedulerMixedModeAbsoluteAndPercentage.java | 6 +- ...lerMixedModeAbsoluteAndPercentageAndWeight.java | 6 +- ...edModeAbsoluteAndPercentageAndWeightVector.java | 6 +- ...edulerMixedModeAbsoluteAndPercentageVector.java | 6 +- ...apacitySchedulerMixedModeAbsoluteAndWeight.java | 6 +- ...ySchedulerMixedModeAbsoluteAndWeightVector.java | 6 +- ...acitySchedulerMixedModePercentageAndWeight.java | 6 +- ...chedulerMixedModePercentageAndWeightVector.java | 6 +- .../TestRMWebServicesConfigurationMutation.java | 50 +- .../webapp/TestRMWebServicesContainers.java | 10 +- ...estRMWebServicesCustomResourceTypesCommons.java | 6 +- ...RMWebServicesDelegationTokenAuthentication.java | 65 +- .../webapp/TestRMWebServicesDelegationTokens.java | 59 +- .../TestRMWebServicesForCSWithPartitions.java | 238 ++-- ...TestRMWebServicesHttpStaticUserPermissions.java | 14 +- .../webapp/TestRMWebServicesNodeLabels.java | 44 +- .../webapp/TestRMWebServicesNodes.java | 146 +-- .../webapp/TestRMWebServicesReservation.java | 160 ++- .../TestRMWebServicesSchedulerActivities.java | 51 +- ...esSchedulerActivitiesWithMultiNodesEnabled.java | 44 +- .../webapp/TestRMWebappAuthentication.java | 38 +- .../webapp/TestRedirectionErrorPage.java | 2 +- .../resourcemanager/webapp/TestWebServiceUtil.java | 6 +- .../webapp/dao/TestFairSchedulerQueueInfo.java | 11 +- .../FairSchedulerJsonVerifications.java | 59 +- .../FairSchedulerXmlVerifications.java | 41 +- .../TestRMWebServicesFairScheduler.java | 14 +- ...ebServicesFairSchedulerCustomResourceTypes.java | 14 +- .../webapp/helper/AppInfoJsonVerifications.java | 106 +- .../webapp/helper/AppInfoXmlVerifications.java | 110 +- .../helper/JsonCustomResourceTypeTestcase.java | 4 +- .../helper/ResourceRequestsJsonVerifications.java | 105 +- .../helper/ResourceRequestsXmlVerifications.java | 79 +- .../helper/XmlCustomResourceTypeTestCase.java | 8 +- .../clientrm/FederationClientInterceptor.java | 16 +- .../rmadmin/FederationRMAdminInterceptor.java | 4 +- .../router/webapp/FederationInterceptorREST.java | 4 +- .../router/clientrm/BaseRouterClientRMTest.java | 4 +- .../webapp/MockDefaultRequestInterceptorREST.java | 2 +- .../webapp/TestFederationInterceptorREST.java | 2 +- .../hadoop/yarn/server/TestMiniYarnCluster.java | 8 +- .../AbstractTimelineReaderHBaseTestBase.java | 14 +- .../TestTimelineReaderWebServicesHBaseStorage.java | 83 +- .../storage/TestHBaseTimelineStorageApps.java | 94 +- .../storage/TestHBaseTimelineStorageDomain.java | 16 +- .../storage/TestHBaseTimelineStorageEntities.java | 99 +- .../storage/TestHBaseTimelineStorageSchema.java | 14 +- .../storage/TestTimelineReaderHBaseDown.java | 25 +- .../storage/TestTimelineWriterHBaseDown.java | 16 +- .../storage/flow/TestHBaseStorageFlowActivity.java | 18 +- .../storage/flow/TestHBaseStorageFlowRun.java | 18 +- .../flow/TestHBaseStorageFlowRunCompaction.java | 32 +- .../LICENSE-uriparser2.txt | 0 630 files changed, 17507 insertions(+), 15809 deletions(-) copy {hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn => hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop}/util/Clock.java (96%) copy {hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn => hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop}/util/MonotonicClock.java (95%) copy {hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn => hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop}/util/SystemClock.java (94%) copy {hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn => hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop}/util/UTCClock.java (97%) create mode 100644 hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/fairness/RouterAsyncRpcFairnessPolicyController.java copy hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/fairness/{TestRouterRpcFairnessPolicyController.java => TestRouterAsyncRpcFairnessPolicyController.java} (53%) create mode 100644 hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/async/TestRouterAsyncWebHdfsMethods.java delete mode 100644 hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/Clock.java delete mode 100644 hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/TestClock.java delete mode 100644 hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/TestAMLaunchFailure.java delete mode 100644 hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/TestASMStateMachine.java delete mode 100644 hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/TestApplicationMasterExpiry.java delete mode 100644 hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/TestSchedulerNegotiator.java copy hadoop-hdfs-project/hadoop-hdfs-native-client/src/main/native/libhdfspp/third_party/uriparser2/uriparser2/LICENSE => licenses-binary/LICENSE-uriparser2.txt (100%) --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org