Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
This report summarizes scanner evidence for hazelcast/hazelcast, a Java project with 6,627 GitHub stars. SynthScan examined 2,273,844 lines of code across 12674 source files, recording 514 pattern matches distributed across 14 syntactic categories. The legacy adjusted pattern signal is 0.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? 426 finding(s).
Are imports declared and package/API names verified? 87 finding(s).
Are wrappers, guards, and repeated structures necessary? 14 finding(s).
Which changes need focused human review? 514 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 514 distinct pattern matches across 14 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 | …sql/impl/opt/physical/visitor/RexToExpressionTest.java | 189 | return org.apache.calcite.util.Sarg.of(RexUnknownAs.UNKNOWN, rangeSet(left, right)); | CODE |
| CRITICAL | …sql/impl/opt/physical/visitor/RexToExpressionTest.java | 193 | return ImmutableRangeSet.of(com.google.common.collect.Range.closed(left, right)); | CODE |
| CRITICAL | docs/design/jet/017-file-data-ingestion.md | 80 | `com.hazelcast.jet.x.XSources.x(...., formatY)` | CODE |
| CRITICAL | docs/design/jet/017-file-data-ingestion.md | 81 | `com.hazelcast.jet.s3.S3Sources.s3(..., Avro)` | CODE |
| CRITICAL | …t/java/com/hazelcast/jet/python/PythonServiceTest.java | 97 | com.hazelcast.internal.nio.IOUtil.delete(baseDir); | CODE |
| CRITICAL | …lcast/jet/hadoop/impl/FileNotFoundReadHadoopPTest.java | 89 | org.apache.hadoop.mapreduce.lib.input.FileInputFormat.addInputPath(job, path); | CODE |
| CRITICAL | …lcast/jet/hadoop/impl/FileNotFoundReadHadoopPTest.java | 97 | org.apache.hadoop.mapred.FileInputFormat.addInputPath(jobConf, path); | CODE |
| CRITICAL | …va/com/hazelcast/jet/hadoop/impl/WriteHadoopPTest.java | 139 | org.apache.hadoop.mapreduce.lib.input.FileInputFormat.addInputPath(job, path); | CODE |
| CRITICAL | …va/com/hazelcast/jet/hadoop/impl/WriteHadoopPTest.java | 157 | org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.setOutputPath(job, path); | CODE |
| CRITICAL | …va/com/hazelcast/jet/hadoop/impl/WriteHadoopPTest.java | 159 | org.apache.hadoop.mapreduce.lib.output.LazyOutputFormat.setOutputFormatClass(job, | CODE |
| CRITICAL | …ava/com/hazelcast/jet/hadoop/impl/ReadHadoopPTest.java | 124 | org.apache.hadoop.mapreduce.lib.input.FileInputFormat.addInputPath(job, path); | CODE |
| CRITICAL | …ava/com/hazelcast/jet/hadoop/impl/ReadHadoopPTest.java | 132 | org.apache.hadoop.mapred.FileInputFormat.addInputPath(jobConf, path); | CODE |
| CRITICAL | …ava/com/hazelcast/jet/hadoop/impl/JsonInputFormat.java | 159 | // We could use org.apache.hadoop.fs.FileSystem.getFileStatus() to get length, but it results in an extra | COMMENT |
| CRITICAL | …hazelcast/test/archunit/TestsHaveRunnersCondition.java | 43 | "com.hazelcast.spi.properties.HazelcastProperty.setSystemProperty(java.lang.String)"); | CODE |
| CRITICAL | …/test/java/com/hazelcast/jet/impl/util/IOUtilTest.java | 73 | com.hazelcast.internal.nio.IOUtil.delete(randomFile); | CODE |
| CRITICAL | …/test/java/com/hazelcast/jet/impl/util/IOUtilTest.java | 163 | com.hazelcast.internal.nio.IOUtil.delete(tmpTargetDir); | CODE |
| CRITICAL | …/test/java/com/hazelcast/jet/impl/util/IOUtilTest.java | 164 | com.hazelcast.internal.nio.IOUtil.delete(tmpNonTargetDir); | CODE |
| CRITICAL | …/java/com/hazelcast/jet/config/ResourceConfigTest.java | 59 | com.hazelcast.internal.nio.IOUtil.delete(baseDir); | CODE |
| CRITICAL | …java/com/hazelcast/cache/HazelcastCachingProvider.java | 179 | com.hazelcast.client.cache.HazelcastClientCachingProvider.class.getName(); | CODE |
| CRITICAL | …ava/com/hazelcast/jet/impl/JobCoordinationService.java | 1521 | return com.hazelcast.jet.impl.util.Util.exceptionallyCompletedFuture(e); | CODE |
| CRITICAL | …n/java/com/hazelcast/jet/impl/JobExecutionService.java | 593 | if (com.hazelcast.internal.util.ExceptionUtil.isOrHasCause(e, CancellationException.class)) { | CODE |
| CRITICAL | …com/hazelcast/internal/monitor/impl/NodeStateImpl.java | 112 | nodeState = com.hazelcast.instance.impl.NodeState.valueOf(jsonNodeState); | CODE |
| CRITICAL | …in/java/com/hazelcast/internal/util/ExceptionUtil.java | 229 | * software.amazon.awssdk.core.exception.SdkException.builder().message(String).cause(Throwable).build() | COMMENT |
| CRITICAL | …in/java/com/hazelcast/internal/util/ExceptionUtil.java | 364 | // software.amazon.awssdk.core.exception.SdkException.builder().message(String).cause(Throwable).build() | COMMENT |
| CRITICAL⚡ | …t/impl/protocol/DefaultMessageTaskFactoryProvider.java | 1784 | (cm, con) -> new com.hazelcast.cp.internal.datastructures.atomicref.client.ApplyMessageTask(cm, node, co | CODE |
| CRITICAL⚡ | …t/impl/protocol/DefaultMessageTaskFactoryProvider.java | 1790 | (cm, con) -> new com.hazelcast.cp.internal.datastructures.atomicref.client.GetMessageTask(cm, node, con) | CODE |
| CRITICAL⚡ | …t/impl/protocol/DefaultMessageTaskFactoryProvider.java | 1792 | (cm, con) -> new com.hazelcast.cp.internal.datastructures.atomicref.client.CompareAndSetMessageTask(cm, | CODE |
| CRITICAL⚡ | …t/impl/protocol/DefaultMessageTaskFactoryProvider.java | 1838 | (cm, con) -> new com.hazelcast.cp.internal.datastructures.cpmap.client.GetMessageTask(cm, node, con)); | CODE |
| CRITICAL⚡ | …t/impl/protocol/DefaultMessageTaskFactoryProvider.java | 1842 | (cm, con) -> new com.hazelcast.cp.internal.datastructures.cpmap.client.SetMessageTask(cm, node, con)); | CODE |
| CRITICAL⚡ | …t/impl/protocol/DefaultMessageTaskFactoryProvider.java | 1848 | (cm, con) -> new com.hazelcast.cp.internal.datastructures.cpmap.client.CompareAndSetMessageTask(cm, node | CODE |
| CRITICAL | …/protocol/codec/custom/NearCacheConfigHolderCodec.java | 86 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.NearCacheConfigHolder(name, inMemoryFormat, ser | CODE |
| CRITICAL | …ol/codec/custom/ReplicatedMapEntryViewHolderCodec.java | 80 | return new com.hazelcast.replicatedmap.impl.record.ReplicatedMapEntryViewHolder(key, value, creationTime, hits, | CODE |
| CRITICAL | …rotocol/codec/custom/DiscoveryStrategyConfigCodec.java | 59 | return new com.hazelcast.client.impl.protocol.codec.holder.DiscoveryStrategyConfigHolder(className, properties); | CODE |
| CRITICAL | …client/impl/protocol/codec/custom/VectorPairCodec.java | 68 | return new com.hazelcast.client.impl.protocol.codec.holder.VectorPairHolder(name, type, vector); | CODE |
| CRITICAL | …/protocol/codec/custom/PredicateConfigHolderCodec.java | 61 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.PredicateConfigHolder(className, sql, implement | CODE |
| CRITICAL | …l/protocol/codec/custom/AnchorDataListHolderCodec.java | 59 | return new com.hazelcast.client.impl.protocol.codec.holder.AnchorDataListHolder(anchorPageList, anchorDataList); | CODE |
| CRITICAL | …/codec/custom/WanCustomPublisherConfigHolderCodec.java | 63 | return new com.hazelcast.client.impl.protocol.codec.holder.WanCustomPublisherConfigHolder(publisherId, className | CODE |
| CRITICAL | …l/protocol/codec/custom/ListenerConfigHolderCodec.java | 74 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.ListenerConfigHolder(listenerType, listenerImpl | CODE |
| CRITICAL | …st/client/impl/protocol/codec/custom/MCEventCodec.java | 69 | return new com.hazelcast.internal.management.dto.MCEventDTO(timestamp, type, dataJson); | CODE |
| CRITICAL | …l/protocol/codec/custom/EvictionConfigHolderCodec.java | 72 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.EvictionConfigHolder(size, maxSizePolicy, evict | CODE |
| CRITICAL | …impl/protocol/codec/custom/CacheConfigHolderCodec.java | 140 | return new com.hazelcast.client.impl.protocol.codec.holder.CacheConfigHolder(name, managerPrefix, uriString, bac | CODE |
| CRITICAL | …protocol/codec/custom/QueryCacheConfigHolderCodec.java | 99 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.QueryCacheConfigHolder(batchSize, bufferSize, d | CODE |
| CRITICAL | …rotocol/codec/custom/WanConsumerConfigHolderCodec.java | 70 | return new com.hazelcast.client.impl.protocol.codec.holder.WanConsumerConfigHolder(persistWanReplicatedData, cla | CODE |
| CRITICAL | …elcast/client/impl/protocol/codec/custom/XidCodec.java | 68 | return new com.hazelcast.transaction.impl.xa.SerializableXID(formatId, globalTransactionId, branchQualifier); | CODE |
| CRITICAL | …l/codec/custom/WanBatchPublisherConfigHolderCodec.java | 131 | return new com.hazelcast.client.impl.protocol.codec.holder.WanBatchPublisherConfigHolder(publisherId, className, | CODE |
| CRITICAL | …t/impl/protocol/codec/custom/DiscoveryConfigCodec.java | 63 | return new com.hazelcast.client.impl.protocol.codec.holder.DiscoveryConfigHolder(discoveryStrategyConfigs, disco | CODE |
| CRITICAL | …mpl/protocol/codec/custom/ResourceDefinitionCodec.java | 70 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.ResourceDefinitionHolder(id, resourceType, payl | CODE |
| CRITICAL | …/protocol/codec/custom/DistributedObjectInfoCodec.java | 59 | return new com.hazelcast.client.impl.client.DistributedObjectInfo(serviceName, name); | CODE |
| CRITICAL | …l/protocol/codec/custom/MapStoreConfigHolderCodec.java | 93 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.MapStoreConfigHolder(enabled, writeCoalescing, | CODE |
| CRITICAL | …/protocol/codec/custom/PagingPredicateHolderCodec.java | 85 | return new com.hazelcast.client.impl.protocol.codec.holder.PagingPredicateHolder(anchorDataListHolder, predicate | CODE |
| CRITICAL | …col/codec/custom/RingbufferStoreConfigHolderCodec.java | 74 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.RingbufferStoreConfigHolder(className, factoryC | CODE |
| CRITICAL | …t/client/impl/protocol/codec/custom/SqlErrorCodec.java | 83 | return new com.hazelcast.sql.impl.client.SqlError(code, message, originatingMemberId, isSuggestionExists, sugges | CODE |
| CRITICAL | …lient/impl/protocol/codec/custom/ErrorHolderCodec.java | 70 | return new com.hazelcast.client.impl.protocol.exception.ErrorHolder(errorCode, className, message, stackTraceEle | CODE |
| CRITICAL | …protocol/codec/custom/QueueStoreConfigHolderCodec.java | 74 | return new com.hazelcast.client.impl.protocol.task.dynamicconfig.QueueStoreConfigHolder(className, factoryClassN | CODE |
| CRITICAL | …ent/impl/protocol/codec/custom/WanSyncConfigCodec.java | 62 | return new com.hazelcast.client.impl.protocol.codec.holder.WanSyncConfigHolder(consistencyCheckStrategy); | CODE |
| CRITICAL | …lcast/client/cache/HazelcastClientCachingProvider.java | 58 | delegate = new com.hazelcast.client.cache.impl.HazelcastClientCachingProvider(); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …in/java/com/hazelcast/jet/sql/impl/ExpressionUtil.java | 61 | } | COMMENT |
| LOW | …ast/jet/sql/impl/opt/ExtractUpdateExpressionsRule.java | 81 | // We do not perform this transformation for IMap because: | COMMENT |
| LOW | …l/opt/physical/AggregateSlidingWindowPhysicalRule.java | 121 | COMMENT | |
| LOW | …/com/hazelcast/jet/kinesis/KinesisIntegrationTest.java | 441 | @Test | COMMENT |
| LOW | …rces/hazelcast-fullconfig-advanced-network-config.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | hazelcast/src/test/resources/test-hazelcast-client.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | hazelcast/src/test/resources/hazelcast-fullconfig.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | hazelcast/src/test/resources/hazelcast-client-c2.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …elcast/src/test/resources/test-hazelcast-variable.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | hazelcast/src/test/resources/hazelcast-client-full.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …st/resources/hazelcast-fullconfig-without-network.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …st/resources/hazelcast-fullconfig-without-network.yaml | 21 | # | COMMENT |
| LOW | …st/resources/hazelcast-fullconfig-without-network.yaml | 221 | # throughput. Valid values are: | COMMENT |
| LOW | …st/resources/hazelcast-fullconfig-without-network.yaml | 261 | # While recovering from split-brain (network partitioning), data structure entries in the small cluster | COMMENT |
| LOW | hazelcast/src/test/resources/test-hazelcast.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …src/test/resources/test-hazelcast-client-variable.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | hazelcast/src/test/resources/hazelcast-client-c1.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …t/src/test/resources/test-hazelcast-client-simple.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …azelcast/client/console/hazelcast-client-template.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …om/hazelcast/client/console/hazelcast-client-test.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …m/hazelcast/durableexecutor/DurableSingleNodeTest.java | 181 | assertTrue(executor.isTerminated()); | COMMENT |
| LOW | …m/hazelcast/durableexecutor/DurableSingleNodeTest.java | 201 | // future.get(); | COMMENT |
| LOW | …java/com/hazelcast/jet/SimpleTestInClusterSupport.java | 181 | // so after next test they will not be visible in getDistributedObjects() | COMMENT |
| LOW | …/com/hazelcast/jet/core/IndeterminateSnapshotTest.java | 481 | setupJetTests(allowedSnapshotsCount); | COMMENT |
| LOW | …ava/com/hazelcast/internal/util/ServiceLoaderTest.java | 121 | public void testMultipleClassloaderLoadsTheSameClass_fromParentClassLoader() throws Exception { | COMMENT |
| LOW | …/hazelcast/internal/util/collection/OAHashSetTest.java | 581 | final IntegerWithFixedHashCode element4 = new IntegerWithFixedHashCode(4, 4); | COMMENT |
| LOW | …ast/spi/impl/AbstractInvocationFuture_AndThenTest.java | 41 | // } | COMMENT |
| LOW | …ast/spi/impl/AbstractInvocationFuture_AndThenTest.java | 61 | // | COMMENT |
| LOW | …ast/spi/impl/AbstractInvocationFuture_AndThenTest.java | 81 | // assertTrueEventually(() -> verify(callback).onResponse(value)); | COMMENT |
| LOW | …ast/spi/impl/AbstractInvocationFuture_AndThenTest.java | 101 | // | COMMENT |
| LOW | …ast/spi/impl/AbstractInvocationFuture_AndThenTest.java | 121 | // | COMMENT |
| LOW | …om/hazelcast/client/pncounter/ClientPNCounterTest.java | 61 | // member list. When the client connects to a new cluster, the member list | COMMENT |
| LOW | …cast/client/queue/ClientQueuePerformanceBenchmark.java | 41 | server = Hazelcast.newHazelcastInstance(); | COMMENT |
| LOW | …cast/client/queue/ClientQueuePerformanceBenchmark.java | 61 | // } else { | COMMENT |
| LOW | …cast/client/queue/ClientQueuePerformanceBenchmark.java | 81 | // Thread.sleep(10 * 1000); | COMMENT |
| LOW | …/resources/hazelcast-client-failover-full-example.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …/resources/hazelcast-client-failover-full-example.yaml | 21 | # | COMMENT |
| LOW | …/main/resources/hazelcast-client-default-assembly.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 1 | # Copyright (c) 2008-2026, Hazelcast, Inc. All Rights Reserved. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 21 | # To learn how to configure Hazelcast, please see the Reference Manual | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 41 | # Below is an example showing property placeholders: | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 81 | license-key: Your Hazelcast Enterprise or Enterprise HD License Key | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 101 | # Default value is true. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 121 | # The "properties" mapping lets you add properties to some of the Hazelcast elements used to configure some of | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 141 | # The configuration element's name is "wan-replication". It has two attributes: | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 161 | # If there is no publisher ID defined (it is empty), the cluster name will | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 181 | # - ACK_ON_RECEIPT: | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 201 | # switched to this state. WAN sync is enabled. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 221 | # partition are now sent randomly to any available target endpoint. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 241 | # By default this property is false which means the WAN connection | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 261 | # lost. Therefore, if you have a large rate of put/update/remove operations, | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 281 | # Secret key of your account on EC2. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 301 | # Please refer to | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 321 | # Custom implementation of a WAN publisher implementing WanPublisher. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 381 | # tag-value: hz-nodes | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 401 | # prop1: prop1-value | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 421 | # willing to have only a few ports assigned. port-count is optional and its default value is 100. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 441 | # - 33000-35000 | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 461 | # sends discovery messages through. Its default value is 54327. | COMMENT |
| LOW | …zelcast/src/main/resources/hazelcast-full-example.yaml | 481 | # to connect to a cluster. Setting it to a too high value means that member startup could | COMMENT |
| 304 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …elcast/jet/sql/impl/opt/physical/SortPhysicalRule.java | 113 | // Input has less collated fields than sort. Definitely not a prefix => local sorting is needed. | COMMENT |
| MEDIUM | …rces/hazelcast-fullconfig-advanced-network-config.yaml | 15 | # A comprehensive example of Hazelcast configuration with advanced network configuration. | COMMENT |
| MEDIUM | hazelcast/src/test/resources/hazelcast-fullconfig.yaml | 15 | # A comprehensive example of Hazelcast configuration. | COMMENT |
| MEDIUM | …st/resources/hazelcast-fullconfig-without-network.yaml | 15 | # A comprehensive example of Hazelcast configuration without network configuration. | COMMENT |
| MEDIUM | …zelcast/flakeidgen/impl/FlakeIdGeneratorProxyTest.java | 247 | // #### Tests pertaining to wait time #### | COMMENT |
| MEDIUM | …/com/hazelcast/test/jdbc/PostgresDatabaseProvider.java | 83 | // If we wait for both conditions (port and log) we should get robust behavior. | COMMENT |
| MEDIUM | …azelcast/client/cp/internal/CPGroupViewClientTest.java | 73 | // Assert the client is still able to utilize the CP subsystem | COMMENT |
| MEDIUM | …ain/java/com/hazelcast/jet/core/ProcessorSupplier.java | 182 | * Returns the partitions from {@link #partitionAssignment()} pertaining to | COMMENT |
| MEDIUM | …peration/PartitionWideEntryWithPredicateOperation.java | 55 | // if we used index we leverage it for the backup too | COMMENT |
| MEDIUM | …st/map/impl/operation/PartitionWideEntryOperation.java | 193 | // if we reach here, it means we didn't manage to leverage index and we fall-back to full-partition scan | COMMENT |
| MEDIUM | …st/map/impl/operation/PartitionWideEntryOperation.java | 271 | // if we used index we leverage it for the backup too | COMMENT |
| MEDIUM | …ain/java/com/hazelcast/map/impl/query/QueryRunner.java | 294 | // leverage index on this node in a global way. | COMMENT |
| MEDIUM | …m/hazelcast/cp/internal/raft/impl/state/RaftState.java | 554 | * Resets {@link #lastGroupMembers} back to {@link #committedGroupMembers}. Essentially this means, | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …java/com/hazelcast/jet/python/PythonServiceConfig.java | 42 | * Here's a simple example of a function that transforms every input | COMMENT |
| MEDIUM | …/main/java/com/hazelcast/jet/hadoop/HadoopSources.java | 61 | * Here is how you can configure the source. Default and always safe value is | COMMENT |
| MEDIUM | …/main/java/com/hazelcast/jet/hadoop/HadoopSources.java | 78 | * Here is how you can configure the source. Default value is {@code false}: | COMMENT |
| LOW | …on/compatibility/BinaryCompatibilityFileGenerator.java | 46 | // DON'T FORGET TO CHANGE VERSION ACCORDINGLY | COMMENT |
| MEDIUM | …zelcast/src/main/resources/hazelcast-full-example.yaml | 303 | # to see the properties you can use. | COMMENT |
| MEDIUM | …zelcast/src/main/resources/hazelcast-full-example.yaml | 523 | # to see the properties you can use. | COMMENT |
| MEDIUM | …zelcast/src/main/resources/hazelcast-full-example.yaml | 3036 | # to see the properties you can use. | COMMENT |
| MEDIUM | hazelcast/src/main/resources/hazelcast-default.yaml | 162 | # configuration. This way, you can add different and multiple interfaces to | COMMENT |
| LOW | hazelcast/src/main/resources/hazelcast-default.yaml | 53 | # mechanism, so make sure to enable only one. | COMMENT |
| MEDIUM | …/src/main/resources/hazelcast-client-full-example.yaml | 217 | # to see the properties you can use. | COMMENT |
| LOW | …/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java | 75 | * request to start iteration. Also don't forget to set newIteration to true. Then, use the returned | COMMENT |
| MEDIUM | …lcast/src/main/config-template/hazelcast-assembly.yaml | 130 | # configuration. This way, you can add different and multiple interfaces to | COMMENT |
| LOW | …lcast/src/main/config-template/hazelcast-assembly.yaml | 53 | # mechanism, so make sure to enable only one. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java | 56 | "SELECT name FROM people WHERE name = 'John Doe'", | CODE |
| LOW | …nector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java | 78 | "SELECT name FROM people WHERE name IN ('John Doe', 'something')", | CODE |
| LOW | …nector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java | 79 | "SELECT name FROM people WHERE name NOT IN ('Jane Doe', 'something')", | CODE |
| LOW | …nector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java | 138 | executeJdbc("INSERT INTO " + quote(tableName) + " VALUES (1, 'John Doe', 30, '{\"value\":42}', 1, 1, 0, " + | CODE |
| LOW | …nector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java | 140 | executeJdbc("INSERT INTO " + quote(tableName) + " VALUES (2, 'Jane Doe', 35, '{\"value\":0}', 0, 0, 1, " + | CODE |
| LOW | …nector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java | 154 | assertRowsAnyOrder(query, new Row("John Doe")); | CODE |
| LOW | …test/java/com/hazelcast/jet/mongodb/MongoSinkTest.java | 153 | Doc doc = new Doc(null, 10L, "new", "text lorem ipsum etc"); | CODE |
| LOW | …test/java/com/hazelcast/jet/mongodb/MongoSinkTest.java | 188 | Doc doc = new Doc(null, 3L, "existing", "text lorem ipsum etc"); | CODE |
| LOW | …c/test/java/com/hazelcast/aggregation/TestSamples.java | 37 | private static final String LOREM_IPSUM = "Lorem ipsum dolor sit amet consectetur adipiscing elit"; | CODE |
| LOW | …c/test/java/com/hazelcast/aggregation/TestSamples.java | 37 | private static final String LOREM_IPSUM = "Lorem ipsum dolor sit amet consectetur adipiscing elit"; | CODE |
| LOW | …t/jet/impl/connector/StreamFilesP_integrationTest.java | 261 | " Lorem ipsum dolor sit amet, consectetur adipiscing elit," + | CODE |
| LOW | …t/jet/impl/connector/StreamFilesP_integrationTest.java | 261 | " Lorem ipsum dolor sit amet, consectetur adipiscing elit," + | CODE |
| LOW | …a/com/hazelcast/jet/impl/connector/WriteJdbcPTest.java | 75 | private static final String DUMMY_DATA_CONNECTION = "dummy-data-connection"; | CODE |
| LOW | …va/com/hazelcast/jet/impl/connector/ReadJdbcPTest.java | 56 | private static final String DUMMY_DATA_CONNECTION = "dummy-data-connection"; | CODE |
| LOW | …t/java/com/hazelcast/config/YamlConfigBuilderTest.java | 5079 | some.property: dummy-value | CODE |
| LOW | …t/java/com/hazelcast/config/YamlConfigBuilderTest.java | 5096 | assertThat(mysqlDataConnectionConfig.getProperty("some.property")).isEqualTo("dummy-value"); | STRING |
| LOW | …st/java/com/hazelcast/config/XMLConfigBuilderTest.java | 4899 | + " <property name=\"some.property\">dummy-value</property>\n" | STRING |
| LOW | …st/java/com/hazelcast/config/XMLConfigBuilderTest.java | 4917 | assertThat(mysqlDataConnectionConfig.getProperty("some.property")).isEqualTo("dummy-value"); | STRING |
| LOW | …lization/impl/compact/CompactStreamSerializerTest.java | 463 | ExternalizableEmployeeDTO employeeDTO = new ExternalizableEmployeeDTO(30, "John Doe"); | CODE |
| LOW | …rialization/impl/compact/CompactSerializationTest.java | 218 | Data data = service.toData(new SerializableEmployeeDTO("John Doe", 42)); | CODE |
| LOW | …rialization/impl/compact/CompactSerializationTest.java | 242 | Data data = service.toData(new SerializableEmployeeDTO("John Doe", 42)); | CODE |
| LOW | …rialization/impl/compact/CompactSerializationTest.java | 433 | service.toData(new UsesSerializableClassAsField(new SerializableEmployeeDTO("John Doe", 42))) | CODE |
| LOW | …rialization/impl/compact/CompactSerializationTest.java | 445 | Data data = service.toData(new UsesSerializableClassAsField(new SerializableEmployeeDTO("John Doe", 42))); | CODE |
| LOW | …ternal/serialization/impl/compact/CompactTestUtil.java | 305 | SerializableEmployeeDTO object = new SerializableEmployeeDTO("John Doe", 1); | CODE |
| LOW | …/serialization/impl/compact/record/AllTypesRecord.java | 127 | "lorem ipsum", | CODE |
| LOW⚡ | …/java/com/hazelcast/internal/json/JsonParser_Test.java | 265 | String input = "[ \"lorem ipsum dolor sit amet\" ]"; | CODE |
| LOW⚡ | …/java/com/hazelcast/internal/json/JsonParser_Test.java | 265 | String input = "[ \"lorem ipsum dolor sit amet\" ]"; | CODE |
| LOW⚡ | …/java/com/hazelcast/internal/json/JsonParser_Test.java | 269 | assertEquals("[\"lorem ipsum dolor sit amet\"]", defHandler.getValue().toString()); | CODE |
| LOW⚡ | …/java/com/hazelcast/internal/json/JsonParser_Test.java | 269 | assertEquals("[\"lorem ipsum dolor sit amet\"]", defHandler.getValue().toString()); | CODE |
| LOW | …main/java/com/hazelcast/internal/json/JsonHandler.java | 37 | * ["lorem ipsum"] | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …/hazelcast/sql/impl/expression/datetime/Formatter.java | 920 | // Step 1 - Normalized form | COMMENT |
| LOW⚡ | …/hazelcast/sql/impl/expression/datetime/Formatter.java | 928 | // Step 2 - Find the actual number | COMMENT |
| LOW⚡ | …/hazelcast/sql/impl/expression/datetime/Formatter.java | 930 | // Step 3 - Determine the lengths of the integer and fraction | COMMENT |
| LOW⚡ | …/hazelcast/sql/impl/expression/datetime/Formatter.java | 938 | // Step 4 - Rounding | COMMENT |
| LOW | …/hazelcast/sql/impl/expression/datetime/Formatter.java | 961 | // Step 5 - Padding | COMMENT |
| LOW | …/hazelcast/sql/impl/expression/datetime/Formatter.java | 990 | // Step 6 - Format the integer and fraction masks | COMMENT |
| LOW⚡ | …ast/cp/internal/datastructures/snapshot/ChunkUtil.java | 107 | // Step 1: Process the snapshot and create chunks | COMMENT |
| LOW⚡ | …ast/cp/internal/datastructures/snapshot/ChunkUtil.java | 115 | // Step 2: Optimize chunks by merging non-chunked operations into the last chunk | COMMENT |
| LOW⚡ | …ast/cp/internal/datastructures/snapshot/ChunkUtil.java | 118 | // Step 3: Add metadata to chunks and prepare the final list | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …om/hazelcast/jet/python/PythonServiceGrpcBindTest.java | 95 | def _port_forcing_grpc_server(*args, **kwargs): | CODE |
| LOW | …internal/partition/MigrationAwareServiceEventTest.java | 118 | private static class FailingOperationResponseHandler implements OperationResponseHandler<Operation> { | CODE |
| LOW | …elcast/internal/locksupport/LockEvictionProcessor.java | 80 | private class UnlockResponseHandler implements OperationResponseHandler { | CODE |
| LOW | …/operationservice/OperationResponseHandlerFactory.java | 32 | private static class NoResponseHandler | CODE |
| LOW | …/operationservice/OperationResponseHandlerFactory.java | 44 | private static final class ErrorLoggingResponseHandler implements OperationResponseHandler { | CODE |
| LOW | …a/com/hazelcast/spi/impl/operationservice/Offload.java | 159 | private class OffloadedOperationResponseHandler implements OperationResponseHandler { | CODE |
| LOW | …rationservice/impl/InboundResponseHandlerSupplier.java | 242 | final class AsyncSingleThreadedResponseHandler implements Consumer<Packet> { | CODE |
| LOW | …rationservice/impl/InboundResponseHandlerSupplier.java | 256 | final class AsyncMultithreadedResponseHandler implements Consumer<Packet> { | CODE |
| LOW | …impl/operationservice/impl/InboundResponseHandler.java | 56 | public final class InboundResponseHandler implements Consumer<Packet> { | CODE |
| LOW | …mpl/operationservice/impl/OutboundResponseHandler.java | 66 | public final class OutboundResponseHandler implements OperationResponseHandler { | CODE |
| LOW⚡ | …lient/impl/spi/impl/ClientResponseHandlerSupplier.java | 221 | class SyncResponseHandler implements Consumer<ClientMessage> { | CODE |
| LOW⚡ | …lient/impl/spi/impl/ClientResponseHandlerSupplier.java | 229 | class AsyncResponseHandler implements Consumer<ClientMessage> { | CODE |
| LOW⚡ | …lient/impl/spi/impl/ClientResponseHandlerSupplier.java | 238 | class DynamicResponseHandler implements Consumer<ClientMessage> { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …com/hazelcast/sql/impl/client/SqlResubmissionTest.java | 211 | // This may be expected (for example: when resubmissionMode == NEVER), so we need to check if in current | COMMENT |
| LOW | …zelcast/sql/impl/client/SqlResubmissionStreamTest.java | 114 | // This may be expected (for example: when resubmissionMode == NEVER), so we need to check if in current | COMMENT |
| LOW | …/com/hazelcast/internal/diagnostics/MetricsPlugin.java | 109 | // So we need to check if writer is null or not. | COMMENT |
| LOW⚡ | …ast/cp/internal/datastructures/snapshot/ChunkUtil.java | 107 | // Step 1: Process the snapshot and create chunks | COMMENT |
| LOW⚡ | …ast/cp/internal/datastructures/snapshot/ChunkUtil.java | 115 | // Step 2: Optimize chunks by merging non-chunked operations into the last chunk | COMMENT |
| LOW⚡ | …ast/cp/internal/datastructures/snapshot/ChunkUtil.java | 118 | // Step 3: Add metadata to chunks and prepare the final list | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/vector/internal/impl/proxy/VectorCollectionProxy.java | 306 | // In this implementation the operations will be smaller, but there may be many of them | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …est/java/com/hazelcast/jet/sql/SqlQueryResultTest.java | 79 | // TODO: implement updateCount for DML and single key plans. | COMMENT |
| LOW | …src/main/java/com/hazelcast/cache/impl/CacheProxy.java | 246 | // TODO: implement a multiple (batch) invoke operation and its factory | COMMENT |
| LOW | …/com/hazelcast/client/cache/impl/ClientCacheProxy.java | 266 | // TODO: implement a multiple (batch) invoke operation and its factory | COMMENT |
| LOW | …/vector/internal/impl/proxy/VectorCollectionProxy.java | 305 | // TODO: implement backpressure or limit number of in-flight batches. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .github/terraform/azure/main.tf | 112 | #Assign role to the user assigned managed identity | COMMENT |
| LOW | …st/src/main/resources/hazelcast-security-hardened.yaml | 240 | # Assign permissions to role names (principals) and remote addresses (endpoints). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …st/resources/hazelcast-fullconfig-without-network.yaml | 16 | # This file is complete if included into either of the following: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/com/hazelcast/jet/python/grpcio_partial_bind_check.py | 4 | python3 -m venv v && v/bin/pip install grpcio==1.80.0 && v/bin/python grpcio_partial_bind_check.py | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nsions/python/src/main/resources/jet_to_python_init.sh | 25 | except Exception: | CODE |