Apache Hadoop
This report summarizes scanner evidence for apache/hadoop, a Java project with 15,704 GitHub stars. SynthScan examined 4,046,170 lines of code across 15525 source files, recording 1940 pattern matches distributed across 15 syntactic categories. The legacy adjusted pattern signal is 1.7 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 1383 finding(s).
Are imports declared and package/API names verified? 507 finding(s).
Are wrappers, guards, and repeated structures necessary? 95 finding(s).
Which changes need focused human review? 1940 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 1940 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …n/applications/distributedshell/ApplicationMaster.java | 1779 | new org.apache.hadoop.yarn.api.records.timelineservice.TimelineEvent(); | CODE |
| CRITICAL | …n/applications/distributedshell/ApplicationMaster.java | 1865 | new org.apache.hadoop.yarn.api.records.timelineservice.TimelineEvent(); | CODE |
| CRITICAL | …n/applications/distributedshell/ApplicationMaster.java | 1903 | new org.apache.hadoop.yarn.api.records.timelineservice.TimelineEvent(); | CODE |
| CRITICAL | …vice/timelineservice/TestServiceTimelinePublisher.java | 226 | new org.apache.hadoop.yarn.service.api.records.Configuration()); | CODE |
| CRITICAL | …vice/timelineservice/TestServiceTimelinePublisher.java | 246 | new org.apache.hadoop.yarn.service.api.records.Configuration()); | CODE |
| CRITICAL | …apache/hadoop/yarn/service/provider/ProviderUtils.java | 469 | org.apache.commons.io.IOUtils.write(content, output, StandardCharsets.UTF_8); | CODE |
| CRITICAL | …rg/apache/hadoop/yarn/service/component/Component.java | 760 | org.apache.hadoop.yarn.api.records.ResourceInformation.newInstance( | CODE |
| CRITICAL | …yarn/service/component/instance/ComponentInstance.java | 217 | new org.apache.hadoop.yarn.service.api.records.Container(); | CODE |
| CRITICAL | …org/apache/hadoop/yarn/service/utils/ServiceUtils.java | 518 | org.apache.commons.io.IOUtils.copy(in, taos); | CODE |
| CRITICAL | …ineservice/collector/NodeTimelineCollectorManager.java | 234 | return org.apache.hadoop.yarn.api.records.Token.newInstance( | CODE |
| CRITICAL | …he/hadoop/yarn/server/resourcemanager/Application.java | 292 | org.apache.hadoop.yarn.server.utils.BuilderUtils.newResourceRequest( | CODE |
| CRITICAL | …p/yarn/server/resourcemanager/TestResourceManager.java | 97 | new org.apache.hadoop.yarn.server.resourcemanager.NodeManager( | CODE |
| CRITICAL | …he/hadoop/yarn/server/resourcemanager/NodeManager.java | 160 | org.apache.hadoop.yarn.server.resourcemanager.NodeManager.createNodeStatus( | CODE |
| CRITICAL | …e/hadoop/yarn/server/resourcemanager/AdminService.java | 275 | org.apache.hadoop.ipc.Server.getRemoteAddress() + | CODE |
| CRITICAL | …e/hadoop/yarn/server/resourcemanager/AdminService.java | 284 | org.apache.hadoop.ipc.Server.getRemoteAddress() + " denied " + | CODE |
| CRITICAL | …adoop/yarn/server/resourcemanager/ClientRMService.java | 769 | if (!org.apache.commons.lang3.StringUtils.isAsciiPrintable(tag)) { | CODE |
| CRITICAL | …n/server/resourcemanager/webapp/RMAppAttemptBlock.java | 489 | org.apache.hadoop.util.StringUtils.formatTime(Times.elapsed( | CODE |
| CRITICAL | …resourcemanager/placement/QueuePlacementRuleUtils.java | 127 | if (!org.apache.commons.lang3.StringUtils.isEmpty(mapping.getParentQueue())) { | CODE |
| CRITICAL | …a/org/apache/hadoop/yarn/TestYarnServerApiClasses.java | 428 | org.apache.hadoop.yarn.api.records.Token.newInstance(new byte[0], | CODE |
| CRITICAL | …oop/yarn/server/util/timeline/TimelineServerUtils.java | 72 | org.apache.commons.lang3.StringUtils.join(target, ","); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1572 | org.apache.commons.lang3.StringUtils.repeat("A", 1024))); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1574 | org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1578 | org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1587 | org.apache.commons.lang3.StringUtils.repeat("A", 1024), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1588 | org.apache.commons.lang3.StringUtils.repeat("A", 1024), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1589 | org.apache.commons.lang3.StringUtils.repeat("A", 1024))); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1593 | org.apache.commons.lang3.StringUtils.repeat("E", 4095), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1594 | org.apache.commons.lang3.StringUtils.repeat("E", 2047), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1595 | org.apache.commons.lang3.StringUtils.repeat("E", 2047 - callCmd.length()))); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1599 | org.apache.commons.lang3.StringUtils.repeat("X", 4095), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1600 | org.apache.commons.lang3.StringUtils.repeat("X", 2047), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1601 | org.apache.commons.lang3.StringUtils.repeat("X", 2048 - callCmd.length()))); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1620 | builder.env("somekey", org.apache.commons.lang3.StringUtils.repeat("A", 1024)); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1621 | builder.env("somekey", org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1624 | builder.env("somekey", org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1646 | builder.mkdir(new Path(org.apache.commons.lang3.StringUtils.repeat("A", 1024))); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1647 | builder.mkdir(new Path(org.apache.commons.lang3.StringUtils.repeat("E", | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1650 | builder.mkdir(new Path(org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1671 | builder.link(new Path(org.apache.commons.lang3.StringUtils.repeat("A", 1024)), | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1672 | new Path(org.apache.commons.lang3.StringUtils.repeat("B", 1024))); | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1674 | new Path(org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1676 | new Path(org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1680 | new Path(org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL⚡ | …ger/containermanager/launcher/TestContainerLaunch.java | 1682 | new Path(org.apache.commons.lang3.StringUtils.repeat( | CODE |
| CRITICAL | …server/nodemanager/WindowsSecureContainerExecutor.java | 337 | org.apache.hadoop.util.StringUtils.stringifyException(e))); | CODE |
| CRITICAL | …server/nodemanager/WindowsSecureContainerExecutor.java | 713 | org.apache.hadoop.util.StringUtils.stringifyException(e))); | CODE |
| CRITICAL | …nodemanager/containermanager/ContainerManagerImpl.java | 1417 | org.apache.hadoop.yarn.api.records.Container.newInstance( | CODE |
| CRITICAL | …in/resources/webapps/static/jquery/jquery-3.6.0.min.js | 2 | !function(e,t){"use strict";"object"==typeof module&&"object"==typeof module.exports?module.exports=e.document?t(e,!0):f | CODE |
| CRITICAL | …s/webapps/static/jquery/jquery-ui-1.13.2.custom.min.js | 6 | !function(t){"use strict";"function"==typeof define&&define.amd?define(["jquery"],t):t(jQuery)}(function(V){"use strict" | CODE |
| CRITICAL | …rg/apache/hadoop/yarn/util/ProcfsBasedProcessTree.java | 812 | org.apache.hadoop.io.IOUtils.closeStream(in); | CODE |
| CRITICAL | …hadoop/yarn/util/Log4jWarningErrorMetricsAppender.java | 156 | org.apache.commons.lang3.StringUtils.left(message, MAX_MESSAGE_SIZE); | CODE |
| CRITICAL | …/yarn/security/client/RMDelegationTokenIdentifier.java | 168 | return org.apache.hadoop.yarn.api.records.Token.newInstance( | CODE |
| CRITICAL | …rg/apache/hadoop/yarn/logaggregation/LogToolUtils.java | 101 | org.apache.hadoop.io.IOUtils.skipFully(fis, toSkip); | CODE |
| CRITICAL | …rg/apache/hadoop/yarn/logaggregation/LogToolUtils.java | 129 | org.apache.hadoop.io.IOUtils.skipFully(fis, skipAfterRead); | CODE |
| CRITICAL | …he/hadoop/yarn/logaggregation/AggregatedLogFormat.java | 842 | org.apache.hadoop.io.IOUtils.skipFully( | CODE |
| CRITICAL | …he/hadoop/yarn/logaggregation/AggregatedLogFormat.java | 865 | org.apache.hadoop.io.IOUtils.skipFully( | CODE |
| CRITICAL | …he/hadoop/yarn/logaggregation/AggregatedLogFormat.java | 973 | org.apache.hadoop.io.IOUtils.skipFully( | CODE |
| CRITICAL | …he/hadoop/yarn/logaggregation/AggregatedLogFormat.java | 994 | org.apache.hadoop.io.IOUtils.skipFully( | CODE |
| CRITICAL | …in/java/org/apache/hadoop/yarn/client/cli/NodeCLI.java | 131 | org.apache.hadoop.util.StringUtils.toUpperCase( | CODE |
| CRITICAL | …apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java | 149 | new org.apache.hadoop.yarn.api.records.ResourceRequest.ResourceRequestComparator()); | CODE |
| 418 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | start-build-env.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …applications-distributedshell/src/test/resources/b.txt | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); | COMMENT |
| LOW | …applications-distributedshell/src/test/resources/a.txt | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); | COMMENT |
| LOW | …/yarn/applications/distributedshell/PlacementSpec.java | 61 | */ | COMMENT |
| LOW | …apache/hadoop/yarn/service/TestYarnNativeServices.java | 721 | } | COMMENT |
| LOW | …inition/YARN-Simplified-V1-API-Layer-For-Services.yaml | 1 | # Hadoop YARN REST APIs for services v1 spec in YAML | COMMENT |
| LOW | …cations-catalog-docker/src/main/scripts/setup-image.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ications-catalog-docker/src/main/scripts/entrypoint.sh | 1 | #!/bin/bash -x | COMMENT |
| LOW | …ources/configsets/exampleCollection/conf/protwords.txt | 1 | # The ASF licenses this file to You under the Apache License, Version 2.0 | COMMENT |
| LOW | …sources/configsets/exampleCollection/conf/synonyms.txt | 1 | # The ASF licenses this file to You under the Apache License, Version 2.0 | COMMENT |
| LOW | …ources/configsets/exampleCollection/conf/stopwords.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …onfigsets/exampleCollection/conf/lang/stopwords_en.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | hadoop-yarn-project/hadoop-yarn/bin/yarn-daemon.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | hadoop-yarn-project/hadoop-yarn/bin/yarn-daemons.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | hadoop-yarn-project/hadoop-yarn/bin/start-yarn.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | hadoop-yarn-project/hadoop-yarn/bin/stop-yarn.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | hadoop-yarn-project/hadoop-yarn/bin/yarn-config.sh | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …arn/server/resourcemanager/TestApplicationCleanup.java | 441 | COMMENT | |
| LOW | …emanager/scheduler/capacity/TestApplicationLimits.java | 961 | // can be used for AMs is 30%. So, 30% of <memory: 100GB, vCores: 1000> is | COMMENT |
| LOW | …/resourcemanager/scheduler/capacity/TestLeafQueue.java | 3921 | COMMENT | |
| LOW | …/resourcemanager/scheduler/capacity/TestLeafQueue.java | 3961 | // ANY: < 1, 1GB, 1, false > | COMMENT |
| LOW | …/resourcemanager/scheduler/capacity/TestLeafQueue.java | 3981 | Collections.singletonList(rack_1), Collections.singletonList(host_1_1)); | COMMENT |
| LOW | …/resourcemanager/scheduler/capacity/TestLeafQueue.java | 4041 | app_0_requests_0.add( | COMMENT |
| LOW | …ager/scheduler/capacity/TestCapacitySchedulerPerf.java | 101 | return retVal; | COMMENT |
| LOW | …ySchedulerNewQueueAutoCreationWithCapacityVectors.java | 121 | COMMENT | |
| LOW | …esourcemanager/nodelabels/TestRMNodeLabelsManager.java | 201 | isEqualTo(Resources.multiply(SMALL_RESOURCE, 1)); | COMMENT |
| LOW | …ourcemanager/nodelabels/TestNodeAttributesManager.java | 181 | // A2=host1_v1_2 | COMMENT |
| LOW | …oop/yarn/server/resourcemanager/rmnode/RMNodeImpl.java | 1381 | rmNode, statusEvent); | COMMENT |
| LOW | …r/monitor/capacity/FifoIntraQueuePreemptionPlugin.java | 521 | COMMENT | |
| LOW | …r/resourcemanager/scheduler/capacity/UsersManager.java | 781 | // - maxUserLimit = total-partition-resource (IGNORE_PARTITION_EXCLUSIVITY) | COMMENT |
| LOW | …esourcemanager/scheduler/capacity/AbstractCSQueue.java | 801 | readLock.lock(); | COMMENT |
| LOW | …uler/capacity/allocator/RegularContainerAllocator.java | 601 | // some containers to meet this queue, its parents', or the users' | COMMENT |
| LOW | …n/server/resourcemanager/reservation/InMemoryPlan.java | 641 | long periodicSearchEnd = (endTime - shift) % period; | COMMENT |
| LOW | …erver/resourcemanager/rmcontainer/RMContainerImpl.java | 641 | Resource rmContainerResource = container.getAllocatedResource(); | COMMENT |
| LOW | …erver/resourcemanager/rmcontainer/RMContainerImpl.java | 661 | // 4. When NM reports 5G to RM, RM now sees its own allocation as 4G | COMMENT |
| LOW | …ver/federation/store/impl/SQLFederationStateStore.java | 1301 | try { | COMMENT |
| LOW | …ver/federation/store/impl/SQLFederationStateStore.java | 1581 | COMMENT | |
| LOW | …rver/hadoop-yarn-server-nodemanager/src/CMakeLists.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …n/server/nodemanager/TestDefaultContainerExecutor.java | 661 | COMMENT | |
| LOW | …n/server/nodemanager/TestDefaultContainerExecutor.java | 681 | // } | COMMENT |
| LOW | …n/server/nodemanager/TestDefaultContainerExecutor.java | 701 | // r.setSeed(jobSeed); | COMMENT |
| LOW | …n/server/nodemanager/TestDefaultContainerExecutor.java | 721 | // DefaultContainerExecutor dce = new DefaultContainerExecutor(lfs); | COMMENT |
| LOW | …n/server/nodemanager/TestDefaultContainerExecutor.java | 741 | // verify(spylfs).mkdir(jobdir, | COMMENT |
| LOW | …in/native/container-executor/impl/container-executor.c | 21 | #include "utils/docker-util.h" | COMMENT |
| LOW | …in/native/container-executor/impl/container-executor.c | 41 | #include <stdio.h> | COMMENT |
| LOW | …in/native/container-executor/impl/container-executor.c | 61 | #ifndef HAVE_FDOPENDIR | COMMENT |
| LOW | …rc/main/native/container-executor/impl/configuration.h | 21 | COMMENT | |
| LOW | …in/native/container-executor/impl/container-executor.h | 61 | #define USER_DIR_PATTERN "%s/usercache/%s" | COMMENT |
| LOW | …manager/src/main/native/container-executor/impl/main.c | 21 | #include "container-executor.h" | COMMENT |
| LOW | …rc/main/native/container-executor/impl/configuration.c | 21 | COMMENT | |
| LOW | …ain/native/container-executor/impl/utils/docker-util.c | 21 | #include <sys/wait.h> | COMMENT |
| LOW | …main/native/container-executor/impl/utils/file-utils.c | 21 | #include <sys/types.h> | COMMENT |
| LOW | …ain/native/container-executor/impl/utils/docker-util.h | 21 | COMMENT | |
| LOW | …ain/native/container-executor/impl/utils/cJSON/cJSON.h | 61 | #endif | COMMENT |
| LOW | …ain/native/container-executor/impl/utils/cJSON/cJSON.h | 81 | /* project version */ | COMMENT |
| LOW | …ain/native/container-executor/impl/utils/cJSON/cJSON.c | 21 | */ | COMMENT |
| LOW | …ain/native/container-executor/impl/utils/cJSON/cJSON.c | 41 | #include <stdio.h> | COMMENT |
| LOW | …main/native/container-executor/impl/runc/runc_config.h | 21 | // Section for all runC config keys | COMMENT |
| LOW | …er/src/main/native/container-executor/impl/runc/runc.c | 21 | #include <sys/stat.h> | COMMENT |
| 1133 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ources/configsets/exampleCollection/conf/protwords.txt | 13 | #----------------------------------------------------------------------- | COMMENT |
| MEDIUM | …sources/configsets/exampleCollection/conf/synonyms.txt | 13 | #----------------------------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 986 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 988 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1016 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1018 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1082 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1084 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1100 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1105 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1217 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1219 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1246 | # --------------------------------------------------- | COMMENT |
| MEDIUM | …site/markdown/tools/hadoop-aws/qualifying_a_new_sdk.md | 1250 | # --------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …oop/fs/s3a/statistics/impl/AwsStatisticsCollector.java | 71 | // ┌─────────────────────────────────────────┐ | COMMENT |
| MEDIUM⚡ | …oop/fs/s3a/statistics/impl/AwsStatisticsCollector.java | 79 | // └─────────────────────────────────────────┘ | COMMENT |
| MEDIUM⚡ | …oop/fs/s3a/statistics/impl/AwsStatisticsCollector.java | 81 | // ┌─────────────────────────────────────────────────────────────────┐ | COMMENT |
| MEDIUM⚡ | …oop/fs/s3a/statistics/impl/AwsStatisticsCollector.java | 88 | // └─────────────────────────────────────────────────────────────────┘ | COMMENT |
| MEDIUM⚡ | …oop/fs/s3a/statistics/impl/AwsStatisticsCollector.java | 90 | // ┌─────────────────────────────────┐ | COMMENT |
| MEDIUM⚡ | …oop/fs/s3a/statistics/impl/AwsStatisticsCollector.java | 97 | // └─────────────────────────────────┘ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 23 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 25 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 54 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 56 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 105 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 107 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 139 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 141 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 198 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …oop-azure/dev-support/testrun-scripts/configsupport.sh | 200 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | …ject/hadoop-hdfs/src/test/resources/hadoop-dfs-dir.txt | 23 | # --------------------- | COMMENT |
| MEDIUM | …ject/hadoop-hdfs/src/test/resources/hadoop-dfs-dir.txt | 35 | # --------------------------------------- | COMMENT |
| MEDIUM | …project/hadoop-hdfs/src/main/bin/distribute-exclude.sh | 19 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …doop-hdfs-project/hadoop-hdfs/src/main/bin/stop-dfs.sh | 51 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …doop-hdfs-project/hadoop-hdfs/src/main/bin/stop-dfs.sh | 69 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …doop-hdfs-project/hadoop-hdfs/src/main/bin/stop-dfs.sh | 80 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …doop-hdfs-project/hadoop-hdfs/src/main/bin/stop-dfs.sh | 100 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …doop-hdfs-project/hadoop-hdfs/src/main/bin/stop-dfs.sh | 116 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …oop-hdfs-project/hadoop-hdfs/src/main/bin/start-dfs.sh | 84 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …oop-hdfs-project/hadoop-hdfs/src/main/bin/start-dfs.sh | 103 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …oop-hdfs-project/hadoop-hdfs/src/main/bin/start-dfs.sh | 114 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …oop-hdfs-project/hadoop-hdfs/src/main/bin/start-dfs.sh | 144 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …oop-hdfs-project/hadoop-hdfs/src/main/bin/start-dfs.sh | 161 | #--------------------------------------------------------- | COMMENT |
| MEDIUM | …-project/hadoop-hdfs/src/main/bin/refresh-namenodes.sh | 19 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | dev-support/docker/hadoop_env_checks.sh | 21 | # ------------------------------------------------------- | COMMENT |
| MEDIUM | dev-support/docker/hadoop_env_checks.sh | 41 | # ------------------------------------------------------- | COMMENT |
| MEDIUM | dev-support/docker/hadoop_env_checks.sh | 58 | # ------------------------------------------------------- | COMMENT |
| MEDIUM | dev-support/docker/hadoop_env_checks.sh | 83 | # ------------------------------------------------------- | COMMENT |
| MEDIUM | dev-support/docker/hadoop_env_checks.sh | 110 | # ------------------------------------------------------- | COMMENT |
| MEDIUM | dev-support/docker/hadoop_env_checks.sh | 116 | # ------------------------------------------------------- | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3298 | // Step 1: Create a Configuration object to hold the settings. | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3301 | // Step 2: Setup the host files. | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3313 | // Step 3: Create a MockRM (ResourceManager) instance to simulate RM behavior | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3319 | // Step 4: Register and simulate node activity for "test_host1" | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3325 | // Step 5: Validate that test_host3 is marked as a LOST node | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3332 | // Step 6: Validate node metrics for lost, active, and decommissioned nodes | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3341 | // Step 7: Register and simulate node activity for "test_host3" | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3346 | // Step 8: Validate updated node metrics after registering test_host3 | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 138 | // Step 1: Launch an App in Default Queue which utilizes the entire cluster | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 150 | // Step 2: Wait till the nodes utilization are full | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 161 | // Step 3: Launch another App in Queue A which will be Reserved | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 186 | // Step 4: Wait for Preemption to happen. It will preempt Node1 (1GB) | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 203 | // Step 5: Don't release the container from NodeManager so that Reservation | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 241 | // Step 6: Okay, now preempted node is Node1 and reserved node is Node3 | COMMENT |
| LOW⚡ | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 260 | // Step 7: Wait for app-2 to get ALLOCATED | COMMENT |
| LOW⚡ | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 265 | // Step 8: Validate if app-2 has got 1 live container and | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 183 | // Step 1: Start a MiniDFSCluster for Log Aggregation Path | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 195 | // Step 2: Prepare a Mock FileSystem which returns Delegation Token | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 216 | // Step 3: Prepare a Mock YarnClientImpl | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 245 | // Step 4: Prepare a ApplicationSubmissionContext and submit the app | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 262 | // Step 5: Verify automatic addition of HDFS DT for log aggregation path | COMMENT |
| LOW⚡ | …curity/authentication/util/TestSubjectPropagation.java | 98 | // Step 1: create the worker INSIDE the callAs scope so it inherits the Subject's ThreadLocal. | COMMENT |
| LOW⚡ | …curity/authentication/util/TestSubjectPropagation.java | 103 | // Step 2: callAs has exited. Submit a task that itself spawns a grandchild Thread, | COMMENT |
| LOW | …e-project/hadoop-bos/src/test/resources/README-TEST.md | 44 | ### Step 1: Create Test Configuration File | COMMENT |
| LOW | …e-project/hadoop-bos/src/test/resources/README-TEST.md | 53 | ### Step 2: Configure BOS Credentials | COMMENT |
| LOW | …e-project/hadoop-bos/src/test/resources/README-TEST.md | 69 | ### Step 3: Set Authentication | COMMENT |
| LOW | …hadoop-aws/src/site/markdown/tools/hadoop-aws/index.md | 271 | ### Step 1: Create a credential file | COMMENT |
| LOW | …hadoop-aws/src/site/markdown/tools/hadoop-aws/index.md | 298 | ### Step 2: Configure the `hadoop.security.credential.provider.path` property | COMMENT |
| LOW | …hadoop-sls/src/site/markdown/SchedulerLoadSimulator.md | 111 | ### Step 1: Configure Hadoop and the simulator | COMMENT |
| LOW | …hadoop-sls/src/site/markdown/SchedulerLoadSimulator.md | 178 | ### Step 2: Run the simulator | COMMENT |
| LOW | …hadoop/fs/azurebfs/services/ITestAbfsOutputStream.java | 411 | // Step 2: Mock the clientHandler to return the blobClient when getBlobClient is called | COMMENT |
| LOW | …a/org/apache/hadoop/fs/azurebfs/AbfsConfiguration.java | 1028 | for (T enumConstant : defaultValue.getDeclaringClass().getEnumConstants()) { // Step 3: Iterate over enum constant | CODE |
| LOW | …sourceestimator/src/site/markdown/ResourceEstimator.md | 71 | ### Step 1: Start the estimator | COMMENT |
| LOW | …sourceestimator/src/site/markdown/ResourceEstimator.md | 82 | ### Step 2: Run the estimator | COMMENT |
| LOW | …sourceestimator/src/site/markdown/ResourceEstimator.md | 106 | ### Step 3: Run the estimator | COMMENT |
| LOW | …ls/hadoop-dynamometer/src/site/markdown/Dynamometer.md | 71 | ### Step 1: Preparing Requisite Files | COMMENT |
| LOW | …ls/hadoop-dynamometer/src/site/markdown/Dynamometer.md | 75 | ### Step 2: Prepare FsImage Files | COMMENT |
| LOW | …ls/hadoop-dynamometer/src/site/markdown/Dynamometer.md | 96 | ### Step 3: Prepare a Hadoop Binary | COMMENT |
| LOW | …ls/hadoop-dynamometer/src/site/markdown/Dynamometer.md | 113 | ### Step 4: Prepare Configurations | COMMENT |
| LOW | …ls/hadoop-dynamometer/src/site/markdown/Dynamometer.md | 122 | ### Step 5: Execute the Block Generation Job | COMMENT |
| LOW | …ls/hadoop-dynamometer/src/site/markdown/Dynamometer.md | 137 | ### Step 6: Prepare Audit Traces (Optional) | COMMENT |
| LOW | …src/main/java/org/apache/hadoop/hdfs/StripeReader.java | 439 | // Step 1: prepare indices and output buffers for missing data units | COMMENT |
| LOW⚡ | …src/main/java/org/apache/hadoop/hdfs/StripeReader.java | 450 | // Step 2: decode into prepared output buffers | COMMENT |
| LOW⚡ | …src/main/java/org/apache/hadoop/hdfs/StripeReader.java | 453 | // Step 3: fill original application buffer with decoded data | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 349 | // Step 1: map the byte range to StripingCells | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 353 | // Step 2: get the unmerged ranges on each internal block | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 357 | // Step 3: merge into stripes | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 361 | // Step 4: calculate each chunk's position in destination buffer. Since the | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 408 | // Step 0: analyze range and calculate basic parameters | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 411 | // Step 1: map the byte range to StripingCells | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 415 | // Step 2: get the unmerged ranges on each internal block | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 419 | // Step 3: merge into at most 5 stripes | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 423 | // Step 4: calculate each chunk's position in destination buffer | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 426 | // Step 5: prepare ALLZERO blocks | COMMENT |
| LOW | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 384 | // Step 5: prepare ALLZERO blocks | COMMENT |
| LOW | …e/hadoop/hdfs/server/blockmanagement/BlockManager.java | 2150 | // Step 1: categorize at-risk blocks into replication and EC tasks | COMMENT |
| LOW | …e/hadoop/hdfs/server/blockmanagement/BlockManager.java | 2171 | // Step 2: choose target nodes for each reconstruction task | COMMENT |
| LOW | …e/hadoop/hdfs/server/blockmanagement/BlockManager.java | 2192 | // Step 3: add tasks to the DN | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3298 | // Step 1: Create a Configuration object to hold the settings. | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3301 | // Step 2: Setup the host files. | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3313 | // Step 3: Create a MockRM (ResourceManager) instance to simulate RM behavior | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3319 | // Step 4: Register and simulate node activity for "test_host1" | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3325 | // Step 5: Validate that test_host3 is marked as a LOST node | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3332 | // Step 6: Validate node metrics for lost, active, and decommissioned nodes | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3341 | // Step 7: Register and simulate node activity for "test_host3" | COMMENT |
| LOW⚡ | …server/resourcemanager/TestResourceTrackerService.java | 3346 | // Step 8: Validate updated node metrics after registering test_host3 | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 138 | // Step 1: Launch an App in Default Queue which utilizes the entire cluster | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 150 | // Step 2: Wait till the nodes utilization are full | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 161 | // Step 3: Launch another App in Queue A which will be Reserved | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 186 | // Step 4: Wait for Preemption to happen. It will preempt Node1 (1GB) | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 203 | // Step 5: Don't release the container from NodeManager so that Reservation | COMMENT |
| LOW | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 241 | // Step 6: Okay, now preempted node is Node1 and reserved node is Node3 | COMMENT |
| LOW⚡ | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 260 | // Step 7: Wait for app-2 to get ALLOCATED | COMMENT |
| LOW⚡ | …ity/TestCapacitySchedulerMultiNodesWithPreemption.java | 265 | // Step 8: Validate if app-2 has got 1 live container and | COMMENT |
| LOW | …rcemanager/scheduler/capacity/AbstractParentQueue.java | 439 | // We need to check if the parent of the child queue is exactly this | COMMENT |
| LOW | …/src/main/resources/webapps/static/jt/jquery.jstree.js | 1413 | // this variable stores the path to the themes folder - if left as false - it will be autodetected | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 183 | // Step 1: Start a MiniDFSCluster for Log Aggregation Path | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 195 | // Step 2: Prepare a Mock FileSystem which returns Delegation Token | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 216 | // Step 3: Prepare a Mock YarnClientImpl | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 245 | // Step 4: Prepare a ApplicationSubmissionContext and submit the app | COMMENT |
| LOW | …he/hadoop/yarn/client/api/impl/TestYarnClientImpl.java | 262 | // Step 5: Verify automatic addition of HDFS DT for log aggregation path | COMMENT |
| LOW⚡ | …curity/authentication/util/TestSubjectPropagation.java | 98 | // Step 1: create the worker INSIDE the callAs scope so it inherits the Subject's ThreadLocal. | COMMENT |
| LOW⚡ | …curity/authentication/util/TestSubjectPropagation.java | 103 | // Step 2: callAs has exited. Submit a task that itself spawns a grandchild Thread, | COMMENT |
| LOW | …pache/hadoop/io/compress/bzip2/CBZip2OutputStream.java | 1827 | // Step 1: | COMMENT |
| LOW | …pache/hadoop/io/compress/bzip2/CBZip2OutputStream.java | 1851 | // Step 2: | COMMENT |
| LOW | …pache/hadoop/io/compress/bzip2/CBZip2OutputStream.java | 1871 | // Step 3: | COMMENT |
| LOW | …/apache/hadoop/fs/gs/GoogleCloudStorageFileSystem.java | 119 | // we need to check if there are no conflicting items in the directory tree: | COMMENT |
| LOW | …/apache/hadoop/fs/gs/GoogleCloudStorageFileSystem.java | 220 | // Before creating a leaf directory we need to check if there are no conflicting files | COMMENT |
| LOW | …hadoop/fs/azurebfs/services/ITestAbfsOutputStream.java | 411 | // Step 2: Mock the clientHandler to return the blobClient when getBlobClient is called | COMMENT |
| LOW | …a/org/apache/hadoop/fs/azurebfs/AbfsConfiguration.java | 1028 | for (T enumConstant : defaultValue.getDeclaringClass().getEnumConstants()) { // Step 3: Iterate over enum constant | CODE |
| LOW | …che/hadoop/fs/azurebfs/services/AbfsRestOperation.java | 130 | * This variable stores the tracing context used for last Rest Operation. | COMMENT |
| LOW | …apache/hadoop/fs/azurebfs/services/AbfsBlobClient.java | 500 | // If the list operation returns no paths, we need to check if the path is a file. | COMMENT |
| LOW | …src/main/java/org/apache/hadoop/hdfs/StripeReader.java | 439 | // Step 1: prepare indices and output buffers for missing data units | COMMENT |
| LOW⚡ | …src/main/java/org/apache/hadoop/hdfs/StripeReader.java | 450 | // Step 2: decode into prepared output buffers | COMMENT |
| LOW⚡ | …src/main/java/org/apache/hadoop/hdfs/StripeReader.java | 453 | // Step 3: fill original application buffer with decoded data | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 349 | // Step 1: map the byte range to StripingCells | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 353 | // Step 2: get the unmerged ranges on each internal block | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 357 | // Step 3: merge into stripes | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 361 | // Step 4: calculate each chunk's position in destination buffer. Since the | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 408 | // Step 0: analyze range and calculate basic parameters | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 411 | // Step 1: map the byte range to StripingCells | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 415 | // Step 2: get the unmerged ranges on each internal block | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 419 | // Step 3: merge into at most 5 stripes | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 423 | // Step 4: calculate each chunk's position in destination buffer | COMMENT |
| LOW⚡ | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 426 | // Step 5: prepare ALLZERO blocks | COMMENT |
| LOW | …java/org/apache/hadoop/hdfs/util/StripedBlockUtil.java | 384 | // Step 5: prepare ALLZERO blocks | COMMENT |
| LOW | …e/hadoop/hdfs/server/blockmanagement/BlockManager.java | 2150 | // Step 1: categorize at-risk blocks into replication and EC tasks | COMMENT |
| LOW | …e/hadoop/hdfs/server/blockmanagement/BlockManager.java | 2171 | // Step 2: choose target nodes for each reconstruction task | COMMENT |
| LOW | …e/hadoop/hdfs/server/blockmanagement/BlockManager.java | 2192 | // Step 3: add tasks to the DN | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …eservice/storage/common/HBaseTimelineStorageUtils.java | 95 | // Essentially we are treating it like an 'unsigned very very long' and | COMMENT |
| MEDIUM | …org/apache/hadoop/registry/server/dns/RegistryDNS.java | 221 | // registryDNS can utilize local DNS server as upstream lookup. | COMMENT |
| MEDIUM | …oop-common/src/main/native/gtest/include/gtest/gtest.h | 9436 | // This implementation is *not* meant to be as highly tuned or robust | COMMENT |
| MEDIUM | …oop-common/src/main/native/gtest/include/gtest/gtest.h | 9508 | // In practice, this can be used to test functions that utilize the | COMMENT |
| MEDIUM | …main/java/org/apache/hadoop/util/DirectBufferPool.java | 48 | // Essentially implement a multimap with weak values. | COMMENT |
| MEDIUM | …g/apache/hadoop/fs/statistics/IOStatisticsLogging.java | 232 | // robust extract and convert to string | COMMENT |
| MEDIUM | …mmon-project/hadoop-common/src/main/conf/hadoop-env.sh | 127 | # Similarly, end users should utilize ${HOME}/.hadooprc . | COMMENT |
| MEDIUM | …/main/java/org/apache/hadoop/fs/s3a/S3AFileSystem.java | 4451 | // Essentially: no DTs, no canonical service name. | COMMENT |
| MEDIUM | …tools/hadoop-sls/src/main/html/js/thirdparty/jquery.js | 10821 | // understands anonymous AMD modules. A named AMD is safest and most robust | COMMENT |
| MEDIUM | …azurebfs/services/AbfsManagedApacheHttpConnection.java | 119 | return true; // Definitely stale | CODE |
| MEDIUM | …n/java/org/apache/hadoop/tools/dynamometer/Client.java | 501 | // Store a temporary config to leverage Configuration's time duration | COMMENT |
| MEDIUM | …s/src/test/java/org/apache/hadoop/hdfs/TestHFlush.java | 309 | // Make sure we work with DFS in order to utilize all its functionality | COMMENT |
| MEDIUM | …c/test/java/org/apache/hadoop/hdfs/TestDFSUpgrade.java | 64 | // TODO: Avoid hard-coding expected_txid. The test should be more robust. | COMMENT |
| MEDIUM | …e/hadoop/hdfs/server/namenode/TestCacheDirectives.java | 965 | // the NameNode be robust against this. | COMMENT |
| MEDIUM | …s/server/datanode/erasurecode/ErasureCodingWorker.java | 78 | // Essentially, this is a cachedThreadPool. | COMMENT |
| MEDIUM | …rg/apache/hadoop/hdfs/server/namenode/FSEditLogOp.java | 5076 | // robust. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ain/webapp/docs/development/adding-validation-rules.md | 243 | export function getAffectedQueuesForValidation( | CODE |
| LOW | …ain/webapp/docs/development/adding-validation-rules.md | 355 | function evaluateWithStagedChanges(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …ain/webapp/docs/development/adding-validation-rules.md | 445 | function evaluateDefaultLifetimeConstraint(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …acity-scheduler-ui/src/main/webapp/src/types/guards.ts | 35 | export function getQueueNameValidationError(name: string): string | null { | CODE |
| LOW | …uler-ui/src/main/webapp/src/config/validation-rules.ts | 102 | function evaluateCapacityTypeConsistency(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …uler-ui/src/main/webapp/src/config/validation-rules.ts | 237 | function evaluateMaxCapacityRelationship(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …uler-ui/src/main/webapp/src/config/validation-rules.ts | 331 | function evaluateParentChildCapacityConstraints(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …uler-ui/src/main/webapp/src/config/validation-rules.ts | 397 | function evaluateParentChildCapacityMode(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …uler-ui/src/main/webapp/src/config/validation-rules.ts | 476 | function evaluateWeightModeTransitionFlexibleAQC(context: ValidationContext): ValidationIssue[] { | CODE |
| LOW | …er-ui/src/main/webapp/src/config/properties/helpers.ts | 27 | export function getTemplatePropertyDefinitions(): PropertyDescriptor[] { | CODE |
| LOW | …er-ui/src/main/webapp/src/config/properties/helpers.ts | 31 | export function getTemplatePropertiesByCategory(category: PropertyCategory): PropertyDescriptor[] { | CODE |
| LOW | …rc/features/property-editor/hooks/usePropertyEditor.ts | 36 | function mergeFormAndValidationErrors( | CODE |
| LOW | …gement/components/QueueVisualizationContainer.test.tsx | 109 | function createSchedulerStoreState() { | CODE |
| LOW | …gement/components/QueueVisualizationContainer.test.tsx | 176 | function defaultSchedulerStoreImpl( | CODE |
| LOW | …rc/features/queue-management/hooks/useQueueTreeData.ts | 618 | function augmentQueueTreeWithStagedQueues( | CODE |
| LOW | …ebapp/src/features/template-config/utils/scopeUtils.ts | 136 | function stagedTemplatePathsForSuffix( | CODE |
| LOW | …src/features/staged-changes/utils/queueStateManager.ts | 18 | export function getParentQueuesForAdditions( | CODE |
| LOW | …src/features/staged-changes/utils/queueStateManager.ts | 66 | export function getQueuesForAutoCreationEnable(changes: StagedChange[]): string[] { | CODE |
| LOW | …src/features/staged-changes/utils/queueStateManager.ts | 105 | export function prepareMutationRequestForSubmission(request: SchedConfUpdateInfo): { | CODE |
| LOW | …src/features/staged-changes/utils/queueStateManager.ts | 140 | export function prepareMutationRequestWithVersion( | CODE |
| LOW | …/features/placement-rules/utils/placementRulesUtils.ts | 42 | export function extractPlacementRulesFromConfig( | CODE |
| LOW | …acement-rules/components/CustomPlacementHelpDialog.tsx | 39 | export function CustomPlacementHelpDialog({ | CODE |
| LOW | …s/global-settings/hooks/useGlobalPropertyValidation.ts | 24 | export function useGlobalPropertyValidation() { | CODE |
| LOW | …webapp/src/features/validation/utils/affectedQueues.ts | 25 | export function getAffectedQueuesForValidation( | CODE |
| LOW | …-scheduler-ui/src/main/webapp/src/utils/configUtils.ts | 60 | export function getEffectivePropertyValue( | CODE |
| LOW | …-scheduler-ui/src/main/webapp/src/utils/configUtils.ts | 96 | export function buildEffectivePropertyKey(queuePath: string, propertyName: string): string { | CODE |
| LOW | …cheduler-ui/src/main/webapp/src/utils/propertyUtils.ts | 65 | export function buildNodeLabelPropertyKey( | CODE |
| LOW | …ler-ui/src/main/webapp/src/lib/errors/readOnlyGuard.ts | 15 | export function createReadOnlyBlockedError(operation: string): { | CODE |
| LOW | …duler-ui/src/main/webapp/src/lib/errors/error-utils.ts | 68 | export function createDetailedErrorMessage( | CODE |
| LOW | …n/server/resourcemanager/webapp/RMAppAttemptBlock.java | 77 | .append("function getTableDataFromObjectArray(objectArray, fields) {") | CODE |
| LOW | …n/server/resourcemanager/webapp/RMAppAttemptBlock.java | 242 | .append("function handleRefreshSchedulerActDone(data){") | CODE |
| LOW | …n/server/resourcemanager/webapp/RMAppAttemptBlock.java | 249 | .append("function handleQuerySchedulerActDone(data){") | CODE |
| LOW | …n/server/resourcemanager/webapp/RMAppAttemptBlock.java | 279 | .append("function refreshSchedulerDiagnostics() {") | CODE |
| LOW | …n/server/resourcemanager/webapp/RMAppAttemptBlock.java | 284 | .append("function querySchedulerDiagnostics() {") | CODE |
| LOW | …ache/hadoop/yarn/server/AMHeartbeatRequestHandler.java | 43 | public class AMHeartbeatRequestHandler extends Thread { | CODE |
| LOW | …doop/yarn/server/timeline/TestTimelineDataManager.java | 43 | public class TestTimelineDataManager extends TimelineStoreTestUtils { | CODE |
| LOW | …e/hadoop/yarn/server/timeline/TimelineDataManager.java | 55 | public class TimelineDataManager extends AbstractService { | CODE |
| LOW | …adoop-yarn-ui/src/main/webapp/app/adapters/yarn-log.js | 21 | function createEmptyContainerLogInfo(location) { | CODE |
| LOW | …rn-ui/src/main/webapp/app/components/sunburst-chart.js | 195 | function initializeBreadcrumbTrail() { | CODE |
| LOW | …n-ui/src/main/webapp/app/helpers/log-adapter-helper.js | 19 | export function createEmptyContainerLogInfo(location) { | CODE |
| LOW | …oop-yarn-ui/src/main/webapp/app/initializers/loader.js | 61 | function getYarnHttpProtocolScheme(rmhost, application) { | CODE |
| LOW | …main/java/org/apache/hadoop/mcp/McpRequestHandler.java | 44 | public final class McpRequestHandler { | CODE |
| LOW | …tools/hadoop-sls/src/main/html/js/thirdparty/jquery.js | 9039 | function addToPrefiltersOrTransports( structure ) { | CODE |
| LOW | …tools/hadoop-sls/src/main/html/js/thirdparty/jquery.js | 9073 | function inspectPrefiltersOrTransports( structure, options, originalOptions, jqXHR ) { | CODE |
| LOW | …oject/hadoop-hdfs/src/main/webapps/static/rest-csrf.js | 39 | function getTrimmedStringArrayValue(element) { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …applications-catalog-webapp/src/main/webapp/theme.html | 631 | <p>Lorem ipsum dolor sit amet, consectetur adipiscing elit. Maecenas sed diam eget risus varius blandit sit amet non | CODE |
| LOW⚡ | …applications-catalog-webapp/src/main/webapp/theme.html | 631 | <p>Lorem ipsum dolor sit amet, consectetur adipiscing elit. Maecenas sed diam eget risus varius blandit sit amet non | CODE |
| LOW⚡ | …applications-catalog-webapp/src/main/webapp/theme.html | 632 | magna. Lorem ipsum dolor sit amet, consectetur adipiscing elit. Praesent commodo cursus magna, vel scelerisque | CODE |
| LOW⚡ | …applications-catalog-webapp/src/main/webapp/theme.html | 632 | magna. Lorem ipsum dolor sit amet, consectetur adipiscing elit. Praesent commodo cursus magna, vel scelerisque | CODE |
| LOW | …/placement-rules/components/PlacementRuleForm.test.tsx | 467 | 'placeholder', | CODE |
| LOW | …duler/fair/converter/FSConfigConverterTestCommons.java | 161 | out.println("dummy_key=dummy_value"); | CODE |
| LOW | …nager/placement/csmappingrule/TestVariableContext.java | 188 | .put("%userPhone", "555-3221") | CODE |
| LOW | …nager/placement/csmappingrule/TestVariableContext.java | 202 | testCases.put("%userPhone", "555-3221"); | CODE |
| LOW | …s/webapps/static/jquery/jquery-ui-1.13.2.custom.min.js | 6 | !function(t){"use strict";"function"==typeof define&&define.amd?define(["jquery"],t):t(jQuery)}(function(V){"use strict" | CODE |
| LOW | …s/webapps/static/dt-1.11.5/js/jquery.dataTables.min.js | 55 | null!==a.searchDelay?a.searchDelay:"ssp"===Q(a)?400:0;var m=l("input",b).val(e.sSearch).attr("placeholder",d.sSearchPlac | CODE |
| LOW | …va/org/apache/hadoop/yarn/webapp/view/LipsumBlock.java | 30 | __("Lorem ipsum dolor sit amet, consectetur adipiscing elit.", | CODE |
| LOW | …va/org/apache/hadoop/yarn/webapp/view/LipsumBlock.java | 30 | __("Lorem ipsum dolor sit amet, consectetur adipiscing elit.", | CODE |
| LOW | …/org/apache/hadoop/yarn/client/ProtocolHATestBase.java | 801 | ByteBuffer key = ByteBuffer.wrap("fake_key".getBytes()); | CODE |
| LOW | …adoop/fs/tosfs/object/tos/TestChainTOSInputStream.java | 183 | String key = "dummy-key"; | CODE |
| LOW | …ava/org/apache/hadoop/mapreduce/TestTypeConverter.java | 119 | when(mockReport.getUser()).thenReturn("dummy-user"); | CODE |
| LOW | …ava/org/apache/hadoop/mapreduce/TestTypeConverter.java | 146 | assertEquals("dummy-user", status.getUsername(), "user set incorrectly"); | CODE |
| LOW | …va/org/apache/hadoop/mapreduce/v2/util/TestMRApps.java | 203 | String jobFile = MRApps.getJobFile(conf, "dummy-user", | CODE |
| LOW | …va/org/apache/hadoop/mapreduce/v2/util/TestMRApps.java | 206 | assertEquals("/my/path/to/staging/dummy-user/.staging/job_dummy-job_12345/job.xml", jobFile, | CODE |
| LOW | …doop/mapreduce/v2/app/rm/TestRMContainerAllocator.java | 3634 | ByteBuffer.wrap("fake_key".getBytes()), | CODE |
| LOW | …ache/hadoop/fs/s3a/ITestS3AAWSCredentialsProvider.java | 93 | return AwsBasicCredentials.create("dummy_key", "dummy_secret"); | CODE |
| LOW | …ache/hadoop/fs/azurebfs/ITestAbfsMsiTokenProvider.java | 137 | token.setAccessToken("fake-token"); | CODE |
| LOW | …ache/hadoop/fs/azurebfs/ITestAbfsMsiTokenProvider.java | 150 | assertThat(token.getAccessToken()).isEqualTo("fake-token"); | CODE |
| LOW | …azurebfs/oauth2/TestWorkloadIdentityTokenProvider.java | 45 | private static final String TOKEN = "dummy-token"; | CODE |
| LOW | …-hdfs/src/main/webapps/static/jquery.dataTables.min.js | 4 | */ var $jscomp=$jscomp||{};$jscomp.scope={},$jscomp.findInternal=function(t,e,n){t instanceof String&&(t=String(t));for( | COMMENT |
| LOW⚡ | …ps/static/bootstrap-3.4.1/js/bootstrap-editable.min.js | 5 | !function(a){"use strict";var b=function(b,c){this.options=a.extend({},a.fn.editableform.defaults,c),this.$div=a(b),this | CODE |
| LOW⚡ | …ps/static/bootstrap-3.4.1/js/bootstrap-editable.min.js | 7 | return a==b}),n=a.inArray(o[0],k[f].months)+1;break;case"M":o=a(k[f].monthsShort).filter(function(){var a=this.slice(0,j | CODE |
| LOW | …adoop/hdfs/server/federation/router/TestRouterRpc.java | 252 | conf.set(DFSConfigKeys.DFS_NAMENODE_IP_PROXY_USERS, "placeholder"); | CODE |
| LOW | …t/java/org/apache/hadoop/example/ITUseMiniCluster.java | 65 | private static final String TEXT = "Lorem ipsum dolor sit amet, consectetur " | CODE |
| LOW | …t/java/org/apache/hadoop/example/ITUseMiniCluster.java | 65 | private static final String TEXT = "Lorem ipsum dolor sit amet, consectetur " | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/hadoop/fs/gs/GoogleCloudStorageClientReadChannel.java | 521 | // close existing contentChannel as requested bytes can't be served from current | COMMENT |
| HIGH | …doop/fs/azurebfs/services/ITestAbfsPositionedRead.java | 160 | // disabled, it will only read the exact bytes as requested and no data | COMMENT |
| HIGH | …e/hadoop/hdfs/server/namenode/TestCacheDirectives.java | 1097 | // only 3 because the file only has 3 replicas, not 4 as requested. | COMMENT |
| HIGH | …p/hdfs/server/blockmanagement/LowRedundancyBlocks.java | 257 | //there is less than a third as many blocks as requested; | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ge-project/hadoop-bos/src/test/resources/core-site.xml | 48 | # Create a file auth-keys.xml - DO NOT ADD TO REVISION CONTROL | COMMENT |
| MEDIUM | …ge-project/hadoop-gcp/src/test/resources/core-site.xml | 40 | # Create a file auth-keys.xml - DO NOT ADD TO REVISION CONTROL | COMMENT |
| MEDIUM | …ct/hadoop-huaweicloud/src/test/resources/core-site.xml | 128 | # Create a file auth-keys.xml - DO NOT ADD TO REVISION CONTROL | COMMENT |
| MEDIUM | …doop-tools/hadoop-aws/src/test/resources/core-site.xml | 225 | # Create a file auth-keys.xml - DO NOT ADD TO REVISION CONTROL | COMMENT |
| MEDIUM | …p-tools/hadoop-aliyun/src/test/resources/core-site.xml | 38 | # Create a file auth-keys.xml - DO NOT ADD TO REVISION CONTROL | COMMENT |
| MEDIUM | …ools/hadoop-azure-datalake/src/test/resources/adls.xml | 17 | # Create a file auth-keys.xml - DO NOT ADD TO REVISION CONTROL | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …p/yarn/server/resourcemanager/TestAMAuthorization.java | 397 | // TODO: Add validation of invalid authorization when there's more data in | COMMENT |
| LOW | …e-client/src/main/native/fuse-dfs/test/fuse_workload.c | 55 | // TODO: implement/test access, mknod, symlink | COMMENT |
| LOW | …op/hdfs/TestDFSStripedOutputStreamWithFailureBase.java | 330 | //TODO: implement hflush/hsync and verify gs strict greater than oldGS | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/timelineservice/reader/filter/TimelineFilterList.java | 31 | * operator {@link Operator#AND} or {@link Operator#OR}. Since you can use | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …project/hadoop-common/src/main/bin/hadoop-functions.sh | 1948 | # Check if jsvc -help has entry for option -cwd | COMMENT |
| LOW | dev-support/jenkins.sh | 246 | # Check if the CI needs to be run, if so, do so :) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …heduler-ui/src/main/webapp/public/mockServiceWorker.js | 122 | async function handleRequest(event, requestId) { | CODE |
| LOW | …tools/hadoop-sls/src/main/html/js/thirdparty/jquery.js | 4401 | function getData( data ) { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | dev-support/docker/pkg-resolver/resolve.py | 29 | CODE | |
| LOW | dev-support/docker/pkg-resolver/resolve.py | 42 | CODE |