[
https://issues.apache.org/jira/browse/HADOOP-17115?focusedWorklogId=597044&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-597044
]
ASF GitHub Bot logged work on HADOOP-17115:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 15/May/21 01:10
Start Date: 15/May/21 01:10
Worklog Time Spent: 10m
Work Description: hadoop-yetus commented on pull request #2985:
URL: https://github.com/apache/hadoop/pull/2985#issuecomment-841576817
:confetti_ball: **+1 overall**
| Vote | Subsystem | Runtime | Logfile | Comment |
|:----:|----------:|--------:|:--------:|:-------:|
| +0 :ok: | reexec | 0m 53s | | Docker mode activated. |
|||| _ Prechecks _ |
| +1 :green_heart: | dupname | 0m 1s | | No case conflicting files
found. |
| +0 :ok: | codespell | 0m 0s | | codespell was not available. |
| +1 :green_heart: | @author | 0m 0s | | The patch does not contain
any @author tags. |
| +1 :green_heart: | test4tests | 0m 0s | | The patch appears to
include 8 new or modified test files. |
|||| _ trunk Compile Tests _ |
| +0 :ok: | mvndep | 11m 10s | | Maven dependency ordering for branch |
| +1 :green_heart: | mvninstall | 22m 55s | | trunk passed |
| +1 :green_heart: | compile | 22m 34s | | trunk passed with JDK
Ubuntu-11.0.11+9-Ubuntu-0ubuntu2.20.04 |
| +1 :green_heart: | compile | 19m 5s | | trunk passed with JDK
Private Build-1.8.0_292-8u292-b10-0ubuntu1~20.04-b10 |
| +1 :green_heart: | checkstyle | 4m 1s | | trunk passed |
| +1 :green_heart: | mvnsite | 4m 40s | | trunk passed |
| +1 :green_heart: | javadoc | 3m 35s | | trunk passed with JDK
Ubuntu-11.0.11+9-Ubuntu-0ubuntu2.20.04 |
| +1 :green_heart: | javadoc | 4m 5s | | trunk passed with JDK
Private Build-1.8.0_292-8u292-b10-0ubuntu1~20.04-b10 |
| +1 :green_heart: | spotbugs | 7m 1s | | trunk passed |
| +1 :green_heart: | shadedclient | 16m 53s | | branch has no errors
when building and testing our client artifacts. |
|||| _ Patch Compile Tests _ |
| +0 :ok: | mvndep | 0m 20s | | Maven dependency ordering for patch |
| +1 :green_heart: | mvninstall | 3m 1s | | the patch passed |
| +1 :green_heart: | compile | 22m 1s | | the patch passed with JDK
Ubuntu-11.0.11+9-Ubuntu-0ubuntu2.20.04 |
| +1 :green_heart: | javac | 22m 1s | | the patch passed |
| +1 :green_heart: | compile | 19m 8s | | the patch passed with JDK
Private Build-1.8.0_292-8u292-b10-0ubuntu1~20.04-b10 |
| +1 :green_heart: | javac | 19m 8s | | the patch passed |
| +1 :green_heart: | blanks | 0m 0s | | The patch has no blanks
issues. |
| +1 :green_heart: | checkstyle | 4m 1s | | root: The patch generated
0 new + 81 unchanged - 1 fixed = 81 total (was 82) |
| +1 :green_heart: | mvnsite | 6m 1s | | the patch passed |
| +1 :green_heart: | xml | 0m 7s | | The patch has no ill-formed XML
file. |
| +1 :green_heart: | javadoc | 3m 35s | | the patch passed with JDK
Ubuntu-11.0.11+9-Ubuntu-0ubuntu2.20.04 |
| +1 :green_heart: | javadoc | 4m 7s | | the patch passed with JDK
Private Build-1.8.0_292-8u292-b10-0ubuntu1~20.04-b10 |
| +1 :green_heart: | spotbugs | 8m 25s | | the patch passed |
| +1 :green_heart: | shadedclient | 17m 27s | | patch has no errors
when building and testing our client artifacts. |
|||| _ Other Tests _ |
| +1 :green_heart: | unit | 17m 32s | | hadoop-common in the patch
passed. |
| +1 :green_heart: | unit | 3m 45s | | hadoop-kms in the patch passed.
|
| +1 :green_heart: | unit | 50m 20s | | hadoop-distcp in the patch
passed. |
| +1 :green_heart: | unit | 9m 49s | | hadoop-dynamometer-infra in the
patch passed. |
| +1 :green_heart: | unit | 11m 38s | | hadoop-dynamometer in the patch
passed. |
| +1 :green_heart: | unit | 3m 54s | | hadoop-aws in the patch passed.
|
| +1 :green_heart: | asflicense | 1m 32s | | The patch does not
generate ASF License warnings. |
| | | 307m 8s | | |
| Subsystem | Report/Notes |
|----------:|:-------------|
| Docker | ClientAPI=1.41 ServerAPI=1.41 base:
https://ci-hadoop.apache.org/job/hadoop-multibranch/job/PR-2985/35/artifact/out/Dockerfile
|
| GITHUB PR | https://github.com/apache/hadoop/pull/2985 |
| Optional Tests | dupname asflicense compile javac javadoc mvninstall
mvnsite unit shadedclient codespell xml spotbugs checkstyle |
| uname | Linux 453bb77bbc27 4.15.0-136-generic #140-Ubuntu SMP Thu Jan 28
05:20:47 UTC 2021 x86_64 x86_64 x86_64 GNU/Linux |
| Build tool | maven |
| Personality | dev-support/bin/hadoop.sh |
| git revision | trunk / 0005b922dd6808dd9860fdb8fb4eb01aee418e40 |
| Default Java | Private Build-1.8.0_292-8u292-b10-0ubuntu1~20.04-b10 |
| Multi-JDK versions |
/usr/lib/jvm/java-11-openjdk-amd64:Ubuntu-11.0.11+9-Ubuntu-0ubuntu2.20.04
/usr/lib/jvm/java-8-openjdk-amd64:Private
Build-1.8.0_292-8u292-b10-0ubuntu1~20.04-b10 |
| Test Results |
https://ci-hadoop.apache.org/job/hadoop-multibranch/job/PR-2985/35/testReport/ |
| Max. process+thread count | 3098 (vs. ulimit of 5500) |
| modules | C: hadoop-common-project/hadoop-common
hadoop-common-project/hadoop-kms hadoop-tools/hadoop-distcp
hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra
hadoop-tools/hadoop-dynamometer hadoop-tools/hadoop-aws U: . |
| Console output |
https://ci-hadoop.apache.org/job/hadoop-multibranch/job/PR-2985/35/console |
| versions | git=2.25.1 maven=3.6.3 spotbugs=4.2.2 |
| Powered by | Apache Yetus 0.14.0-SNAPSHOT https://yetus.apache.org |
This message was automatically generated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 597044)
Time Spent: 5h 50m (was: 5h 40m)
> Replace Guava Sets usage by Hadoop's own Sets
> ---------------------------------------------
>
> Key: HADOOP-17115
> URL: https://issues.apache.org/jira/browse/HADOOP-17115
> Project: Hadoop Common
> Issue Type: Sub-task
> Reporter: Ahmed Hussein
> Assignee: Viraj Jasani
> Priority: Major
> Labels: pull-request-available
> Time Spent: 5h 50m
> Remaining Estimate: 0h
>
> Unjustified usage of Guava API to initialize a {{HashSet}}. This should be
> replaced by Java APIs.
> {code:java}
> Targets
> Occurrences of 'Sets.newHashSet' in project
> Found Occurrences (223 usages found)
> org.apache.hadoop.crypto.key (2 usages found)
> TestValueQueue.java (2 usages found)
> testWarmUp() (2 usages found)
> 106 Assert.assertEquals(Sets.newHashSet("k1", "k2", "k3"),
> 107 Sets.newHashSet(fillInfos[0].key,
> org.apache.hadoop.crypto.key.kms (6 usages found)
> TestLoadBalancingKMSClientProvider.java (6 usages found)
> testCreation() (6 usages found)
> 86
> assertEquals(Sets.newHashSet("http://host1:9600/kms/foo/v1/";),
> 87 Sets.newHashSet(providers[0].getKMSUrl()));
> 95
> assertEquals(Sets.newHashSet("http://host1:9600/kms/foo/v1/";,
> 98 Sets.newHashSet(providers[0].getKMSUrl(),
> 108
> assertEquals(Sets.newHashSet("http://host1:9600/kms/foo/v1/";,
> 111 Sets.newHashSet(providers[0].getKMSUrl(),
> org.apache.hadoop.crypto.key.kms.server (1 usage found)
> KMSAudit.java (1 usage found)
> 59 static final Set<KMS.KMSOp> AGGREGATE_OPS_WHITELIST =
> Sets.newHashSet(
> org.apache.hadoop.fs.s3a (1 usage found)
> TestS3AAWSCredentialsProvider.java (1 usage found)
> testFallbackToDefaults() (1 usage found)
> 183 Sets.newHashSet());
> org.apache.hadoop.fs.s3a.auth (1 usage found)
> AssumedRoleCredentialProvider.java (1 usage found)
> AssumedRoleCredentialProvider(URI, Configuration) (1 usage found)
> 113 Sets.newHashSet(this.getClass()));
> org.apache.hadoop.fs.s3a.commit.integration (1 usage found)
> ITestS3ACommitterMRJob.java (1 usage found)
> test_200_execute() (1 usage found)
> 232 Set<String> expectedKeys = Sets.newHashSet();
> org.apache.hadoop.fs.s3a.commit.staging (5 usages found)
> TestStagingCommitter.java (3 usages found)
> testSingleTaskMultiFileCommit() (1 usage found)
> 341 Set<String> keys = Sets.newHashSet();
> runTasks(JobContext, int, int) (1 usage found)
> 603 Set<String> uploads = Sets.newHashSet();
> commitTask(StagingCommitter, TaskAttemptContext, int) (1 usage
> found)
> 640 Set<String> files = Sets.newHashSet();
> TestStagingPartitionedTaskCommit.java (2 usages found)
> verifyFilesCreated(PartitionedStagingCommitter) (1 usage found)
> 148 Set<String> files = Sets.newHashSet();
> buildExpectedList(StagingCommitter) (1 usage found)
> 188 Set<String> expected = Sets.newHashSet();
> org.apache.hadoop.hdfs (5 usages found)
> DFSUtil.java (2 usages found)
> getNNServiceRpcAddressesForCluster(Configuration) (1 usage found)
> 615 Set<String> availableNameServices = Sets.newHashSet(conf
> getNNLifelineRpcAddressesForCluster(Configuration) (1 usage
> found)
> 660 Set<String> availableNameServices = Sets.newHashSet(conf
> MiniDFSCluster.java (1 usage found)
> 597 private Set<FileSystem> fileSystems = Sets.newHashSet();
> TestDFSUtil.java (2 usages found)
> testGetNNServiceRpcAddressesForNsIds() (2 usages found)
> 1046 assertEquals(Sets.newHashSet("nn1"), internal);
> 1049 assertEquals(Sets.newHashSet("nn1", "nn2"), all);
> org.apache.hadoop.hdfs.net (5 usages found)
> TestDFSNetworkTopology.java (5 usages found)
> testChooseRandomWithStorageType() (4 usages found)
> 277 Sets.newHashSet("host2", "host4", "host5", "host6");
> 278 Set<String> archiveUnderL1 = Sets.newHashSet("host1",
> "host3");
> 279 Set<String> ramdiskUnderL1 = Sets.newHashSet("host7");
> 280 Set<String> ssdUnderL1 = Sets.newHashSet("host8");
> testChooseRandomWithStorageTypeWithExcluded() (1 usage found)
> 363 Set<String> expectedSet = Sets.newHashSet("host4",
> "host5");
> org.apache.hadoop.hdfs.qjournal.server (2 usages found)
> JournalNodeSyncer.java (2 usages found)
> getOtherJournalNodeAddrs() (1 usage found)
> 276 HashSet<String> sharedEditsUri = Sets.newHashSet();
> getJournalAddrList(String) (1 usage found)
> 318 Sets.newHashSet(jn.getBoundIpcAddress()));
> org.apache.hadoop.hdfs.server.datanode (5 usages found)
> BlockPoolManager.java (1 usage found)
> doRefreshNamenodes(Map<String, Map<String, InetSocketAddress>>,
> Map<String, Map<String, InetSocketAddress>>) (1 usage found)
> 198 toRemove = Sets.newHashSet(Sets.difference(
> BPOfferService.java (2 usages found)
> refreshNNList(String, List<String>, ArrayList<InetSocketAddress>,
> ArrayList<InetSocketAddress>) (2 usages found)
> 146 Set<InetSocketAddress> oldAddrs = Sets.newHashSet();
> 150 Set<InetSocketAddress> newAddrs = Sets.newHashSet(addrs);
> TestRefreshNamenodes.java (2 usages found)
> testRefreshNamenodes() (2 usages found)
> 74 Set<InetSocketAddress> nnAddrsFromCluster =
> Sets.newHashSet();
> 80 Set<InetSocketAddress> nnAddrsFromDN = Sets.newHashSet();
> org.apache.hadoop.hdfs.server.datanode.fsdataset.impl (1 usage found)
> FsDatasetImpl.java (1 usage found)
> getInitialVolumeFailureInfos(Collection<StorageLocation>,
> DataStorage) (1 usage found)
> 430 Set<StorageLocation> failedLocationSet =
> Sets.newHashSetWithExpectedSize(
> org.apache.hadoop.hdfs.server.namenode (11 usages found)
> FSImageTestUtil.java (2 usages found)
> assertFileContentsSame(File...) (1 usage found)
> 418 if (Sets.newHashSet(md5s.values()).size() > 1) {
> assertFileContentsDifferent(int, File...) (1 usage found)
> 435 if (Sets.newHashSet(md5s.values()).size() !=
> expectedUniqueHashes) {
> TestFsck.java (6 usages found)
> testFsckMove() (5 usages found)
> 388 new CorruptedTestFile(fileNames[0], Sets.newHashSet(0),
> 390 new CorruptedTestFile(fileNames[1], Sets.newHashSet(2, 3),
> 392 new CorruptedTestFile(fileNames[2], Sets.newHashSet(4),
> 394 new CorruptedTestFile(fileNames[3], Sets.newHashSet(0, 1,
> 2, 3),
> 396 new CorruptedTestFile(fileNames[4], Sets.newHashSet(1, 2,
> 3, 4),
> testFsckMoveAfterCorruption() (1 usage found)
> 2217 Sets.newHashSet(0), dfsClient, numDatanodes,
> dfsBlockSize);
> TestNameNodeRecovery.java (3 usages found)
> getValidTxIds() (1 usage found)
> 303 return Sets.newHashSet(0L);
> getValidTxIds() (1 usage found)
> 345 return Sets.newHashSet(0L);
> getValidTxIds() (1 usage found)
> 391 return Sets.newHashSet(1L , 2L, 3L, 5L, 6L, 7L, 8L, 9L,
> 10L);
> org.apache.hadoop.mapred (1 usage found)
> TestMRTimelineEventHandling.java (1 usage found)
> checkNewTimelineEvent(ApplicationId, ApplicationReport, String)
> (1 usage found)
> 302 Set<String> cfgsToCheck = Sets.newHashSet("dummy_conf1",
> "dummy_conf2",
> org.apache.hadoop.mapreduce.lib.input (2 usages found)
> TestFileInputFormat.java (2 usages found)
> verifyFileStatuses(List<Path>, List<FileStatus>, FileSystem) (1
> usage found)
> 408 Set<Path> expectedPathSet =
> Sets.newHashSet(fqExpectedPaths);
> verifySplits(List<String>, List<InputSplit>) (1 usage found)
> 426 Set<String> expectedSet = Sets.newHashSet(expected);
> org.apache.hadoop.mapreduce.v2.app.webapp (1 usage found)
> TestAMWebServices.java (1 usage found)
> configureServlets() (1 usage found)
> 78 appContext.setBlacklistedNodes(Sets.newHashSet("badnode1",
> "badnode2"));
> org.apache.hadoop.mapreduce.v2.hs.webapp (4 usages found)
> TestHsWebServicesLogs.java (4 usages found)
> testGetAggregatedLogsMetaForFinishedApp() (1 usage found)
> 302 Set<String> expectedIdStrings = Sets.newHashSet(
> testGetAggregatedLogsMetaForRunningApp() (1 usage found)
> 335 Set<String> expectedIdStrings = Sets.newHashSet(
> testGetAggregatedLogsMetaForFinishedAppAttempt() (1 usage found)
> 368 Set<String> expectedIdStrings = Sets.newHashSet(
> testGetAggregatedLogsMetaForRunningAppAttempt() (1 usage found)
> 401 Set<String> expectedIdStrings = Sets.newHashSet(
> org.apache.hadoop.metrics2.lib (2 usages found)
> MutableRates.java (1 usage found)
> 47 private final Set<Class<?>> protocolCache = Sets.newHashSet();
> MutableRatesWithAggregation.java (1 usage found)
> 55 private final Set<Class<?>> protocolCache = Sets.newHashSet();
> org.apache.hadoop.tools (2 usages found)
> CopyListing.java (2 usages found)
> validateFinalListing(Path, DistCpContext) (2 usages found)
> 166 Set<URI> aclSupportCheckFsSet = Sets.newHashSet();
> 167 Set<URI> xAttrSupportCheckFsSet = Sets.newHashSet();
> org.apache.hadoop.tools.dynamometer (3 usages found)
> TestDynamometerInfra.java (3 usages found)
> setupClass() (3 usages found)
> 272 Sets.newHashSet(NAMENODE_NODELABEL, DATANODE_NODELABEL));
> 275 Sets.newHashSet(NAMENODE_NODELABEL));
> 277 Sets.newHashSet(DATANODE_NODELABEL));
> org.apache.hadoop.yarn.api (1 usage found)
> BasePBImplRecordsTest.java (1 usage found)
> genTypeValue(Type) (1 usage found)
> 115 ret = Sets.newHashSet(genTypeValue(params[0]));
> org.apache.hadoop.yarn.api.protocolrecords.impl.pb (1 usage found)
> GetNodesToLabelsResponsePBImpl.java (1 usage found)
> initNodeToLabels() (1 usage found)
> 70 Sets.newHashSet(c.getNodeLabelsList()));
> org.apache.hadoop.yarn.api.resource (3 usages found)
> TestPlacementConstraintParser.java (3 usages found)
> testTargetExpressionParser() (1 usage found)
> 116 Set<TargetExpression> expectedTargetExpressions =
> Sets.newHashSet(
> testCardinalityConstraintParser() (1 usage found)
> 169 Set<TargetExpression> expectedTargetExpressions =
> Sets.newHashSet(
> testParseAllocationTagNameSpace() (1 usage found)
> 583 Set<TargetExpression> expectedTargetExpressions =
> Sets.newHashSet(
> org.apache.hadoop.yarn.client.cli (10 usages found)
> TestYarnCLI.java (10 usages found)
> testGetApplications() (10 usages found)
> 410 Sets.newHashSet("tag1", "tag3"), false,
> Priority.UNDEFINED, "", "");
> 421 null, Sets.newHashSet("tag2", "tag3"), false,
> Priority.UNDEFINED,
> 431 null, Sets.newHashSet("tag1", "tag4"), false,
> Priority.UNDEFINED,
> 441 "NON-MAPREDUCE", null, Sets.newHashSet("tag1"), false,
> 451 Sets.newHashSet("tag2", "tag4"), false,
> Priority.UNDEFINED, "", "");
> 756 Set<String> appTag1 = Sets.newHashSet("tag1");
> 829 Set<String> appType9 = Sets.newHashSet("YARN");
> 830 Set<String> appTag2 = Sets.newHashSet("tag3");
> 858 Set<String> appType10 = Sets.newHashSet("HIVE");
> 859 Set<String> appTag3 = Sets.newHashSet("tag4");
> org.apache.hadoop.yarn.logaggregation (1 usage found)
> AggregatedLogFormat.java (1 usage found)
> getFileCandidates(Set<File>, boolean) (1 usage found)
> 366 return Sets.newHashSet(mask);
> org.apache.hadoop.yarn.logaggregation.filecontroller (1 usage found)
> LogAggregationFileController.java (1 usage found)
> cleanOldLogs(Path, NodeId, UserGroupInformation) (1 usage found)
> 545 status = Sets.newHashSet(mask);
> org.apache.hadoop.yarn.logaggregation.filecontroller.ifile (1 usage
> found)
> LogAggregationIndexedFileController.java (1 usage found)
> parseCheckSumFiles(List<FileStatus>) (1 usage found)
> 718 status = Sets.newHashSet(mask);
> org.apache.hadoop.yarn.nodelabels (7 usages found)
> NodeLabelTestBase.java (1 usage found)
> toSet(E...) (1 usage found)
> 123 Set<E> set = Sets.newHashSet(elements);
> TestCommonNodeLabelsManager.java (6 usages found)
> testAddRemovelabel() (5 usages found)
> 65 verifyNodeLabelAdded(Sets.newHashSet("hello"),
> mgr.lastAddedlabels);
> 69 verifyNodeLabelAdded(Sets.newHashSet("hello1", "world1"),
> mgr.lastAddedlabels);
> 72 Sets.newHashSet("hello", "world", "hello1", "world1")));
> 103 assertCollectionEquals(Sets.newHashSet("hello"),
> mgr.lastRemovedlabels);
> 109
> Assert.assertTrue(mgr.lastRemovedlabels.containsAll(Sets.newHashSet(
> testAddlabelWithCase() (1 usage found)
> 118 verifyNodeLabelAdded(Sets.newHashSet("HeLlO"),
> mgr.lastAddedlabels);
> org.apache.hadoop.yarn.nodelabels.store.op (1 usage found)
> RemoveClusterLabelOp.java (1 usage found)
> write(OutputStream, CommonNodeLabelsManager) (1 usage found)
> 48
> .newInstance(Sets.newHashSet(labels.iterator()))).getProto()
> org.apache.hadoop.yarn.server.api.protocolrecords (1 usage found)
> TestProtocolRecords.java (1 usage found)
> testNodeHeartBeatRequest() (1 usage found)
> 185 Sets.newHashSet(NodeAttribute.newInstance("attributeA",
> org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb (1 usage found)
> ReplaceLabelsOnNodeRequestPBImpl.java (1 usage found)
> initNodeToLabels() (1 usage found)
> 66 Sets.newHashSet(c.getNodeLabelsList()));
> org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer (2
> usages found)
> TestResourceLocalizationService.java (2 usages found)
> doLocalization(ResourceLocalizationService, DrainDispatcher,
> DummyExecutor, DeletionService) (1 usage found)
> 1400 Sets.newHashSet(new Path(locPath1), new Path(locPath1 +
> "_tmp"),
> doLocalizationAfterCleanup(ResourceLocalizationService,
> DrainDispatcher, DummyExecutor, DeletionService) (1 usage found)
> 1547 Sets.newHashSet(new Path(locPath1), new Path(locPath1 +
> "_tmp"),
> org.apache.hadoop.yarn.server.nodemanager.containermanager.logaggregation
> (1 usage found)
> AppLogAggregatorImpl.java (1 usage found)
> doContainerLogAggregation(LogAggregationFileController, boolean,
> boolean) (1 usage found)
> 674 this.uploadedFileMeta = Sets.newHashSet(mask);
>
> org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nec
> (1 usage found)
> TestNECVEPlugin.java (1 usage found)
> testFindDevicesWithUdev() (1 usage found)
> 388 .thenReturn(Sets.newHashSet(testDevice));
>
> org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga
> (1 usage found)
> FpgaDiscoverer.java (1 usage found)
> discover() (1 usage found)
> 123 Set<String> minors = Sets.newHashSet(allowed.split(","));
>
> org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.gpu
> (1 usage found)
> GpuDiscoverer.java (1 usage found)
> lookupBinaryInDefaultDirsInternal() (1 usage found)
> 328 Set<String> triedBinaryPaths = Sets.newHashSet();
> org.apache.hadoop.yarn.server.resourcemanager (5 usages found)
> TestAppManager.java (1 usage found)
> testEscapeApplicationSummary() (1 usage found)
> 977
> when(app.getApplicationTags()).thenReturn(Sets.newHashSet("tag2", "tag1"));
> TestClientRMService.java (3 usages found)
> testGetApplications() (3 usages found)
> 1442 tagSet = Sets.newHashSet(tags.get(0));
> 1447 tagSet = Sets.newHashSet(tags.get(1));
> 1452 tagSet = Sets.newHashSet(tags.get(2));
> TestRMRestart.java (1 usage found)
> toSet(E...) (1 usage found)
> 2587 Set<E> set = Sets.newHashSet(elements);
> org.apache.hadoop.yarn.server.resourcemanager.nodelabels (11 usages
> found)
> TestNodeAttributesManager.java (11 usages found)
> testAddNodeAttributes() (2 usages found)
> 132 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[0]));
> 138
> .getClusterNodeAttributes(Sets.newHashSet("non_exist_prefix"));
> testRemoveNodeAttributes() (4 usages found)
> 219 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[0]));
> 222 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[1]));
> 225 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[2]));
> 263 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[0]));
> testReplaceNodeAttributes() (5 usages found)
> 299 Sets.newHashSet(NodeAttribute.PREFIX_DISTRIBUTED,
> PREFIXES[0]));
> 313 Sets.newHashSet(NodeAttribute.PREFIX_DISTRIBUTED,
> PREFIXES[0]));
> 340 Sets.newHashSet(NodeAttribute.PREFIX_DISTRIBUTED));
> 357 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[1]));
> 360 .getClusterNodeAttributes(Sets.newHashSet(
> org.apache.hadoop.yarn.server.resourcemanager.scheduler (5 usages found)
> TestAbstractYarnScheduler.java (3 usages found)
> testContainerReleaseWithAllocationTags() (2 usages found)
> 469 Sets.newHashSet(testTag1),
> 477 Sets.newHashSet(testTag2),
> testNodeRemovedWithAllocationTags() (1 usage found)
> 578 Sets.newHashSet(testTag1),
> TestSchedulerUtils.java (2 usages found)
> testValidateResourceRequestWithErrorLabelsPermission() (1 usage
> found)
> 246 Set<String> queueAccessibleNodeLabels = Sets.newHashSet();
> testNormalizeNodeLabelExpression() (1 usage found)
> 795 Set<String> queueAccessibleNodeLabels = Sets.newHashSet();
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity (8
> usages found)
> CapacitySchedulerTestBase.java (1 usage found)
> toSet(E...) (1 usage found)
> 56 Set<E> set = Sets.newHashSet(elements);
> TestApplicationLimits.java (1 usage found)
> toSet(String...) (1 usage found)
> 790 Set<String> set = Sets.newHashSet(elements);
> TestCapacityScheduler.java (1 usage found)
> testParseQueueWithAbsoluteResource() (1 usage found)
> 1042 Sets.newHashSet(labelName));
> TestCapacitySchedulerMaxParallelApps.java (1 usage found)
> executeCommonStepsAndChecks() (1 usage found)
> 200 Sets.newHashSet(
> TestCapacitySchedulerNodeLabelUpdate.java (1 usage found)
> toSet(String...) (1 usage found)
> 144 Set<String> set = Sets.newHashSet(elements);
> TestNodeLabelContainerAllocation.java (1 usage found)
> toSet(E...) (1 usage found)
> 157 Set<E> set = Sets.newHashSet(elements);
> TestUtils.java (1 usage found)
> toSet(E...) (1 usage found)
> 262 Set<E> set = Sets.newHashSet(elements);
> TestWorkPreservingRMRestartForNodeLabel.java (1 usage found)
> toSet(E...) (1 usage found)
> 77 Set<E> set = Sets.newHashSet(elements);
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.constraint (3
> usages found)
> TestPlacementConstraintManagerService.java (3 usages found)
> testGetRequestConstraint() (3 usages found)
> 209 Sets.newHashSet("not_exist_tag"), null);
> 228 Sets.newHashSet(sourceTag1), null);
> 256 Sets.newHashSet(sourceTag1), c1);
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair (2 usages
> found)
> TestFairScheduler.java (1 usage found)
> testGetAppsInQueue() (1 usage found)
> 4455 Set<ApplicationAttemptId> appAttIds =
> Sets.newHashSet(apps.get(0), apps.get(1));
> TestQueueManager.java (1 usage found)
> updateConfiguredLeafQueues(QueueManager, String...) (1 usage
> found)
> 185 .addAll(Sets.newHashSet(confLeafQueues));
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.allocation
> (1 usage found)
> AllocationFileParser.java (1 usage found)
> 81 Sets.newHashSet(QUEUE_MAX_RESOURCES_DEFAULT,
> USER_MAX_APPS_DEFAULT,
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.converter
> (8 usages found)
> TestFSQueueConverter.java (8 usages found)
> testConvertQueueHierarchy() (1 usage found)
> 168 Sets.newHashSet("root",
> testQueueMaxAMShare() (1 usage found)
> 192 Sets.newHashSet("root.admins.bob", "root.admins.alice"));
> testQueueMaxParallelApps() (1 usage found)
> 208 Sets.newHashSet("root.admins.alice"));
> testQueueMaxAllocations() (1 usage found)
> 232 Sets.newHashSet("root.admins", "root.users.john"));
> testQueuePreemptionDisabled() (1 usage found)
> 251 Sets.newHashSet("root.admins.alice", "root.users.joe"));
> testQueueAutoCreateChildQueue() (2 usages found)
> 319 Set<String> parentQueues = Sets.newHashSet(
> 323 Set<String> leafQueues = Sets.newHashSet(
> 64 Sets.newHashSet("root",
> org.apache.hadoop.yarn.server.resourcemanager.webapp (25 usages found)
> ApplicationsRequestBuilder.java (5 usages found)
> 34 private Set<String> statesQuery = Sets.newHashSet();
> 35 private Set<String> users = Sets.newHashSetWithExpectedSize(1);
> 36 private Set<String> queues =
> Sets.newHashSetWithExpectedSize(1);
> 45 private Set<String> appTypes = Sets.newHashSet();
> 46 private Set<String> appTags = Sets.newHashSet();
> RMWebAppFilter.java (1 usage found)
> 71 private static final Set<String> NON_REDIRECTED_URIS =
> Sets.newHashSet(
> TestApplicationsRequestBuilder.java (16 usages found)
> testRequestWithValidStateQuery() (1 usage found)
> 86
> Sets.newHashSet(YarnApplicationState.NEW_SAVING.toString());
> testRequestWithEmptyStateQueries() (1 usage found)
> 96 .withStatesQuery(Sets.newHashSet()).build();
> testRequestWithInvalidStateQueries() (1 usage found)
> 106 .withStatesQuery(Sets.newHashSet("a1", "a2", "")).build();
> testRequestWithValidStateQueries() (2 usages found)
> 127
> Sets.newHashSet(YarnApplicationState.NEW_SAVING.toString(),
> 133
> Sets.newHashSet(YarnApplicationState.NEW_SAVING.toString(),
> testRequestWithUserQuery() (1 usage found)
> 165 expectedRequest.setUsers(Sets.newHashSet("user1"));
> testRequestWithQueueQueryExistingQueue() (1 usage found)
> 196 expectedRequest.setQueues(Sets.newHashSet("queue1"));
> testRequestWithQueueQueryNotExistingQueue() (1 usage found)
> 212 expectedRequest.setQueues(Sets.newHashSet("queue1"));
> testRequestWithEmptyApplicationTypesQuery() (2 usages found)
> 487 .withApplicationTypes(Sets.newHashSet()).build();
> 490 expectedRequest.setApplicationTypes(Sets.newHashSet());
> testRequestWithValidApplicationTypesQuery() (2 usages found)
> 497 .withApplicationTypes(Sets.newHashSet("type1")).build();
> 500
> expectedRequest.setApplicationTypes(Sets.newHashSet("type1"));
> testRequestWithEmptyApplicationTagsQuery() (2 usages found)
> 513 .withApplicationTags(Sets.newHashSet()).build();
> 516 expectedRequest.setApplicationTags(Sets.newHashSet());
> testRequestWithValidApplicationTagsQuery() (2 usages found)
> 523 .withApplicationTags(Sets.newHashSet("tag1")).build();
> 526
> expectedRequest.setApplicationTags(Sets.newHashSet("tag1"));
> TestRMWebServiceAppsNodelabel.java (1 usage found)
> toSet(E...) (1 usage found)
> 242 Set<E> set = Sets.newHashSet(elements);
> TestRMWebServicesApps.java (1 usage found)
> getApplicationIds(JSONArray) (1 usage found)
> 107 Set<String> ids = Sets.newHashSet();
> TestRMWebServicesForCSWithPartitions.java (1 usage found)
> testPartitionInSchedulerActivities() (1 usage found)
> 273 .of(NodeId.newInstance("127.0.0.1", 0),
> Sets.newHashSet(LABEL_LX)));
> org.apache.hadoop.yarn.server.resourcemanager.webapp.fairscheduler (4
> usages found)
> FairSchedulerJsonVerifications.java (2 usages found)
> FairSchedulerJsonVerifications(List<String>) (1 usage found)
> 49 this.customResourceTypes =
> Sets.newHashSet(customResourceTypes);
> 42 Sets.newHashSet("minResources", "amUsedResources",
> "amMaxResources",
> FairSchedulerXmlVerifications.java (2 usages found)
> FairSchedulerXmlVerifications(List<String>) (1 usage found)
> 53 this.customResourceTypes =
> Sets.newHashSet(customResourceTypes);
> 46 private static final Set<String> RESOURCE_FIELDS =
> Sets.newHashSet(
> org.apache.hadoop.yarn.server.resourcemanager.webapp.helper (1 usage
> found)
> ResourceRequestsXmlVerifications.java (1 usage found)
> extractActualCustomResourceType(Element, List<String>) (1 usage
> found)
> 85 Sets.newHashSet(expectedResourceTypes));
> org.apache.hadoop.yarn.server.timeline (3 usages found)
> EntityGroupPlugInForTest.java (3 usages found)
> getTimelineEntityGroupId(String, NameValuePair,
> Collection<NameValuePair>) (1 usage found)
> 39 return Sets.newHashSet(getStandardTimelineGroupId(appId));
> getTimelineEntityGroupId(String, String) (1 usage found)
> 47 return Sets.newHashSet(getStandardTimelineGroupId(appId));
> getTimelineEntityGroupId(String, SortedSet<String>, Set<String>)
> (1 usage found)
> 54 return Sets.newHashSet();
> org.apache.hadoop.yarn.server.timelineservice.collector (1 usage found)
> TestTimelineCollector.java (1 usage found)
> testClearPreviousEntitiesOnAggregation() (1 usage found)
> 306 assertEquals(Sets.newHashSet("type"),
> aggregationGroups.keySet());
>
> org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb
> (1 usage found)
> CosmosDBDocumentStoreReader.java (1 usage found)
> fetchEntityTypes(String, TimelineReaderContext) (1 usage found)
> 118 return Sets.newHashSet(client.queryDocuments(
> org.apache.hadoop.yarn.server.timelineservice.reader (38 usages found)
> TestTimelineReaderWebServicesHBaseStorage.java (16 usages found)
> loadData() (16 usages found)
> 266 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 267 isRelatedTo1.put("type4", Sets.newHashSet("entity41",
> "entity42"));
> 268 isRelatedTo1.put("type1", Sets.newHashSet("entity14",
> "entity15"));
> 270 Sets.newHashSet("entity31", "entity35", "entity32",
> "entity33"));
> 274 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 275 relatesTo1.put("type4", Sets.newHashSet("entity41",
> "entity42"));
> 276 relatesTo1.put("type1", Sets.newHashSet("entity14",
> "entity15"));
> 278 Sets.newHashSet("entity31", "entity35", "entity32",
> "entity33"));
> 327 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 328 isRelatedTo2.put("type5", Sets.newHashSet("entity51",
> "entity52"));
> 329 isRelatedTo2.put("type6", Sets.newHashSet("entity61",
> "entity66"));
> 330 isRelatedTo2.put("type3", Sets.newHashSet("entity31"));
> 334 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 335 relatesTo2.put("type5", Sets.newHashSet("entity51",
> "entity52"));
> 336 relatesTo2.put("type6", Sets.newHashSet("entity61",
> "entity66"));
> 337 relatesTo2.put("type3", Sets.newHashSet("entity31"));
> TestTimelineReaderWebServicesUtils.java (22 usages found)
> testRelationFiltersParsing() (22 usages found)
> 721 "type1", Sets.newHashSet((Object)"entity11")),
> 723 "type2", Sets.newHashSet((Object)"entity21", "entity22"))
> 737 "type1", Sets.newHashSet((Object)"entity11")),
> 739 "type2", Sets.newHashSet((Object)"entity21", "entity22"))
> 743 "type3", Sets.newHashSet(
> 746 "type1", Sets.newHashSet((Object)"entity11", "entity12"))
> 758 "type1", Sets.newHashSet((Object)"entity11")),
> 760 "type2", Sets.newHashSet((Object)"entity21", "entity22")),
> 762 "type5", Sets.newHashSet((Object)"entity51"))
> 766 "type3", Sets.newHashSet(
> 769 "type1", Sets.newHashSet((Object)"entity11", "entity12"))
> 784 "type1", Sets.newHashSet((Object)"entity11")),
> 786 "type2", Sets.newHashSet(
> 789 "type5", Sets.newHashSet((Object)"entity51"))
> 793 "type3", Sets.newHashSet(
> 796 "type1", Sets.newHashSet(
> 803 "type11", Sets.newHashSet((Object)"entity111"))
> 807 "type4", Sets.newHashSet((Object)"entity43", "entity44",
> 810 "type7", Sets.newHashSet((Object)"entity71"))
> 817 "type2", Sets.newHashSet((Object)"entity2")),
> 819 "type8", Sets.newHashSet((Object)"entity88"))
> 822 Sets.newHashSet((Object)"e", "e1"))
> org.apache.hadoop.yarn.service (1 usage found)
> TestApiServer.java (1 usage found)
> testUpgradeSingleInstance() (1 usage found)
> 533 mockServerClient.setExpectedInstances(Sets.newHashSet(
> org.apache.hadoop.yarn.service.utils (2 usages found)
> ServiceApiUtil.java (2 usages found)
> validateAndResolveCompsUpgrade(Service, Collection<String>) (1
> usage found)
> 625 HashSet<String> requestedComps =
> Sets.newHashSet(compNames);
> validateAndResolveCompsStable(Service, Collection<String>) (1
> usage found)
> 651 HashSet<String> requestedComps =
> Sets.newHashSet(compNames);
> org.apache.hadoop.yarn.service.webapp (1 usage found)
> ApiServer.java (1 usage found)
> updateComponent(HttpServletRequest, String, String, Component)
> (1 usage found)
> 374 Sets.newHashSet(componentName));
> org.apache.hadoop.yarn.webapp.hamlet (2 usages found)
> HamletGen.java (2 usages found)
> 67 final Set<String> endTagOptional = Sets.newHashSet();
> 68 final Set<String> inlineElements = Sets.newHashSet();
> org.apache.hadoop.yarn.webapp.hamlet2 (2 usages found)
> HamletGen.java (2 usages found)
> 65 final Set<String> endTagOptional = Sets.newHashSet();
> 66 final Set<String> inlineElements = Sets.newHashSet();
> patches (4 usages found)
> HADOOP-17101.001.patch (2 usages found)
> 226 Set<Path> expectedPathSet =
> Sets.newHashSet(fqExpectedPaths);
> 244 Set<String> expectedSet = Sets.newHashSet(expected);
> HADOOP-17101.002.patch (2 usages found)
> 456 Set<Path> expectedPathSet =
> Sets.newHashSet(fqExpectedPaths);
> 474 Set<String> expectedSet = Sets.newHashSet(expected);
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-issues-h...@hadoop.apache.org
