Apache Storm
This report summarizes scanner evidence for apache/storm, a Java project with 6,698 GitHub stars. SynthScan examined 401,232 lines of code across 2439 source files, recording 627 pattern matches distributed across 16 syntactic categories. The legacy adjusted pattern signal is 2.8 (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? 453 finding(s).
Are imports declared and package/API names verified? 86 finding(s).
Are wrappers, guards, and repeated structures necessary? 200 finding(s).
Which changes need focused human review? 627 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 627 distinct pattern matches across 16 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 | docs/STORM-UI-REST-API.md | 735 | "lastError": "java.lang.RuntimeException: Error here! at org.apache.storm.starter.bolt.WordCountBolt.nextTup | CODE |
| CRITICAL | docs/STORM-UI-REST-API.md | 1161 | "error": "java.lang.RuntimeException: java.lang.StringIndexOutOfBoundsException: Some Error\n\ta | CODE |
| CRITICAL | docs/Troubleshooting.md | 84 | at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:84) | CODE |
| CRITICAL | docs/Troubleshooting.md | 85 | at org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:55) | CODE |
| CRITICAL⚡ | docs/Troubleshooting.md | 100 | at org.apache.storm.serialization.SerializableSerializer.write(SerializableSerializer.java:21) | CODE |
| CRITICAL⚡ | docs/Troubleshooting.md | 102 | at com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:77) | CODE |
| CRITICAL⚡ | docs/Troubleshooting.md | 103 | at com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:18) | CODE |
| CRITICAL⚡ | docs/Troubleshooting.md | 105 | at org.apache.storm.serialization.KryoValuesSerializer.serializeInto(KryoValuesSerializer.java:27) | CODE |
| CRITICAL | …org/apache/storm/state/DefaultStateSerializerTest.java | 157 | org.apache.storm.serialization.SerializationFactory.register( | CODE |
| CRITICAL | …lient/src/jvm/org/apache/storm/utils/CuratorUtils.java | 39 | = org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNetty.class.getName(); | CODE |
| CRITICAL | …rc/main/java/org/apache/storm/daemon/ui/UIHelpers.java | 2465 | logLevel.set_target_log_level(org.apache.logging.log4j.Level.toLevel(targetLevel).name()); | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 112 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:num-nimbus-leaders", io.prometheus.metrics.core.metrics.Gauge.build | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 117 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:num-nimbuses", io.prometheus.metrics.core.metrics.Gauge.builder() | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 122 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:num-supervisors", io.prometheus.metrics.core.metrics.Gauge.builder( | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 127 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:num-topologies", io.prometheus.metrics.core.metrics.Gauge.builder() | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 132 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:num-total-used-workers", io.prometheus.metrics.core.metrics.Gauge.b | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 137 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:num-total-workers", io.prometheus.metrics.core.metrics.Gauge.builde | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 142 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:total-fragmented-cpu-non-negative", io.prometheus.metrics.core.metr | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 147 | CLUSTER_SUMMARY_METRICS.put("summary.cluster:total-fragmented-memory-non-negative", io.prometheus.metrics.core.m | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 152 | CLUSTER_SUMMARY_METRICS.put("nimbus:available-cpu-non-negative", io.prometheus.metrics.core.metrics.Gauge.builde | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 157 | CLUSTER_SUMMARY_METRICS.put("nimbus:total-cpu", io.prometheus.metrics.core.metrics.Gauge.builder() | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 162 | CLUSTER_SUMMARY_METRICS.put("nimbus:total-memory", io.prometheus.metrics.core.metrics.Gauge.builder() | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 167 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:assigned-cpu", io.prometheus.metrics.core.metrics.Histogram.buil | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 172 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:assigned-mem-off-heap", io.prometheus.metrics.core.metrics.Histo | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 177 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:assigned-mem-on-heap", io.prometheus.metrics.core.metrics.Histog | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 182 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:num-executors", io.prometheus.metrics.core.metrics.Histogram.bui | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 187 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:num-tasks", io.prometheus.metrics.core.metrics.Histogram.builder | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 192 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:num-workers", io.prometheus.metrics.core.metrics.Histogram.build | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 197 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:replication-count", io.prometheus.metrics.core.metrics.Histogram | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 202 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:requested-cpu", io.prometheus.metrics.core.metrics.Histogram.bui | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 207 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:requested-mem-off-heap", io.prometheus.metrics.core.metrics.Hist | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 212 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:requested-mem-on-heap", io.prometheus.metrics.core.metrics.Histo | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 217 | CLUSTER_SUMMARY_METRICS.put("summary.topologies:uptime-secs", io.prometheus.metrics.core.metrics.Histogram.build | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 222 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:fragmented-cpu", io.prometheus.metrics.core.metrics.Histogram.b | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 227 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:fragmented-mem", io.prometheus.metrics.core.metrics.Histogram.b | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 232 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:num-used-workers", io.prometheus.metrics.core.metrics.Histogram | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 237 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:num-workers", io.prometheus.metrics.core.metrics.Histogram.buil | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 242 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:uptime-secs", io.prometheus.metrics.core.metrics.Histogram.buil | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 247 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:used-cpu", io.prometheus.metrics.core.metrics.Histogram.builder | CODE |
| CRITICAL⚡ | …storm/metrics/prometheus/PrometheusReporterClient.java | 252 | CLUSTER_SUMMARY_METRICS.put("summary.supervisors:used-mem", io.prometheus.metrics.core.metrics.Histogram.builder | CODE |
| CRITICAL | …test/java/org/apache/storm/security/auth/AuthTest.java | 626 | InetAddress unauthorizedHost = com.google.common.net.InetAddresses.forString("10.10.10.10"); | CODE |
| CRITICAL⚡ | …/apache/storm/daemon/nimbus/NimbusClojurePortTest.java | 1109 | org.apache.storm.stats.StatsUtil.convertZkWorkerHb( | CODE |
| CRITICAL⚡ | …/apache/storm/daemon/nimbus/NimbusClojurePortTest.java | 1113 | stats.put(org.apache.storm.stats.ClientStatsUtil.convertExecutor(executor), | CODE |
| CRITICAL⚡ | …/apache/storm/daemon/nimbus/NimbusClojurePortTest.java | 1119 | org.apache.storm.stats.ClientStatsUtil.thriftifyZkWorkerHb( | CODE |
| CRITICAL⚡ | …/apache/storm/daemon/nimbus/NimbusClojurePortTest.java | 1120 | org.apache.storm.stats.ClientStatsUtil.mkZkWorkerHb(stormId, stats, 10))); | CODE |
| CRITICAL⚡ | …/apache/storm/daemon/nimbus/NimbusClojurePortTest.java | 1122 | org.apache.storm.stats.StatsUtil.thriftifyRpcWorkerHb(stormId, executor)); | CODE |
| CRITICAL | …/src/main/java/org/apache/storm/utils/ServerUtils.java | 205 | boolean isSymLink = org.apache.commons.io.FileUtils.isSymlink(allFiles[i]); | CODE |
| CRITICAL | …ava/org/apache/storm/daemon/supervisor/Supervisor.java | 414 | return new org.apache.storm.generated.Supervisor.Iface() { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | rewrite.yml | 1 | # | COMMENT |
| LOW | rewrite.yml | 21 | # Checkstyle's own reports). | COMMENT |
| LOW | …st/binary/final-package/src/main/scripts/dedup-libs.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | …st/binary/final-package/src/main/scripts/dedup-libs.py | 21 | # directory, to keep the distribution small. | COMMENT |
| LOW | …st/binary/final-package/src/main/scripts/dedup-libs.py | 41 | # lib-common copy silently shadowing the lib one. All conflicts are detected in | COMMENT |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | storm-core/src/native/worker-launcher/.autom4te.cfg | 1 | # | COMMENT |
| LOW | …core/src/native/worker-launcher/impl/worker-launcher.h | 61 | }; | COMMENT |
| LOW | …core/src/native/worker-launcher/impl/worker-launcher.c | 21 | #include "utils/file-utils.h" | COMMENT |
| LOW | storm-core/src/native/worker-launcher/impl/main.c | 21 | #include "oci/oci.h" | COMMENT |
| LOW | …m-core/src/native/worker-launcher/impl/configuration.c | 21 | COMMENT | |
| LOW | …ore/src/native/worker-launcher/impl/oci/oci_base_ctx.c | 21 | #include <errno.h> | COMMENT |
| LOW | …src/native/worker-launcher/impl/oci/oci_write_config.c | 21 | #include <stdio.h> | COMMENT |
| LOW | …rm-core/src/native/worker-launcher/impl/oci/oci_reap.c | 21 | #include <sys/wait.h> | COMMENT |
| LOW | …rm-core/src/native/worker-launcher/impl/oci/oci_reap.c | 41 | #define DEV_LOOP_PREFIX "/dev/loop" | COMMENT |
| LOW | …e/src/native/worker-launcher/impl/oci/oci_launch_cmd.c | 21 | #include <stdbool.h> | COMMENT |
| LOW | storm-core/src/native/worker-launcher/impl/oci/oci.c | 21 | #include <sys/stat.h> | COMMENT |
| LOW | storm-core/src/native/worker-launcher/impl/oci/oci.c | 41 | #include "utils/string-utils.h" | COMMENT |
| LOW | …-core/src/native/worker-launcher/impl/oci/oci_config.h | 21 | // Prefix for all OCI config keys | COMMENT |
| LOW | …orm-core/src/native/worker-launcher/impl/utils/cJSON.h | 61 | #endif | COMMENT |
| LOW | …orm-core/src/native/worker-launcher/impl/utils/cJSON.h | 81 | /* project version */ | COMMENT |
| LOW | …orm-core/src/native/worker-launcher/impl/utils/cJSON.c | 21 | */ | COMMENT |
| LOW | …orm-core/src/native/worker-launcher/impl/utils/cJSON.c | 41 | #include <stdio.h> | COMMENT |
| LOW | …core/src/native/worker-launcher/impl/utils/user_info.c | 21 | #include <errno.h> | COMMENT |
| LOW | …ore/src/native/worker-launcher/impl/utils/file-utils.c | 21 | #include <sys/types.h> | COMMENT |
| LOW | …src/native/worker-launcher/test/test-worker-launcher.c | 21 | COMMENT | |
| LOW | storm-core/src/resources/compile-worker-launcher.sh | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | storm-core/src/dev/resources/tester_bolt.rb | 1 | # -*- coding: utf-8 -*- | COMMENT |
| LOW | storm-core/src/dev/resources/tester_spout_metrics.py | 1 | # -*- coding: utf-8 -*- | COMMENT |
| LOW | storm-core/src/dev/resources/tester_spout.py | 1 | # -*- coding: utf-8 -*- | COMMENT |
| LOW | storm-core/src/dev/resources/tester_spout.rb | 1 | # -*- coding: utf-8 -*- | COMMENT |
| LOW | storm-core/src/dev/resources/tester_bolt.py | 1 | # -*- coding: utf-8 -*- | COMMENT |
| LOW | storm-core/src/dev/resources/tester_bolt_metrics.py | 1 | # -*- coding: utf-8 -*- | COMMENT |
| LOW | bin/test_storm.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | bin/docker-to-squash.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | bin/storm.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | bin/test_docker_to_squash.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | bin/test_docker_to_squash.py | 41 | # TODO: | COMMENT |
| LOW | bin/flight.bash | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …wrappers/src/main/resources/resources/splitsentence.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ux/flux-core/src/test/resources/configs/hdfs_test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …x/flux-core/src/test/resources/configs/kafka_test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …/src/test/resources/configs/component-config-test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …st/resources/configs/existing-topology-reflection.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …/test/resources/configs/existing-topology-trident.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …t/resources/configs/component-config-missing-test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …urces/configs/existing-topology-reflection-config.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …flux-core/src/test/resources/configs/include_test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …core/src/test/resources/configs/existing-topology.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …rc/test/resources/configs/bad_static_factory_test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …-core/src/test/resources/configs/diamond-topology.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …sources/configs/existing-topology-method-override.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …core/src/test/resources/configs/substitution-test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …core/src/test/resources/configs/substitution-test.yaml | 21 | # name to be used when submitting | COMMENT |
| LOW | …ux-core/src/test/resources/configs/bad_shell_test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ux-core/src/test/resources/configs/bad_shell_test.yaml | 21 | # name to be used when submitting | COMMENT |
| LOW | …/flux-core/src/test/resources/configs/worker_hook.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …sources/configs/component-config-invalid-key-test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …/resources/configs/component-config-override-test.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | flux/flux-core/src/test/resources/configs/tck.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| 106 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 59 | def test_identical_jars_are_deduped(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 76 | def test_diverged_jar_between_lib_and_worker_fails(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 99 | def test_diverged_jar_between_lib_and_common_fails(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 115 | def test_diverged_jar_between_worker_and_common_fails(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 134 | def test_all_conflicts_are_reported(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 148 | def test_version_drift_between_lib_and_worker_fails(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 169 | def test_version_drift_between_lib_and_prestaged_common_fails(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 182 | def test_version_drift_between_worker_and_common_fails(self): | CODE |
| LOW | …nary/final-package/src/main/scripts/test_dedup_libs.py | 209 | def test_worker_only_jar_is_promoted_and_counted(self): | CODE |
| LOW | bin/test_storm.py | 69 | def test_get_classpath_includes_lib_common(self): | CODE |
| LOW | bin/test_storm.py | 82 | def test_resolve_dependencies(self): | CODE |
| LOW⚡ | bin/test_storm.py | 116 | def test_print_localconfvalue(self): | CODE |
| LOW⚡ | bin/test_storm.py | 125 | def test_print_remoteconfvalue(self): | CODE |
| LOW⚡ | bin/test_storm.py | 134 | def test_initialize_main_command(self): | CODE |
| LOW | bin/test_storm.py | 224 | def test_print_server_classpath(self): | CODE |
| LOW⚡ | bin/docker-to-squash.py | 278 | def get_local_manifest_from_path(manifest_path): | CODE |
| LOW⚡ | bin/docker-to-squash.py | 286 | def get_hdfs_manifest_from_path(manifest_path): | CODE |
| LOW⚡ | bin/docker-to-squash.py | 293 | def get_hdfs_manifests_from_paths(manifest_paths): | CODE |
| LOW | bin/docker-to-squash.py | 309 | def get_config_hash_from_manifest(manifest): | CODE |
| LOW | bin/docker-to-squash.py | 332 | def get_layer_hashes_from_manifest(manifest, error_on_size_check=True): | CODE |
| LOW | bin/docker-to-squash.py | 354 | def get_manifest_from_docker_image(pull_format, image): | CODE |
| LOW | bin/docker-to-squash.py | 456 | def remove_image_hash_from_dicts(hash_to_tags, tag_to_hash, image_hash): | CODE |
| LOW | bin/docker-to-squash.py | 486 | def write_local_image_tag_to_hash(image_tag_to_hash, hash_to_tags): | CODE |
| LOW | bin/docker-to-squash.py | 507 | def update_dicts_for_multiple_tags(hash_to_tags, tag_to_hash, tags, manifest_hash, comment): | CODE |
| LOW | bin/docker-to-squash.py | 527 | def populate_tag_dicts_set_root(image_tag_to_hash, local_image_tag_to_hash, hdfs_root): | CODE |
| LOW | bin/docker-to-squash.py | 576 | def make_whiteout_block_device(file_path, whiteout): | CODE |
| LOW | bin/docker-to-squash.py | 678 | def check_image_for_magic_file(magic_file, skopeo_dir, layers): | CODE |
| LOW | bin/docker-to-squash.py | 1001 | def get_delete_list_from_images_to_remove(images_to_remove, known_images): | CODE |
| LOW | bin/docker-to-squash.py | 1389 | def get_all_layers_and_configs(manifest_names): | CODE |
| LOW | bin/docker-to-squash.py | 1449 | def does_image_have_unref_file(image): | CODE |
| LOW | bin/docker-to-squash.py | 1453 | def does_image_have_dead_perms(image): | CODE |
| LOW | bin/docker-to-squash.py | 1466 | def cleanup_handle_tagged_images(tagged_images): | CODE |
| LOW | bin/docker-to-squash.py | 1479 | def cleanup_handle_untagged_images(untagged_images): | CODE |
| LOW | bin/docker-to-squash.py | 1492 | def cleanup_handle_stale_images(stale_images): | CODE |
| LOW | bin/docker-to-squash.py | 1506 | def cleanup_handle_dead_images(dead_images, known_images): | CODE |
| LOW | bin/docker-to-squash.py | 1519 | def make_manifests_unreadable(images): | CODE |
| LOW | bin/docker-to-squash.py | 1656 | def add_parser_default_arguments(parser): | CODE |
| LOW⚡ | bin/storm.py | 1029 | def initialize_classpath_subcommand(subparsers): | CODE |
| LOW⚡ | bin/storm.py | 1036 | def initialize_server_classpath_subcommand(subparsers): | CODE |
| LOW⚡ | bin/storm.py | 1043 | def initialize_monitor_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 355 | def initialize_localconfvalue_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 366 | def initialize_remoteconfvalue_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 468 | def initialize_local_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 505 | def initialize_kill_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 540 | def initialize_upload_credentials_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 571 | def initialize_blobstore_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 650 | def initialize_heartbeats_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 667 | def initialize_activate_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 678 | def initialize_listtopos_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 687 | def initialize_set_log_level_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 804 | def initialize_healthcheck_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 813 | def initialize_kill_workers_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 824 | def initialize_admin_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 884 | def initialize_shell_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 899 | def initialize_repl_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 910 | def initialize_nimbus_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 998 | def initialize_drpc_subcommand(subparsers): | CODE |
| LOW | bin/storm.py | 1433 | def merge_args_and_preserve_order(sys_args, known_args, unknown_args): | CODE |
| LOW⚡ | bin/storm.py | 1022 | def initialize_version_subcommand(subparsers): | STRING |
| LOW | bin/storm.py | 439 | def initialize_jar_subcommand(subparsers): | STRING |
| 40 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | bin/docker-to-squash.py | 389 | CODE | |
| LOW | bin/docker-to-squash.py | 690 | CODE | |
| LOW | bin/docker-to-squash.py | 827 | CODE | |
| LOW | bin/docker-to-squash.py | 1001 | CODE | |
| LOW | bin/docker-to-squash.py | 1033 | CODE | |
| LOW | bin/docker-to-squash.py | 1087 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4062 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4161 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4253 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4363 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4513 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4589 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4666 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4806 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 4946 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5022 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5101 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5187 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5441 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5537 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5613 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5737 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5821 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5895 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 5974 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 6060 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 6139 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 6290 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 6375 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 6837 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 6923 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7000 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7142 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7292 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7433 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7713 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7798 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 7876 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 8115 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 8190 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 8522 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 8642 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 8762 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 8883 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9033 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9185 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9316 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9456 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9597 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9749 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9835 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 9914 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10000 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10079 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10167 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10255 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10343 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10431 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10521 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 10619 | CODE | |
| 99 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | bin/docker-to-squash.py | 1706 | except Exception as ex: | CODE |
| LOW⚡ | bin/docker-to-squash.py | 1716 | except Exception as _: | CODE |
| LOW⚡ | bin/docker-to-squash.py | 1723 | except Exception as _: | CODE |
| LOW⚡ | bin/docker-to-squash.py | 1731 | except Exception as _: | CODE |
| LOW⚡ | bin/docker-to-squash.py | 1738 | except Exception: | CODE |
| LOW | bin/docker-to-squash.py | 88 | except Exception as ex: | CODE |
| LOW | bin/docker-to-squash.py | 247 | except Exception as ex: | CODE |
| LOW | bin/docker-to-squash.py | 653 | except Exception as ex: | CODE |
| LOW | bin/docker-to-squash.py | 821 | except Exception as _: | CODE |
| LOW | bin/storm.py | 239 | except Exception: | CODE |
| LOW | bin/storm.py | 1139 | except Exception: | CODE |
| LOW | bin/storm.py | 1165 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2550 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2582 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2611 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2640 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2669 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2698 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2730 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2753 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2776 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2805 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2828 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2851 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2883 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2912 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2941 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2967 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 2993 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3019 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3048 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3077 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3106 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3132 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3164 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3187 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3216 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3245 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3268 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3294 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3320 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3346 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3372 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3398 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3424 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3450 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3479 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3508 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3534 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3560 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3589 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3618 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3647 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3676 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3705 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3734 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3763 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3792 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3821 | except Exception: | CODE |
| LOW | storm-client/src/py/storm/Nimbus.py | 3850 | except Exception: | CODE |
| 27 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | storm-core/src/dev/resources/tester_spout_metrics.py | 23 | CODE | |
| LOW | storm-core/src/dev/resources/tester_bolt_metrics.py | 22 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 28 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 30 | CODE | |
| LOW | storm-client/src/py/storm/Nimbus.py | 34 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPCInvocations.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPCInvocations.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPCInvocations.py | 28 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPCInvocations.py | 30 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPCInvocations.py | 34 | CODE | |
| LOW | storm-client/src/py/storm/Supervisor.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/Supervisor.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/Supervisor.py | 28 | CODE | |
| LOW | storm-client/src/py/storm/Supervisor.py | 30 | CODE | |
| LOW | storm-client/src/py/storm/Supervisor.py | 34 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 28 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 29 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 30 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 32 | CODE | |
| LOW | storm-client/src/py/storm/constants.py | 33 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 30 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPC.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPC.py | 27 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPC.py | 28 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPC.py | 30 | CODE | |
| LOW | storm-client/src/py/storm/DistributedRPC.py | 34 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …t/src/jvm/org/apache/storm/utils/SupervisorClient.java | 161 | * @return the client, don't forget to close it when done. | COMMENT |
| LOW | …t/src/jvm/org/apache/storm/utils/SupervisorClient.java | 177 | * @return the client, don't forget to close it when done. | COMMENT |
| LOW | …t/src/jvm/org/apache/storm/utils/SupervisorClient.java | 192 | * @return the client, don't forget to close it when done. | COMMENT |
| LOW | …lient/src/jvm/org/apache/storm/utils/NimbusClient.java | 188 | * @return the client, don't forget to close it when done. | COMMENT |
| LOW | …lient/src/jvm/org/apache/storm/utils/NimbusClient.java | 201 | * @return the client, don't forget to close it when done. | COMMENT |
| LOW | …lient/src/jvm/org/apache/storm/utils/NimbusClient.java | 237 | * @return the client, don't forget to close it when done. | COMMENT |
| LOW | …lient/src/jvm/org/apache/storm/utils/NimbusClient.java | 251 | * @return the client, don't forget to close it when done. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | bin/storm.py | 243 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 601 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 1429 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 2228 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 2523 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 3930 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 4821 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 5161 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 5692 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 6743 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 7457 | CODE | |
| LOW | storm-client/src/py/storm/ttypes.py | 8922 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …/test/jvm/org/apache/storm/metrics2/EwmaGaugeTest.java | 118 | // Step 1: transit=10, prev=0, D=10, J = 0 + (10-0) * 0.5 = 5.0 | COMMENT |
| LOW⚡ | …/test/jvm/org/apache/storm/metrics2/EwmaGaugeTest.java | 122 | // Step 2: transit=0, prev=10, D=10, J = 5.0 + (10-5.0) * 0.5 = 7.5 | COMMENT |
| LOW⚡ | …/test/jvm/org/apache/storm/metrics2/EwmaGaugeTest.java | 126 | // Step 3: transit=10, prev=0, D=10, J = 7.5 + (10-7.5) * 0.5 = 8.75 | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …/test/jvm/org/apache/storm/metrics2/EwmaGaugeTest.java | 118 | // Step 1: transit=10, prev=0, D=10, J = 0 + (10-0) * 0.5 = 5.0 | COMMENT |
| LOW⚡ | …/test/jvm/org/apache/storm/metrics2/EwmaGaugeTest.java | 122 | // Step 2: transit=0, prev=10, D=10, J = 5.0 + (10-5.0) * 0.5 = 7.5 | COMMENT |
| LOW⚡ | …/test/jvm/org/apache/storm/metrics2/EwmaGaugeTest.java | 126 | // Step 3: transit=10, prev=0, D=10, J = 7.5 + (10-7.5) * 0.5 = 8.75 | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | bin/docker-to-squash.py | 240 | working_dir = "(undefined)" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | bin/storm.py | 1434 | Attributes: - sys_args: original system arguments - known_args: tokens argparse recognized as a declared | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | conf/defaults.yaml | 186 | # Define the amount of workers that can be run on this machine. Each worker is assigned a port to use for communication | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | dev-tools/cluster/netsim.sh | 32 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | storm-client/src/py/storm/__init__.py | 19 | __all__ = ['ttypes', 'constants', 'Nimbus', 'DistributedRPC', 'DistributedRPCInvocations', 'Supervisor'] | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …server/src/test/java/org/apache/storm/TestCgroups.java | 89 | String user = "dummy-user"; | CODE |