A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.
This report summarizes scanner evidence for akka/akka-core, a Scala project with 13,283 GitHub stars. SynthScan examined 700,958 lines of code across 3775 source files, recording 461 pattern matches distributed across 10 syntactic categories. The legacy adjusted pattern signal is 3.5 (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? 90 finding(s).
Are imports declared and package/API names verified? 230 finding(s).
Are wrappers, guards, and repeated structures necessary? 164 finding(s).
Which changes need focused human review? 461 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 461 distinct pattern matches across 10 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 | …ka/actor/testkit/typed/scaladsl/ActorTestKitSpec.scala | 113 | scalaTestWithActorTestKit2.testKit.system.settings.config.hasPath("test.from-application") should ===(false) | CODE |
| CRITICAL | …ala/akka/actor/testkit/typed/scaladsl/ManualTime.scala | 41 | "make sure to include akka.actor.testkit.typed.scaladsl.ManualTime.config() when setting up the test") | CODE |
| CRITICAL | …scala/akka/actor/testkit/typed/javadsl/TestProbe.scala | 43 | def fail(error: String): FishingOutcome = akka.actor.testkit.typed.FishingOutcome.Fail(error) | CODE |
| CRITICAL | …cala/akka/actor/testkit/typed/javadsl/ManualTime.scala | 42 | "make sure to include akka.actor.testkit.typed.scaladsl.ManualTime.config() when setting up the test") | CODE |
| CRITICAL | …/cluster/sharding/typed/ShardingMessageExtractor.scala | 80 | akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor.shardId(entityId, numberOfShards) | CODE |
| CRITICAL | …/cluster/sharding/typed/ShardingMessageExtractor.scala | 95 | akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor.shardId(entityId, numberOfShards) | CODE |
| CRITICAL | …a/cluster/sharding/typed/javadsl/ClusterSharding.scala | 360 | new akka.cluster.sharding.typed.scaladsl.Entity( | CODE |
| CRITICAL | …ster/sharding/typed/javadsl/ShardedDaemonProcess.scala | 23 | akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess(system).asJava | CODE |
| CRITICAL | …a/akka/actor/typed/scaladsl/adapter/PropsAdapter.scala | 23 | akka.actor.typed.internal.adapter.PropsAdapter( | CODE |
| CRITICAL | …/src/main/scala/akka/actor/typed/javadsl/Adapter.scala | 147 | akka.actor.typed.internal.adapter.PropsAdapter( | CODE |
| CRITICAL | …akka/cluster/ddata/typed/javadsl/DistributedData.scala | 51 | val distributedData = akka.cluster.ddata.typed.scaladsl.DistributedData(context.getSystem) | CODE |
| CRITICAL | …akka/cluster/ddata/typed/javadsl/DistributedData.scala | 94 | akka.cluster.ddata.typed.scaladsl.DistributedData(system).replicator.narrow[Replicator.Command] | CODE |
| CRITICAL | …akka/cluster/ddata/typed/javadsl/DistributedData.scala | 97 | akka.cluster.ddata.typed.scaladsl.DistributedData(system).selfUniqueAddress | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 912 | // Construct using akka.remote.testconductor.TestConductorProtocol.Wrapper.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2162 | // Construct using akka.remote.testconductor.TestConductorProtocol.Hello.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3003 | // Construct using akka.remote.testconductor.TestConductorProtocol.EnterBarrier.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3775 | // Construct using akka.remote.testconductor.TestConductorProtocol.AddressRequest.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4741 | // Construct using akka.remote.testconductor.TestConductorProtocol.Address.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 5749 | // Construct using akka.remote.testconductor.TestConductorProtocol.InjectFailure.newBuilder() | COMMENT |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 506 | return hello_ == null ? akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 513 | return hello_ == null ? akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 532 | return barrier_ == null ? akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : barr | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 539 | return barrier_ == null ? akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : barr | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 558 | return failure_ == null ? akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : fai | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 565 | return failure_ == null ? akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : fai | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 633 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : addr_ | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 640 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : addr_ | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 967 | return akka.remote.testconductor.TestConductorProtocol.Wrapper.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1064 | if (other == akka.remote.testconductor.TestConductorProtocol.Wrapper.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1194 | return hello_ == null ? akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1236 | hello_ != akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1279 | akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance() : hello_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1315 | return barrier_ == null ? akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1357 | barrier_ != akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1400 | akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance() : barrier_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1436 | return failure_ == null ? akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1478 | failure_ != akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1521 | akka.remote.testconductor.TestConductorProtocol.InjectFailure.getDefaultInstance() : failure_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1637 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : a | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1679 | addr_ != akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1722 | akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1943 | return address_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : address_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 1950 | return address_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : address_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2199 | return akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2278 | if (other == akka.remote.testconductor.TestConductorProtocol.Hello.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2447 | return address_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addre | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2489 | address_ != akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2532 | akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : address_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 2759 | akka.remote.testconductor.TestConductorProtocol.BarrierOp result = akka.remote.testconductor.TestConductorProtocol | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3031 | return akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3112 | if (other == akka.remote.testconductor.TestConductorProtocol.EnterBarrier.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3164 | akka.remote.testconductor.TestConductorProtocol.BarrierOp.forNumber(tmpRaw); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3289 | akka.remote.testconductor.TestConductorProtocol.BarrierOp result = akka.remote.testconductor.TestConductorProtoc | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3558 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3565 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3812 | return akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance(); | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 3891 | if (other == akka.remote.testconductor.TestConductorProtocol.AddressRequest.getDefaultInstance()) return this; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4059 | return addr_ == null ? akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4101 | addr_ != akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance()) { | CODE |
| CRITICAL | …a/akka/remote/testconductor/TestConductorProtocol.java | 4144 | akka.remote.testconductor.TestConductorProtocol.Address.getDefaultInstance() : addr_; | CODE |
| 141 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …-cluster/src/test/scala/akka/cluster/ClusterSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …ala/akka/cluster/ClusterDomainEventPublisherSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …akka/cluster/routing/ClusterRouterSupervisorSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …st/scala/akka/cluster/ddata/LocalConcurrencySpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …t/scala/akka/cluster/metrics/WeightedRouteesSpec.scala | 0 | akka.actor.provider = "cluster" akka.remote.artery.canonical.port = 0 | STRING |
| HIGH | …lti-jvm/scala/akka/cluster/ClusterDeathWatchSpec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/RestartNode3Spec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …m/scala/akka/remote/RemoteQuarantinePiercingSpec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …kka/remote/artery/RemoteRestartedQuarantinedSpec.scala | 0 | akka.loglevel = warning # test is using java serialization and not priority to rewrite akka.actor.allow-java-serializati | STRING |
| HIGH | …cala/akka/cluster/MultiDcHeartbeatTakingOverSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …src/multi-jvm/scala/akka/cluster/MultiDcJoinSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/MultiDcJoin2Spec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …i-jvm/scala/akka/cluster/MultiDcSunnyWeatherSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = alpha } | STRING |
| HIGH | …cala/akka/cluster/MultiDcHeartbeatTakingOverSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …src/multi-jvm/scala/akka/cluster/MultiDcJoinSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/MultiDcJoin2Spec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …i-jvm/scala/akka/cluster/MultiDcSunnyWeatherSpec.scala | 0 | akka { cluster.multi-data-center.self-data-center = beta } | STRING |
| HIGH | …lti-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …/multi-jvm/scala/akka/cluster/MultiDcClusterSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …multi-jvm/scala/akka/cluster/MultiDcLastNodeSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …luster/sharding/typed/MultiDcClusterShardingSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …a/akka/cluster/typed/MultiDcClusterSingletonSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/typed/PubSubSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc1" | STRING |
| HIGH | …lti-jvm/scala/akka/cluster/MultiDcSplitBrainSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …/multi-jvm/scala/akka/cluster/MultiDcClusterSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …multi-jvm/scala/akka/cluster/MultiDcLastNodeSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …luster/sharding/typed/MultiDcClusterShardingSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …a/akka/cluster/typed/MultiDcClusterSingletonSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …rc/multi-jvm/scala/akka/cluster/typed/PubSubSpec.scala | 0 | akka.cluster.multi-data-center.self-data-center = "dc2" | STRING |
| HIGH | …la/akka/cluster/sbr/IndirectlyConnected5NodeSpec.scala | 0 | akka { loglevel = info cluster { downing-provider-class = "akka.cluster.sbr.splitbrainresolverprovider" split-brain-reso | STRING |
| HIGH | …la/akka/cluster/sbr/IndirectlyConnected3NodeSpec.scala | 0 | akka { loglevel = info cluster { downing-provider-class = "akka.cluster.sbr.splitbrainresolverprovider" split-brain-reso | STRING |
| HIGH | …ster/sbr/DownAllWhenIndirectlyConnected3NodeSpec.scala | 0 | akka { loglevel = info cluster { downing-provider-class = "akka.cluster.sbr.splitbrainresolverprovider" split-brain-reso | STRING |
| HIGH | …/test/scala/akka/stream/io/TlsStageEdgeCasesSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …la/akka/stream/scaladsl/CancellationStrategySpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …test/scala/akka/io/dns/internal/TcpDnsClientSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …rc/test/scala/akka/io/dns/internal/DnsClientSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …/scala/akka/io/dns/internal/AsyncDnsResolverSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …cala/akka/pattern/BackoffOnRestartSupervisorSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …-actor-tests/src/test/scala/akka/pattern/AskSpec.scala | 0 | akka.loglevel = debug akka.loggers = ["akka.testkit.silencealltesteventlistener"] | STRING |
| HIGH | …/test/scala/akka/stream/scaladsl/FlowRecoverSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …rc/test/scala/akka/stream/scaladsl/RetryFlowSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …test/scala/akka/stream/scaladsl/FlowMapErrorSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/LazyFlowSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/LazySinkSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …c/test/scala/akka/stream/scaladsl/FlowBufferSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 1 akka.stream.materializer.max-input-buffer-size = 1 | STRING |
| HIGH | …/scala/akka/stream/scaladsl/FlowInitialDelaySpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …c/test/scala/akka/stream/scaladsl/FlowFilterSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/FlowScanSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/HeadSinkSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …/akka/stream/scaladsl/CoupledTerminationFlowSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …st/scala/akka/stream/scaladsl/GraphUnzipWithSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …test/scala/akka/stream/scaladsl/GraphPartialSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …rc/test/scala/akka/stream/scaladsl/FlowLimitSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …scala/akka/stream/scaladsl/FlowLimitWeightedSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …est/scala/akka/stream/scaladsl/FlowAlsoToAllSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …st/scala/akka/stream/scaladsl/FlowOnCompleteSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …st/scala/akka/stream/scaladsl/CollectionSinkSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …/test/scala/akka/stream/scaladsl/FlowGroupedSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| HIGH | …est/scala/akka/stream/scaladsl/FlowMapConcatSpec.scala | 0 | akka.stream.materializer.initial-input-buffer-size = 2 | STRING |
| 81 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …kka/actor/testkit/typed/internal/ActorSystemStub.scala | 141 | // this is backward compatible with the old behaviour, hence it uses the loader used to load the test-kit | COMMENT |
| LOW | …ts/src/test/java/akka/stream/javadsl/GraphDslTest.java | 221 | } | COMMENT |
| LOW | …akka/remote/artery/RollingEventLogSimulationSpec.scala | 161 | COMMENT | |
| LOW | …/scala/akka/remote/artery/tcp/ArteryTcpTransport.scala | 281 | serverBinding = Some(binding) | COMMENT |
| LOW | …test/scala/akka/cluster/sharding/SupervisionSpec.scala | 141 | ClusterShardingSettings(system), | COMMENT |
| LOW | akka-pki/src/main/scala/akka/pki/pem/PEMDecoder.scala | 21 | // Luckily, Java Pattern's \s matches the RFCs W ABNF expression perfectly | COMMENT |
| LOW | …r-tests/src/test/scala/akka/util/TokenBucketSpec.scala | 121 | bucket.init() | COMMENT |
| LOW | scripts/release-prep.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/multi-node-log-replace.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | kubernetes/create-cluster-gke.sh | 1 | #!/bin/bash -e | COMMENT |
| LOW | …ctor/src/main/scala/akka/routing/SmallestMailbox.scala | 41 | else selectNext(routees) | COMMENT |
| LOW | akka-docs/src/test/java/jdocs/stream/HubDocTest.java | 101 | Source<String, NotUsed> source = sinkAndSource.second(); | COMMENT |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 21 | // #or-else | COMMENT |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 41 | // #concat | COMMENT |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 501 | void takeExample() { | COMMENT |
| LOW | …/java/jdocs/stream/operators/sourceorflow/Sliding.java | 21 | // [1, 2] | COMMENT |
| LOW | …ava/jdocs/stream/operators/sourceorflow/MapConcat.java | 21 | void example() { | COMMENT |
| LOW | …st/java/jdocs/stream/operators/sourceorflow/Split.java | 101 | // 6 | COMMENT |
| LOW | …a/jdocs/stream/operators/sourceorflow/MergeLatest.java | 21 | prices | COMMENT |
| LOW | …c/test/java/jdocs/stream/operators/source/Restart.java | 41 | // logs | COMMENT |
| LOW | …c/test/java/jdocs/stream/operators/source/Restart.java | 61 | // --> 2 second gap | COMMENT |
| LOW | …s/src/test/java/jdocs/stream/operators/source/Zip.java | 81 | // this will print | COMMENT |
| LOW | …c/test/java/jdocs/stream/operators/source/Combine.java | 61 | // 10 | COMMENT |
| LOW | …/src/test/java/jdocs/stream/operators/source/From.java | 21 | // 1 | COMMENT |
| LOW | …test/java/jdocs/stream/operators/flow/StatefulMap.java | 101 | // 3 | COMMENT |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 481 | final ActorRef persistentActor = system.actorOf(Props.create(MyPersistentActor.class)); | COMMENT |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 581 | COMMENT | |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 641 | COMMENT | |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 701 | // #safe-shutdown | COMMENT |
| LOW | …t/java/jdocs/persistence/LambdaPersistenceDocTest.java | 721 | // SAFE: | COMMENT |
| LOW | akka-docs/src/test/java/jdocs/actor/ActorDocTest.java | 301 | // #preStart | COMMENT |
| LOW | …st/scala/docs/serialization/SerializationDocSpec.scala | 21 | //#marker-interface | COMMENT |
| LOW | …t/scala/docs/stream/operators/sourceorflow/Split.scala | 41 | .splitWhen(_._2) // split when time bucket changes | COMMENT |
| LOW | …t/scala/docs/stream/operators/sourceorflow/Split.scala | 81 | .map(_.head._1) | COMMENT |
| LOW | …a/docs/stream/operators/sourceorflow/MergeLatest.scala | 21 | .runForeach(println) | COMMENT |
| LOW | …scala/docs/stream/operators/sourceorflow/Sliding.scala | 41 | // 4.4 = average of 3, 10, 2, 3, 4 | COMMENT |
| LOW | …ala/docs/stream/operators/sourceorflow/MapConcat.scala | 21 | // 1 | COMMENT |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 41 | longWords.runForeach(println) | COMMENT |
| LOW | …src/test/scala/docs/stream/operators/source/From.scala | 21 | // 2 | COMMENT |
| LOW | …/test/scala/docs/stream/operators/source/Restart.scala | 41 | // --> 1 second gap | COMMENT |
| LOW | …/src/test/scala/docs/stream/operators/source/Zip.scala | 41 | // 5 | COMMENT |
| LOW | …/src/test/scala/docs/stream/operators/source/Zip.scala | 61 | // #zipAll-simple | COMMENT |
| LOW | …/test/scala/docs/stream/operators/source/Combine.scala | 21 | val source3 = Source(12 to 14) | COMMENT |
| LOW | …/test/scala/docs/stream/operators/source/Combine.scala | 41 | val source2 = Source(8 to 10) | COMMENT |
| LOW | …est/scala/docs/stream/operators/flow/StatefulMap.scala | 81 | //prints | COMMENT |
| LOW | …ala/docs/stream/cookbook/RecipeCollectingMetrics.scala | 21 | // //#periodic-metrics-collection | COMMENT |
| LOW | …ala/docs/stream/cookbook/RecipeCollectingMetrics.scala | 41 | // manualTick.sendNext(()) | COMMENT |
| LOW | …ala/docs/stream/cookbook/RecipeCollectingMetrics.scala | 61 | // **Situation:** Given performance counters expressed as a stream of updates we want to gather a periodic re | COMMENT |
| LOW | …c/test/scala/docs/persistence/PersistenceDocSpec.scala | 341 | } | COMMENT |
| LOW | …c/test/scala/docs/persistence/PersistenceDocSpec.scala | 441 | persistentActor ! PoisonPill | COMMENT |
| LOW | …c/test/scala/docs/persistence/PersistenceDocSpec.scala | 461 | // b | COMMENT |
| LOW | …src/test/scala/typed/tutorial_5/DeviceGroupQuery.scala | 121 | } | COMMENT |
| LOW | akka-docs/src/main/paradox/general/configuration.md | 101 | # Logger config for Akka internals and classic actors, the new API relies | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 35 | """Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolo | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 35 | """Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolo | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 37 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 37 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 39 | et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 40 | sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 40 | sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 42 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 42 | gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 46 | dolore te feugait nulla facilisi. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 46 | dolore te feugait nulla facilisi. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 55 | assum. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt ut laoreet | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 55 | assum. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt ut laoreet | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 63 | ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 63 | ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 65 | Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 65 | Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 68 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 68 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 73 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy e""".replace( | STRING |
| LOW⚡ | …cala/akka/stream/io/compression/CodecSpecSupport.scala | 73 | est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy e""".replace( | STRING |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 527 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 527 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 546 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …src/test/java/jdocs/stream/operators/SourceOrFlow.java | 546 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 19 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 19 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 36 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| LOW | …/scala/docs/stream/operators/sourceorflow/Filter.scala | 36 | ("Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt " + | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ream/src/main/scala/akka/stream/stage/GraphStage.scala | 1018 | private def setOrAddEmitting[T](out: Outlet[T], next: Emitting[T]): Unit = | CODE |
| LOW | …t/src/test/scala/akka/testkit/metrics/MetricsKit.scala | 153 | private[metrics] def getOrRegister[M <: Metric](key: String, metric: => M)(implicit tag: ClassTag[M]): M = { | CODE |
| LOW | …rc/main/scala/akka/remote/artery/LruBoundedCache.scala | 79 | final def getOrCompute(k: K): V = | CODE |
| LOW | …te/src/main/scala/akka/remote/artery/Association.scala | 792 | private def getOrCreateQueueWrapper(queueIndex: Int, capacity: Int): QueueWrapper = { | CODE |
| LOW | …src/main/scala/akka/stream/GraphBuilderBenchmark.scala | 27 | def graph_with_junctions_gradual(): RunnableGraph[NotUsed] = | CODE |
| LOW | …src/main/scala/akka/stream/GraphBuilderBenchmark.scala | 31 | def graph_with_junctions_immediate(): RunnableGraph[NotUsed] = | CODE |
| LOW | …/main/scala/akka/stream/MaterializationBenchmark.scala | 129 | def graph_with_junctions_gradual(): NotUsed = graphWithJunctionsGradual.run() | CODE |
| LOW | …/main/scala/akka/stream/MaterializationBenchmark.scala | 132 | def graph_with_junctions_immediate(): NotUsed = graphWithJunctionsImmediate.run() | CODE |
| LOW | …/src/main/scala/akka/stream/FusedGraphsBenchmark.scala | 289 | def broadcast_zip_balance_merge(blackhole: org.openjdk.jmh.infra.Blackhole): Unit = { | STRING |
| LOW | …ted-data/src/main/scala/akka/cluster/ddata/ORMap.scala | 213 | def getOrElse(key: A, default: => B): B = values.getOrElse(key, default) | CODE |
| LOW | …ata/src/main/scala/akka/cluster/ddata/ORMultiMap.scala | 129 | def getOrElse(key: A, default: => Set[B]): Set[B] = | CODE |
| LOW | …rding/src/main/scala/akka/cluster/sharding/Shard.scala | 1145 | def getOrCreateEntity(id: EntityId): ActorRef = { | CODE |
| LOW | …nce/src/main/scala/akka/persistence/Eventsourced.scala | 121 | private def getAndClearInstrumentationContext(seqNr: Long): EventsourcedInstrumentation.Context = { | CODE |
| LOW | akka-actor/src/main/scala/akka/util/MessageBuffer.scala | 213 | private def getOrAddBuffer(id: I): MessageBuffer = { | CODE |
| LOW | akka-actor/src/main/scala/akka/util/MessageBuffer.scala | 279 | def getOrEmpty(id: I): MessageBuffer = { | CODE |
| LOW | akka-actor/src/main/scala/akka/util/OptionVal.scala | 57 | def getOrElse[B >: A](default: B): B = | CODE |
| LOW | …/main/scala/akka/pattern/CircuitBreakersRegistry.scala | 73 | private[akka] def getOrCreate(id: String, config: Config): CircuitBreaker = | CODE |
| LOW | …main/scala/akka/actor/dungeon/LicenseKeySupplier.scala | 24 | def implementing_this_is_a_violation_of_the_akka_license(): Unit | CODE |
| LOW | akka-actor/src/main/scala/akka/japi/JavaAPI.scala | 175 | def getOrElse[B >: A](defaultValue: B): B | CODE |
| LOW | akka-actor/src/main/scala/akka/japi/JavaAPI.scala | 214 | def getOrElse[B >: A](defaultValue: B): B = v | CODE |
| LOW | akka-actor/src/main/scala/akka/japi/JavaAPI.scala | 224 | def getOrElse[B](defaultValue: B): B = defaultValue | CODE |
| LOW | …erialization/jackson/JacksonObjectMapperProvider.scala | 334 | def getOrCreate(bindingName: String, jsonFactory: Option[JsonFactory]): ObjectMapper = { | CODE |
| LOW | …erialization/jackson/JacksonObjectMapperProvider.scala | 353 | def getOrCreate(bindingName: String, jsonFactory: Optional[JsonFactory]): ObjectMapper = | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …testkit/src/test/scala/akka/testkit/AkkaSpecSpec.scala | 39 | // verbose config just for demonstration purposes, please leave in in case of debugging | COMMENT |
| LOW | …n/scala/akka/persistence/journal/JournalPerfSpec.scala | 119 | * methods (don't forget to call `super` in your overridden methods). | STRING |
| LOW | …/main/scala/akka/persistence/journal/JournalSpec.scala | 36 | * methods (don't forget to call `super` in your overridden methods). | STRING |
| LOW | …cala/akka/persistence/snapshot/SnapshotStoreSpec.scala | 35 | * methods (don't forget to call `super` in your overridden methods). | STRING |
| LOW | …kka/persistence/japi/journal/JavaJournalPerfSpec.scala | 41 | * methods (don't forget to call `super` in your overridden methods). | COMMENT |
| LOW | …la/akka/persistence/japi/journal/JavaJournalSpec.scala | 21 | * methods (don't forget to call `super` in your overridden methods). | COMMENT |
| LOW | …/persistence/japi/snapshot/JavaSnapshotStoreSpec.scala | 22 | * methods (don't forget to call `super` in your overridden methods). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | akka-remote/src/test/resources/ssl/gen-functions.sh | 11 | # Create a certificate used for peer-to-peer, under the example.com CA | COMMENT |
| MEDIUM | akka-remote/src/test/resources/ssl/gen-functions.sh | 24 | # Create a certificate signing request for $PREFIX.example.com | COMMENT |
| MEDIUM | akka-remote/src/test/resources/ssl/genca.sh | 5 | # Create a self signed key pair root CA certificate. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …src/main/scala/akka/stream/impl/TraversalBuilder.scala | 973 | * Since the exposed output port has been wired optimistically to -1, we need to check if this is correct, | COMMENT |
| LOW | …a-stream/src/main/scala/akka/stream/scaladsl/Hub.scala | 659 | * we need to check if it was blocking us from advancing (being the slowest). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/typed/internal/receptionist/ClusterReceptionist.scala | 242 | // which is possible for OR CRDTs - done with an adapter to leverage the existing NodesRemoved message | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | kubernetes/create-cluster-gke.sh | 17 | # Usage: | COMMENT |