AI Slop Code Risk Monitor

apache/nifi

SlopCodeMonitor badge for apache/nifi Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

Apache NiFi

1.2 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for apache/nifi, a Java project with 6,283 GitHub stars. SynthScan examined 1,872,495 lines of code across 12978 source files, recording 1059 pattern matches distributed across 15 syntactic categories. The legacy adjusted pattern signal is 1.2 (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.

1.2
Adjusted Signal
1.2
Raw Pattern Score
100%
Time Factor
2026-10-30
Last Push
6.3K
Stars
Java
Language
1.9M
Lines of Code
13.0K
Files
1.1K
Pattern Hits
2026-10-31
Scan Date
0.01
HC Hit Rate

Risk Review · Payload v1

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.

Cognitive Ownership Risk 1.6/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 474 finding(s).

Hallucinated Dependency & Supply Chain Risk 4.0/100 · LOW

Are imports declared and package/API names verified? 518 finding(s).

Agent Over-Engineering Ratio 0.9/100 · LOW

Are wrappers, guards, and repeated structures necessary? 209 finding(s).

PR Review Velocity Impact 5.4/100 · LOW

Which changes need focused human review? 1059 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

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.

Severity Breakdown

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.

CRITICAL 94HIGH 3MEDIUM 77LOW 885

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 1059 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Hallucination Indicators94 hits · 1095 pts
SeverityFileLineSnippetContext
CRITICAL…fi/processors/mqtt/adapters/PahoMqttClientAdapter.java147 return new org.eclipse.paho.client.mqttv3.MqttClient(brokerUri.toString(), clientProperties.getClientId(), nCODE
CRITICAL…s.cf.JMSConnectionFactoryProvider/additionalDetails.md68_com.ibm.mq.jms.MQConnectionFactory.setChannel(String)_ would imply 'channel' property andCODE
CRITICAL…s.cf.JMSConnectionFactoryProvider/additionalDetails.md69_com.ibm.mq.jms.MQConnectionFactory.setTransportType(int)_ would imply 'transportType' property. For the list ofCODE
CRITICAL…g/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java52 + "specific ConnectionFactory's implementation. For example, 'com.ibm.mq.jms.MQConnectionFactory.setChanCODE
CRITICAL…g/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java53 + "property and 'com.ibm.mq.jms.MQConnectionFactory.setTransportType(int)' would imply 'transportType' pCODE
CRITICAL…i.processors.standard.QueryRecord/additionalDetails.md1633860 [pool-2-thread-1] ERROR org.apache.nifi.processors.standard.QueryRecord - QueryRecord[id=135e9bc8-0372-4c1e-9c82-9dCODE
CRITICAL…rocessors/standard/db/impl/PhoenixDatabaseAdapter.java112 if (org.apache.nifi.util.StringUtils.isEmpty(table)) {CODE
CRITICAL⚡…st/java/org/apache/nifi/grok/TestGrokRecordReader.java185 assertTrue(stackTrace.contains(" at org.apache.nifi.cluster.coordination.node.NodeClusterCoorCODE
CRITICAL⚡…st/java/org/apache/nifi/grok/TestGrokRecordReader.java188 assertTrue(stackTrace.contains("at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.CODE
CRITICAL⚡…st/java/org/apache/nifi/grok/TestGrokRecordReader.java195 assertTrue(raw.contains(" at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinatorCODE
CRITICAL⚡…st/java/org/apache/nifi/grok/TestGrokRecordReader.java198 assertTrue(raw.contains("at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElecCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md175 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md176 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md177 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md178 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md179 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md180 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md181 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClustCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md190 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md191 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md192 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md193 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoCODE
CRITICAL⚡…s/org.apache.nifi.grok.GrokReader/additionalDetails.md194 at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoCODE
CRITICAL…s/org.apache.nifi.grok.GrokReader/additionalDetails.md220| STACK\_TRACE | org.apache.nifi.exception.UnitTestException: Testing to ensure we are able to capture stack traces<br> CODE
CRITICAL…/processors/azure/storage/PutAzureDataLakeStorage.java250 // com.azure.storage.common.Utility.convertStreamToByteBuffer() throws an exceptionCOMMENT
CRITICAL…factory/strategies/WebIdentityCredentialsStrategy.java111 final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazoCODE
CRITICAL…/factory/strategies/AssumeRoleCredentialsStrategy.java136 final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazoCODE
CRITICAL…apache/nifi/processors/aws/kinesis/ConsumeKinesis.java433 final software.amazon.awssdk.http.nio.netty.ProxyConfiguration.Builder nettyProxyBuilder = software.amazCODE
CRITICAL…apache/nifi/processors/aws/kinesis/ConsumeKinesis.java481 software.amazon.awssdk.http.apache5.ProxyConfiguration.builder().endpoint(proxyEndpoint);CODE
CRITICAL…/nifi/aws/schemaregistry/AmazonGlueSchemaRegistry.java251 final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazon.awCODE
CRITICAL…che/nifi/processors/aws/AbstractAwsAsyncProcessor.java69 final software.amazon.awssdk.http.nio.netty.ProxyConfiguration.Builder proxyConfigBuilder = software.amaCODE
CRITICAL…ache/nifi/processors/aws/AbstractAwsSyncProcessor.java70 final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazoCODE
CRITICAL…/ui/common/edit-tenant/edit-tenant-dialog.component.ts183 users.push(...this.request.userGroup.component.users.map((user) => user.id));CODE
CRITICAL…/ui/common/edit-tenant/edit-tenant-dialog.component.ts196 userGroups.push(...this.request.user.component.userGroups.map((userGroup) => userGroup.id));CODE
CRITICAL…/ui/common/edit-tenant/edit-tenant-dialog.component.ts219 const userGroups: string[] = this.request.user.component.userGroups.map((userGroup) => userGroup.id);CODE
CRITICAL…src/app/pages/flow-designer/state/flow/flow.reducer.ts301 const componentIndex: number = draftState.flow.processGroupFlow.flow.connections.findIndex(CODE
CRITICAL…src/app/pages/flow-designer/state/flow/flow.reducer.ts318 const componentIndex: number = draftState.flow.processGroupFlow.flow.processors.findIndex(CODE
CRITICAL…src/app/pages/flow-designer/state/flow/flow.reducer.ts334 const componentIndex: number = draftState.flow.processGroupFlow.flow.inputPorts.findIndex(CODE
CRITICAL…src/app/pages/flow-designer/state/flow/flow.reducer.ts350 const componentIndex: number = draftState.flow.processGroupFlow.flow.remoteProcessGroups.findIndex(CODE
CRITICAL…src/app/pages/flow-designer/state/flow/flow.reducer.ts369 const componentIndex: number = draftState.flow.processGroupFlow.flow.processGroups.findIndex(CODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java229 final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.ConfiguCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java240 final org.apache.nifi.extension.manifest.ConfigurationStepDependency dependency = new org.apache.nifi.extension.CODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java245 final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.ConfiguCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java257 final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.CCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java261 final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.ConfiguCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java281 final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.CCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java286 final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.ConfiguCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java313 final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.CCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java317 final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.ConfiguCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java337 final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.CCODE
CRITICAL…/impl/StandardRuntimeManifestBuilderConnectorTest.java341 final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.ConfiguCODE
CRITICAL…time/manifest/impl/StandardRuntimeManifestBuilder.java354 final org.apache.nifi.c2.protocol.component.api.Attribute c2Attribute = new org.apache.nifi.c2.protocol.componenCODE
CRITICAL…time/manifest/impl/StandardRuntimeManifestBuilder.java361 final org.apache.nifi.c2.protocol.component.api.DynamicRelationship c2DynamicRelationship = new org.apache.nifi.CODE
CRITICAL…time/manifest/impl/StandardRuntimeManifestBuilder.java625 final org.apache.nifi.c2.protocol.component.api.Stateful componentStateful = new org.apache.nifi.c2.protocolCODE
CRITICAL…time/manifest/impl/StandardRuntimeManifestBuilder.java653 final org.apache.nifi.c2.protocol.component.api.SystemResourceConsideration c2consideration = new org.apache.nifCODE
CRITICAL…time/manifest/impl/StandardRuntimeManifestBuilder.java696 final org.apache.nifi.c2.protocol.component.api.DynamicProperty c2DynamicProperty = new org.apache.nifi.c2.protoCODE
CRITICAL…va/org/apache/nifi/connectors/kafkas3/KafkaToS3IT.java108 org.apache.kafka.common.security.plain.PlainLoginModule.class.getName(),CODE
CRITICAL…security/authorization/file/FileUserGroupProvider.java285 new org.apache.nifi.registry.security.authorization.file.tenants.generated.Group();CODE
CRITICAL…security/authorization/file/FileUserGroupProvider.java292 new org.apache.nifi.registry.security.authorization.file.tenants.generated.Group.User();CODE
CRITICAL…security/authorization/file/FileUserGroupProvider.java357 new org.apache.nifi.registry.security.authorization.file.tenants.generated.Group.User();CODE
34 more matches not shown…
Fake / Example Data416 hits · 408 pts
SeverityFileLineSnippetContext
LOW…g/apache/nifi/processors/mongodb/PutMongoRecordIT.java114 recordReader.addRecord("John Doe", 48, "Soccer");CODE
LOW…g/apache/nifi/processors/mongodb/PutMongoRecordIT.java115 recordReader.addRecord("Jane Doe", 47, "Tennis");CODE
LOW…g/apache/nifi/processors/mongodb/PutMongoRecordIT.java161 recordReader.addRecord(1, new MapRecord(personSchema, Map.of("name", "John Doe",CODE
LOW…g/apache/nifi/processors/mongodb/PutMongoRecordIT.java163 recordReader.addRecord(2, new MapRecord(personSchema, Map.of("name", "Jane Doe", "age",CODE
LOW…rs/src/test/resources/bigquery/streaming-bad-data.json3 "name": "John Doe",CODE
LOW…rs/src/test/resources/bigquery/streaming-bad-data.json22 "name": "Jane Doe",CODE
LOW…sources/bigquery/streaming-correct-data-with-date.json4 "name": "John Doe",CODE
LOW…sources/bigquery/streaming-correct-data-with-date.json29 "name": "Jane Doe",CODE
LOW…gquery/streaming-correct-data-with-date-formatted.json4 "name": "John Doe",CODE
LOW…gquery/streaming-correct-data-with-date-formatted.json32 "name": "Jane Doe",CODE
LOW…rc/test/resources/bigquery/streaming-correct-data.json4 "name": "John Doe",CODE
LOW…rc/test/resources/bigquery/streaming-correct-data.json23 "name": "Jane Doe",CODE
LOW…apache/nifi/processors/gcp/bigquery/PutBigQueryIT.java196 assertEquals("Jane Doe", firstElt.get("name").getStringValue());CODE
LOW…apache/nifi/processors/gcp/bigquery/PutBigQueryIT.java532 john = firstElt.get("name").getStringValue().equals("John Doe") ? firstElt : sndElt;CODE
LOW…apache/nifi/processors/gcp/bigquery/PutBigQueryIT.java533 jane = firstElt.get("name").getStringValue().equals("Jane Doe") ? firstElt : sndElt;CODE
LOW…i/processors/box/ListBoxFileMetadataInstancesTest.java89 .add("Author", "John Doe");CODE
LOW…i/processors/box/ListBoxFileMetadataTemplatesTest.java87 when(mockJsonValue4.asString()).thenReturn("John Doe");CODE
LOW…ocessors/box/ExtractStructuredBoxFileMetadataTest.java130 jsonAnswer.add("author", "John Doe");STRING
LOW…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java130 final org.apache.nifi.serialization.record.Record record = new MapRecord(personSchema, Collections.singletonMap(CODE
LOW…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java138 assertEquals("John Doe", avroRecord.get("name"));CODE
LOW⚡…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java172 final org.apache.nifi.serialization.record.Record record = new MapRecord(personSchema, Collections.singletonMap(CODE
LOW⚡…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java180 assertEquals("John Doe", avroRecord.get("name"));CODE
LOW⚡…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java190 final org.apache.nifi.serialization.record.Record record = new MapRecord(personSchema, Collections.singletonMap(CODE
LOW⚡…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java198 assertEquals("John Doe", avroRecord.get("name"));CODE
LOW…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java514 record.put("name", "John Doe");CODE
LOW…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java519 assertEquals("John Doe", map.get("name"));CODE
LOW…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java530 record.put("name", "John Doe");CODE
LOW…c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java537 assertEquals("John Doe", map.get("name"));CODE
LOW…ifi/schema/validation/TestStandardSchemaValidator.java335 valueMap.put("name", "John Doe");CODE
LOW…g/apache/nifi/github/GitHubFlowRegistryClientTest.java114 final String serializedSnapshotContent = "placeholder";CODE
LOW…g/apache/nifi/github/GitHubFlowRegistryClientTest.java144 final String serializedSnapshotContent = "placeholder";CODE
LOW…g/apache/nifi/github/GitHubFlowRegistryClientTest.java181 final String serializedSnapshotContent = "placeholder";CODE
LOW…est/resources/TestUpdateRecord/input/multi-arrays.json4 "name" : "John Doe",CODE
LOW…est/resources/TestUpdateRecord/input/multi-arrays.json19 "name" : "Jane Doe",CODE
LOW…dateRecord/output/updateArrays/multi-arrays-0and2.json19 "name" : "Jane Doe",CODE
LOW…teRecord/output/updateArrays/multi-arrays-streets.json4 "name" : "John Doe",CODE
LOW…teRecord/output/updateArrays/multi-arrays-streets.json19 "name" : "Jane Doe",CODE
LOW…ources/TestRenameRecordField/input/complex-person.json2 "name" : "John Doe",CODE
LOW…sources/TestRenameRecordField/input/simple-person.json2 "name" : "John Doe",CODE
LOW…RenameRecordField/output/testRenameMultipleFields.json2 "full_name" : "John Doe",CODE
LOW…rces/TestRenameRecordField/output/testRenameArray.json2 "name" : "John Doe",CODE
LOW…nameRecordField/output/testRenameFieldStaticValue.json2 "name" : "John Doe",CODE
LOW…dField/output/testRecursivelyReferencingAllFields.json2 "NAME" : "John Doe",CODE
LOW…urces/TestRenameRecordField/output/testNestedPath.json2 "name" : "John Doe",CODE
LOW…dField/output/testRecursivelyReferencingFieldName.json2 "NAME" : "John Doe",CODE
LOW…eRecordField/output/testRenameFieldUsingAttribute.json2 "name" : "John Doe",CODE
LOW…RenameRecordField/output/testReferencingFieldName.json2 "UPDATED_name" : "John Doe",CODE
LOW…estForkRecord/single-element-nested-array-strings.json3 "name": "John Doe",CODE
LOW…tForkRecord/two-elements-nested-nested-array-null.json4 "name": "John Doe",CODE
LOW…tForkRecord/two-elements-nested-nested-array-null.json35 "name": "John Doe",CODE
LOW…ources/TestForkRecord/single-element-nested-array.json3 "name": "John Doe",CODE
LOW…TestForkRecord/single-element-nested-nested-array.json3 "name": "John Doe",CODE
LOW…org/apache/nifi/processors/standard/TestPutRecord.java60 recordReader.addRecord("John Doe", 48, "Soccer");CODE
LOW…org/apache/nifi/processors/standard/TestPutRecord.java61 recordReader.addRecord("Jane Doe", 47, "Tennis");CODE
LOW…org/apache/nifi/processors/standard/TestPutRecord.java119 recordReader.addRecord("John Doe", 48, "Soccer");CODE
LOW…org/apache/nifi/processors/standard/TestPutRecord.java120 recordReader.addRecord("Jane Doe", 47, "Tennis");CODE
LOW…org/apache/nifi/processors/standard/TestPutRecord.java145 recordReader.addRecord("John Doe", 48, "Soccer");CODE
LOW…ache/nifi/processors/standard/TestFilterAttribute.java40 private final String exampleContent = "lorem ipsum dolor sit amet";CODE
LOW…ache/nifi/processors/standard/TestFilterAttribute.java40 private final String exampleContent = "lorem ipsum dolor sit amet";CODE
LOW⚡…g/apache/nifi/processors/standard/TestQueryRecord.java148 assertEquals("John Doe", output.getValue("name"));CODE
356 more matches not shown…
Over-Commented Block218 hits · 218 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWcodecov.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.grype.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…fi-other-graph-services/src/test/resources/gremlin.yml1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…he/nifi/processor/util/list/AbstractListProcessor.java761 // If there have been files created, update the last timestamp we processed.COMMENT
LOW…che/nifi/processors/hadoop/SequenceFileWriterImpl.java61 // This allows the Sequence File to say that the Values are of type BytesWritable (so they can beCOMMENT
LOW…ache/nifi/processors/slack/consume/ConsumeChannel.java321 String ts = stateMap.get(startingTimestampKey);COMMENT
LOW…rocessors/src/main/resources/default-grok-patterns.txt1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…java/org/apache/nifi/processors/standard/TailFile.java821 reader = createReader(file, position);COMMENT
LOW…rocessors/standard/AbstractDatabaseFetchProcessor.java501 case TIMESTAMP:COMMENT
LOW…-services/src/main/resources/default-grok-patterns.txt1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…a/org/apache/nifi/processors/aws/s3/FetchS3Object.java501 final GetObjectRequest.Builder requestBuilder = GetObjectRequest.builder()COMMENT
LOW…/main/resources/extensions/ExitAfterFourInvocations.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…sions/src/main/resources/extensions/HashRecordField.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ons/src/main/resources/extensions/WriteNumpyVersion.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…/src/main/resources/extensions/ConditionalProcessor.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ons/src/main/resources/extensions/ConvertCsvToExcel.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ensions/src/main/resources/extensions/LookupAddress.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ns/src/main/resources/extensions/FailWithAttributes.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…main/resources/extensions/TestStateManagerException.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…nsions/src/main/resources/extensions/CreateFlowFile.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…nsions/src/main/resources/extensions/WriteMessageV2.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…c/main/resources/extensions/WritePropertyToFlowFile.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…tensions/src/main/resources/extensions/WriteMessage.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…s/src/main/resources/extensions/DetectObjectInImage.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ensions/src/main/resources/extensions/RouteFlowFile.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…xtensions/src/main/resources/extensions/LogContents.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…nsions/src/main/resources/extensions/GenerateRecord.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…nsions/src/main/resources/extensions/PopulateRecord.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…sions/src/main/resources/extensions/PrettyPrintJson.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…nsions/src/main/resources/extensions/SetRecordField.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ions/src/main/resources/extensions/TestStateManager.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ensions/src/main/resources/extensions/CreateNothing.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…/resources/extensions/multi-processor/requirements.txt1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ources/extensions/multi-processor/CreateHttpRequest.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…/main/resources/extensions/multi-processor/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…esources/extensions/multi-processor/ProtobufVersion.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…ain/resources/extensions/multi-module/ProcessorUtil.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…src/main/resources/extensions/multi-module/__init__.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…/main/resources/extensions/multi-module/WriteNumber.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…nents/searchable-select/searchable-select.component.ts861 // Non-virtual mode: select through MatSelect's MatOption instances. This mirrors aCOMMENT
LOW…d/src/services/codemirror-nifi-language/nfel/README.md21${attr:contains('value')}COMMENT
LOW…d/src/services/codemirror-nifi-language/nfel/README.md141COMMENT
LOW…ps/nifi/src/app/ui/common/canvas/canvas.component.scss861 &.neutral.transmitting {COMMENT
LOW…apps/nifi/src/app/ui/common/canvas/canvas.component.ts721 }COMMENT
LOW…apps/nifi/src/app/ui/common/canvas/canvas.component.ts1221 // Prevent zoom/pan when:COMMENT
LOW…s/layers/process-group-layer/process-group-renderer.ts1141 // -------------------COMMENT
LOW…/layers/connection-layer/connection-layer.component.ts261 const _processGroupId = this.processGroupId();COMMENT
LOW…apps/nifi/src/app/ui/common/canvas/utils/drag.utils.ts521COMMENT
LOW…apps/nifi/src/app/ui/common/canvas/utils/drag.utils.ts541 })COMMENT
LOW…apps/nifi/src/app/ui/common/canvas/utils/drag.utils.ts561 // `mouseover.drop` headed for an underlying PG.COMMENT
LOW…apps/nifi-registry/src/app/service/droplets.service.ts21COMMENT
LOW…apps/nifi-registry/src/app/service/droplets.service.ts41 // return throwError(() => mockError);COMMENT
LOW…apps/nifi-registry/src/app/service/droplets.service.ts61 return this.httpClient.delete(`${DropletsService.API}/${href}?version=0`);COMMENT
LOW…apps/nifi-registry/src/app/service/droplets.service.ts81 }COMMENT
LOW…apps/nifi-registry/src/app/service/droplets.service.ts101 exportDropletVersionedSnapshot(dropletUri: string, versionNumber: number): Observable<any> {COMMENT
LOW…apps/nifi-registry/src/app/service/droplets.service.ts121COMMENT
LOW…/apps/nifi-registry/src/app/service/buckets.service.ts121COMMENT
LOW…/apps/nifi-registry/src/app/service/buckets.service.ts141 // status: 404,COMMENT
LOWnifi-docs/src/main/asciidoc/asciidoc-mod.css141b.button:before{content:"[";padding:0 3px 0 2px}COMMENT
158 more matches not shown…
Decorative Section Separators60 hits · 156 pts
SeverityFileLineSnippetContext
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts179 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts181 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts200 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts202 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts220 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts222 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts247 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts249 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts266 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts268 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts323 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts325 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts350 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts352 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts379 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts381 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts422 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts424 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts453 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts455 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts535 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts537 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts598 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts600 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts629 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts631 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts702 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts704 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts785 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts787 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts960 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts962 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts1021 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…onents/connector-wizard/connector-wizard.store.spec.ts1023 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM⚡…on-step/connector-configuration-step.component.spec.ts248 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM⚡…on-step/connector-configuration-step.component.spec.ts250 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM⚡…on-step/connector-configuration-step.component.spec.ts259 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM⚡…on-step/connector-configuration-step.component.spec.ts261 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts278 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts280 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts366 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts368 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts398 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts400 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts503 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts505 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts527 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts529 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts651 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts653 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts819 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts821 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts861 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts863 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts932 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts934 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts954 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts960 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts1110 // ═══════════════════════════════════════════════════════COMMENT
MEDIUM…on-step/connector-configuration-step.component.spec.ts1112 // ═══════════════════════════════════════════════════════COMMENT
Hyper-Verbose Identifiers139 hits · 146 pts
SeverityFileLineSnippetContext
LOW…istributed/cache/client/CacheClientRequestHandler.java37public class CacheClientRequestHandler extends ChannelInboundHandlerAdapter {CODE
LOW…ributed/cache/server/codec/SetCacheRequestHandler.java37public class SetCacheRequestHandler extends SimpleChannelInboundHandler<CacheRequest> {CODE
LOW…ted/cache/server/codec/CacheVersionRequestHandler.java34public class CacheVersionRequestHandler extends SimpleChannelInboundHandler<CacheVersionRequest> {CODE
LOW…ributed/cache/server/codec/MapCacheRequestHandler.java42public class MapCacheRequestHandler extends SimpleChannelInboundHandler<MapCacheRequest> {CODE
LOW…rocessors/opentelemetry/server/HttpRequestHandler.java55public class HttpRequestHandler extends SimpleChannelInboundHandler<FullHttpRequest> {CODE
LOW…ntend/libs/shared/src/types/connector-message.types.ts216export function isParentToConnectorMessage(data: unknown): data is ParentToConnectorMessage {CODE
LOW…ontend/libs/shared/src/types/entities/entities.spec.ts412function remoteProcessGroupSnapshot(id: string): RemoteProcessGroupStatusSnapshotDTO {CODE
LOW…ontend/libs/shared/src/types/entities/entities.spec.ts508function createRemoteProcessGroupEntity(CODE
LOW…d/libs/shared/src/utils/connector-permissions.utils.ts44export function getConnectorActionDisabledReason(entity: ConnectorEntity, actionName: ConnectorActionName): string {CODE
LOW…ontend/libs/shared/src/utils/dependency-value.utils.ts30export function isDependencyValueSatisfied(CODE
LOW…nd/libs/shared/src/utils/connector-validation.utils.ts85export function assetReferencesHaveMissingContent(CODE
LOW…nd/libs/shared/src/utils/connector-validation.utils.ts132function evaluatePropertyVisibility(CODE
LOW…c/components/connector-wizard/step-dependency.utils.ts75export function isStepDependencySatisfied(CODE
LOW…ents/connector-wizard/with-connector-wizard.feature.ts188 function processVerificationResults(stepName: string, results: ConfigVerificationResult[]): void {CODE
LOW…apps/nifi/src/app/ui/common/overlap-detection.utils.ts43export function detectOverlappingConnections(CODE
LOW…ss-group/source-remote-process-group.component.spec.ts38 function createMockRemoteProcessGroup(name: string, outputPorts: any[] = []): any {CODE
LOW…oup/destination-remote-process-group.component.spec.ts33 function createMockRemoteProcessGroup(groupName = 'Test Remote Process Group', inputPorts: any[] = []) {CODE
LOW…/create-connection/create-connection.component.spec.ts202 function createMockRemoteProcessGroup(id = 'remote-group-id'): ConnectionDialogEndpoint {CODE
LOW…/nifi/src/app/ui/common/utils/component-state.utils.ts24export function runnableSupportsModification(entity: any): boolean {CODE
LOW…/nifi/src/app/ui/common/utils/component-state.utils.ts35export function remoteProcessGroupSupportsModification(entity: any): boolean {CODE
LOW…/nifi/src/app/ui/common/utils/component-state.utils.ts45export function getComponentTypeForSource(connectableType: string): ComponentType | null {CODE
LOW…/nifi/src/app/ui/common/utils/component-state.utils.ts65export function getComponentTypeForDestination(connectableType: string): ComponentType | null {CODE
LOW…/nifi/src/app/ui/common/utils/component-state.utils.ts85export function getConnectableTypeForSource(type: ComponentType): ConnectableComponentType | '' {CODE
LOW…/nifi/src/app/ui/common/utils/component-state.utils.ts105export function getConnectableTypeForDestination(type: ComponentType): ConnectableComponentType | '' {CODE
LOW…rc/app/ui/common/canvas/connectable-behavior.helper.ts56export function resolveConnectablePosition(datum: ConnectableComponentDatum): Position {CODE
LOW…app/ui/common/canvas/layers/render-context-fixtures.ts29export function createBaseRenderContextFixture(CODE
LOW…cess-group-layer/remote-process-group-renderer.spec.ts39function createMockRemoteProcessGroup(CODE
LOW…ers/process-group-layer/process-group-renderer.spec.ts1134 function setupWithControllableCanSelect(initialCanSelect: boolean) {CODE
LOW…p/ui/common/canvas/utils/connection-collision.utils.ts46export function calculateConnectionCollisionBendsByIds(CODE
LOW…p/ui/common/canvas/utils/connection-collision.utils.ts76export function calculateConnectionCollisionBends(CODE
LOW…rvice-table/controller-service-table.component.spec.ts52 function createMockControllerServiceEntity(): ControllerServiceEntity {CODE
LOW…roperty-value-tip/property-value-tip.component.spec.ts196 function getParameterValueCellText(): string {CODE
LOW…s/ui/connector-table/connector-table.component.spec.ts114 function createMockFlowConfiguration(CODE
LOW…ui/connector-canvas/connector-canvas.component.spec.ts406function configureConnectorCanvasTestBed(options: SetupOptions = {}, storage?: ReturnType<typeof createMockStorage>) {CODE
LOW…ui/connector-canvas/connector-canvas.component.spec.ts443function createConnectorCanvasFixture(storage: ReturnType<typeof createMockStorage>): {CODE
LOW…-info-control/connector-info-control.component.spec.ts31function createMockConnectorEntity(overrides: Partial<ConnectorEntity> = {}): ConnectorEntity {CODE
LOW…i/connector-configure/connector-configure.component.ts51function connectorWizardConfigFactory(): ConnectorWizardConfig {CODE
LOW…/connectors-listing/connectors-listing.effects.spec.ts127 function createChangeVersionRequest(CODE
LOW…/state/purge-connector/purge-connector.effects.spec.ts90 function createMockDropRequestEntity(CODE
LOW…-canvas-entity/connector-canvas-entity.reducer.spec.ts38 function createMockConnectorEntity(overrides: Partial<ConnectorEntity> = {}): ConnectorEntity {CODE
LOW…-canvas-entity/connector-canvas-entity.effects.spec.ts53 function createMockConnectorEntity(overrides: Partial<ConnectorEntity> = {}): ConnectorEntity {CODE
LOW…e/connector-canvas/bind-connector-parameter-context.ts34export function bindConnectorParameterContext(CODE
LOW…ors/state/connector-canvas/connector-canvas.reducer.ts23function hasCurrentOrNewerRevision(current: Revision, incoming: Revision): boolean {CODE
LOW…tate/connector-canvas/connector-canvas.effects.spec.ts1778 function controllerServicesSuccessAction(connectorId: string, processGroupId: string) {CODE
LOW…/pages/connectors/testing/parameter-context-fixture.ts27export function createParameterContextFixture(CODE
LOW…connectors/testing/connector-canvas-entity-fixtures.ts294export function makeRemoteProcessGroupDto(overrides: Partial<RemoteProcessGroupDTO> = {}): RemoteProcessGroupDTO {CODE
LOW…vices/management-controller-services.component.spec.ts35 function createMockControllerServiceEntity(): ControllerServiceEntity {CODE
LOW…w-analysis-rules/flow-analysis-rules.component.spec.ts36 function createMockFlowAnalysisRuleEntity(): FlowAnalysisRuleEntity {CODE
LOW…-rule-table/flow-analysis-rule-table.component.spec.ts54 function createMockFlowAnalysisRuleEntity(): FlowAnalysisRuleEntity {CODE
LOW…ui/registry-clients/registry-clients.component.spec.ts33 function createMockRegistryClientEntity(): RegistryClientEntity {CODE
LOW…y-client-table/registry-client-table.component.spec.ts49 function createMockRegistryClientEntity(): RegistryClientEntity {CODE
LOW…ameter-providers/parameter-providers.component.spec.ts32 function createMockParameterProviderEntity(): ParameterProviderEntity {CODE
LOW…ders-table/parameter-providers-table.component.spec.ts52 function createMockParameterProviderEntity(): ParameterProviderEntity {CODE
LOW…ders-table/parameter-providers-table.component.spec.ts138 function createMockFlowConfiguration(supportsManagedAuthorizer = true): FlowConfiguration {CODE
LOW…s/ui/reporting-tasks/reporting-tasks.component.spec.ts35 function createMockReportingTaskEntity(): ReportingTaskEntity {CODE
LOW…ting-task-table/reporting-task-table.component.spec.ts51 function createMockReportingTaskEntity(): ReportingTaskEntity {CODE
LOW…ting-task-table/reporting-task-table.component.spec.ts149 function createMockFlowConfiguration(): FlowConfiguration {CODE
LOW…low-analysis-rules/flow-analysis-rules.effects.spec.ts586 function createMockFlowAnalysisRuleEntity(): FlowAnalysisRuleEntity {CODE
LOW…tate/registry-clients/registry-clients.effects.spec.ts493 function createMockRegistryClientEntity(): RegistryClientEntity {CODE
LOW…arameter-providers/parameter-providers.effects.spec.ts47 function createMockParameterProviderEntity(): ParameterProviderEntity {CODE
79 more matches not shown…
Verbosity Indicators40 hits · 80 pts
SeverityFileLineSnippetContext
LOW…java/org/apache/nifi/processors/standard/TailFile.java553 // We need to check if the existing file is the same as the one referred to in the state file based onCOMMENT
LOW…time/manifest/impl/StandardRuntimeManifestBuilder.java605 // a non-null DeprecationNotice, so we need to check if the reason is also non-null before setting the boolean hCOMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java90 // Step 1: Create Parameter Context "P" with param1COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java93 // Step 2: Create v1 - Process Group A with just a Processor X using param1COMMENT
LOW…ts/system/registry/ParameterContextPreservationIT.java105 // Step 3: Create v2 - Add Process Group B inside A, also attached to PCOMMENT
LOW…ts/system/registry/ParameterContextPreservationIT.java118 // Step 4: Clean up original flowCOMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java129 // Step 5: Import v1 FIRST time - creates A1 with Parameter Context "P"COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java136 // Step 6: Import v1 SECOND time - creates A2 with Parameter Context "P (1)"COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java147 // Step 7: Upgrade A2 from v1 to v2 (this adds Process Group B)COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java150 // Step 8: Verify the NEW Process Group B uses the CORRECT parameter contextCOMMENT
LOW…/main/java/org/apache/nifi/util/MockPropertyValue.java129 // if we have a processor where input requirement is INPUT_ALLOWED, we need to check if there is anCOMMENT
LOW…/nifi/stateless/flow/StandardStatelessFlowCurrent.java267 // Check if the component made any progress or not. If so, continue on. If not, we need to check if provCOMMENT
LOW…a/org/apache/nifi/provenance/AbstractRecordWriter.java128 // once we have obtained the lock, we need to check if the writerCOMMENT
LOW⚡…ponents/connector/TestStandardConnectorRepository.java1265 // Step 1: provider.syncAssets() calledCOMMENT
LOW⚡…ponents/connector/TestStandardConnectorRepository.java1267 // Step 2: provider.load() called to reload updated config (may also have been called during addConnector)COMMENT
LOW⚡…/components/connector/StandardConnectorRepository.java1065 // Step 1: Sync Connector Assets from ProviderCOMMENT
LOW⚡…/components/connector/StandardConnectorRepository.java1069 // Step 2: Sync ConnectorNode Configuration from ProviderCOMMENT
LOW…ronization/StandardVersionedComponentSynchronizer.java362 // If this update adds a new Controller Service, then we need to check if the service already exists at a hiCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1084 // Step 1: Ensure that user has write permissions to the Process Group. If not, then immediately fail.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1085 // Step 2: Retrieve flow from Flow RegistryCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1086 // Step 3: Resolve Bundle infoCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1087 // Step 4: Update contents of the ProcessGroupDTO passed in to include the components that need to be added.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1088 // Step 5: Replicate the request or call serviceFacade.updateProcessGroupCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1094 // Step 1: Ensure that user has write permissions to the Process Group. If not, then immediately fail.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1095 // Step 2: Retrieve flow from Flow RegistryCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1099 // Step 3: Enrich version control info came from UICOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1110 // Step 4: Replace parameter contexts if necessaryCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1115 // Step 5: Resolve Bundle infoCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1125 // Step 6: Update contents of the ProcessGroupDTO passed in to include the components that need to be added.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1134 // Step 7: Replicate the request or call serviceFacade.updateProcessGroupCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1508 // Step 0: Get the Versioned Flow Snapshot from the Flow RegistryCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1513 // Step 1: Determine which components will be affected by updating the versionCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1528 // Step 3: Verify that all components in the snapshot exist on all nodesCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1529 // Step 4: Verify that Process Group is already under version control. If not, must start Version CoCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java190 // Step 0: Obtain the versioned flow snapshot to use for the updateCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java195 // Step 1: Determine which components will be affected by updating the flowCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java210 // Step 3: Verify that all components in the snapshot exist on all nodesCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java211 // Step 4: Verify that Process Group can be updated. Only versioned flows care about the verifyNotDiCOMMENT
LOW…n/java/org/apache/nifi/web/api/FlowUpdateResource.java384 // Step 9: Ensure that if any connection exists in the flow and does not exist in the proposed snapshot,COMMENT
LOW…pache/nifi/cluster/manager/ConnectionEntityMerger.java41 // If Load Balancing is configured but client entity indicates that data is not being transferred, we need to chCOMMENT
Structural Annotation Overuse35 hits · 73 pts
SeverityFileLineSnippetContext
LOW…/java/org/apache/nifi/processors/mqtt/ConsumeMQTT.java387 // NOTE: This method is called when isConnected returns false which can happen when the client is null, or when COMMENT
LOW…/java/org/apache/nifi/processors/mqtt/PublishMQTT.java290 // NOTE: This method is called when isConnected returns false which can happen when the client is null, or when COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java90 // Step 1: Create Parameter Context "P" with param1COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java93 // Step 2: Create v1 - Process Group A with just a Processor X using param1COMMENT
LOW…ts/system/registry/ParameterContextPreservationIT.java105 // Step 3: Create v2 - Add Process Group B inside A, also attached to PCOMMENT
LOW…ts/system/registry/ParameterContextPreservationIT.java118 // Step 4: Clean up original flowCOMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java129 // Step 5: Import v1 FIRST time - creates A1 with Parameter Context "P"COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java136 // Step 6: Import v1 SECOND time - creates A2 with Parameter Context "P (1)"COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java147 // Step 7: Upgrade A2 from v1 to v2 (this adds Process Group B)COMMENT
LOW⚡…ts/system/registry/ParameterContextPreservationIT.java150 // Step 8: Verify the NEW Process Group B uses the CORRECT parameter contextCOMMENT
LOW⚡…ponents/connector/TestStandardConnectorRepository.java1265 // Step 1: provider.syncAssets() calledCOMMENT
LOW⚡…ponents/connector/TestStandardConnectorRepository.java1267 // Step 2: provider.load() called to reload updated config (may also have been called during addConnector)COMMENT
LOW⚡…/components/connector/StandardConnectorRepository.java1065 // Step 1: Sync Connector Assets from ProviderCOMMENT
LOW⚡…/components/connector/StandardConnectorRepository.java1069 // Step 2: Sync ConnectorNode Configuration from ProviderCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1084 // Step 1: Ensure that user has write permissions to the Process Group. If not, then immediately fail.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1085 // Step 2: Retrieve flow from Flow RegistryCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1086 // Step 3: Resolve Bundle infoCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1087 // Step 4: Update contents of the ProcessGroupDTO passed in to include the components that need to be added.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1088 // Step 5: Replicate the request or call serviceFacade.updateProcessGroupCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1094 // Step 1: Ensure that user has write permissions to the Process Group. If not, then immediately fail.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1095 // Step 2: Retrieve flow from Flow RegistryCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1099 // Step 3: Enrich version control info came from UICOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1110 // Step 4: Replace parameter contexts if necessaryCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1115 // Step 5: Resolve Bundle infoCOMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1125 // Step 6: Update contents of the ProcessGroupDTO passed in to include the components that need to be added.COMMENT
LOW⚡…java/org/apache/nifi/web/api/ProcessGroupResource.java1134 // Step 7: Replicate the request or call serviceFacade.updateProcessGroupCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1508 // Step 0: Get the Versioned Flow Snapshot from the Flow RegistryCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1513 // Step 1: Determine which components will be affected by updating the versionCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1528 // Step 3: Verify that all components in the snapshot exist on all nodesCOMMENT
LOW⚡…ain/java/org/apache/nifi/web/api/VersionsResource.java1529 // Step 4: Verify that Process Group is already under version control. If not, must start Version CoCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java190 // Step 0: Obtain the versioned flow snapshot to use for the updateCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java195 // Step 1: Determine which components will be affected by updating the flowCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java210 // Step 3: Verify that all components in the snapshot exist on all nodesCOMMENT
LOW⚡…n/java/org/apache/nifi/web/api/FlowUpdateResource.java211 // Step 4: Verify that Process Group can be updated. Only versioned flows care about the verifyNotDiCOMMENT
LOW…n/java/org/apache/nifi/web/api/FlowUpdateResource.java384 // Step 9: Ensure that if any connection exists in the flow and does not exist in the proposed snapshot,COMMENT
AI Slop Vocabulary10 hits · 28 pts
SeverityFileLineSnippetContext
MEDIUM…he/nifi/processors/hadoop/AbstractHadoopProcessor.java280 // properties this processor sets. TODO: re-work ListHDFS to utilize KerberosCOMMENT
MEDIUM…/src/main/java/org/apache/nifi/util/db/JdbcCommon.java379 // Delegate mapping to AvroTypeUtil in order to utilize logical types.COMMENT
MEDIUM…/src/main/java/org/apache/nifi/util/db/JdbcCommon.java432 // Delegate mapping to AvroTypeUtil in order to utilize logical types.COMMENT
MEDIUM…/src/main/java/org/apache/nifi/util/db/JdbcCommon.java444 // Delegate mapping to AvroTypeUtil in order to utilize logical types.COMMENT
MEDIUM…fluent/schemaregistry/ProtobufMessageIndexEncoder.java74 // encoder is robust to how the MessageName was constructed (a statically configured "package.Outer.Nested"COMMENT
LOW…xtension-api/src/main/python/src/nifiapi/properties.py567 # Otherwise just return self, in order to avoid the cost of making the call to Java for evaluateAttributeExpressCOMMENT
LOW⚡…rk/src/main/python/framework/PythonProcessorAdapter.py57 # If no customValidate method, just returnCOMMENT
MEDIUM…/status/history/VolatileComponentStatusRepository.java359 // Updated getStatusHistory to utilize the start/end/preferredDataPoints parameters passed intoCOMMENT
MEDIUM…ava/org/apache/nifi/web/StandardNiFiContentAccess.java200 // user authorization is handled once we have the actual content so we can utilize the flow file attributes in tCOMMENT
MEDIUM…ava/org/apache/nifi/web/StandardNiFiContentAccess.java205 // user authorization is handled once we have the actual prov event so we can utilize the event attributes in thCOMMENT
Self-Referential Comments9 hits · 27 pts
SeverityFileLineSnippetContext
MEDIUM…s/src/main/resources/extensions/DetectObjectInImage.py92 # Create a blob from the image. I.e., perform pre-processing stepsCOMMENT
MEDIUM…work/minifi-resources/src/main/resources/bin/minifi.sh191# Create the init script, overwriting anything currently presentCOMMENT
MEDIUM…stry-resources/src/main/resources/bin/nifi-registry.sh193# Create the init script, overwriting anything currently presentCOMMENT
MEDIUM…k/src/test/python/framework/TestProcessorInspection.py206 # Create a minimal AST node that simulates a dependency listCOMMENT
MEDIUM…thon-framework/src/main/python/framework/Controller.py101 # Create the ControllerCOMMENT
MEDIUM…thon-framework/src/main/python/framework/Controller.py104 # Create the Java Gateway for communicating with NiFi Java processCOMMENT
MEDIUM…thon-framework/src/main/python/framework/Controller.py118 # Initialize the JvmHolder class with the gateway jvm.COMMENT
MEDIUM…ramework/src/main/python/framework/ExtensionManager.py367 # Create the module specificationCOMMENT
MEDIUM…ramework/src/main/python/framework/ExtensionManager.py371 # Create the module from the specificationCOMMENT
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGH…g/apache/nifi/processors/script/TestExecuteGroovy.java0gender,title,first,last female,miss,marlene,shaw male,mr,todd,grahamSTRING
HIGH…/apache/nifi/processors/script/TestExecuteClojure.java0gender,title,first,last female,miss,marlene,shaw male,mr,todd,grahamSTRING
HIGH…e/nifi/processors/groovyx/ExecuteGroovyScriptTest.java0gender,title,first,last female,miss,marlene,shaw male,mr,todd,grahamSTRING
Redundant / Tautological Comments8 hits · 12 pts
SeverityFileLineSnippetContext
LOW…nsions/src/main/resources/extensions/SetRecordField.py46 # Return the resultCOMMENT
LOW…gistry-core/nifi-registry-docker/dockerhub/sh/start.sh28# Check if we are secured or unsecuredCOMMENT
LOW.github/scripts/collect-system-tests-coverage.sh87# Check if report was generatedCOMMENT
LOWnifi-docker/dockerhub/sh/common.sh52# Set Path to include local directory for Astral uvCOMMENT
LOWnifi-docker/dockerhub/sh/start.sh104# Check if we are secured or unsecuredCOMMENT
LOW…ework/src/main/python/framework/ProcessorInspection.py210 # Check if this is a PropertyDescriptor assignmentCOMMENT
LOW…ework/src/main/python/framework/ProcessorInspection.py282 # Check if the imported name is a PropertyDescriptor in the source moduleCOMMENT
LOW…ramework/src/main/python/framework/ExtensionManager.py402 # Check if the instance has a method named 'implements'COMMENT
Deep Nesting12 hits · 11 pts
SeverityFileLineSnippetContext
LOW…xtension-api/src/main/python/src/nifiapi/properties.py87CODE
LOW…xtension-api/src/main/python/src/nifiapi/properties.py202CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py159CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py194CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py245CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py580CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py36CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py99CODE
LOW…ramework/src/main/python/framework/ExtensionManager.py183CODE
LOW…ramework/src/main/python/framework/ExtensionManager.py210CODE
LOW…ramework/src/main/python/framework/ExtensionManager.py331CODE
LOW…ramework/src/main/python/framework/ExtensionManager.py395CODE
Unused Imports8 hits · 8 pts
SeverityFileLineSnippetContext
LOW…main/resources/extensions/TestStateManagerException.py16CODE
LOW…nsions/src/main/resources/extensions/CreateFlowFile.py17CODE
LOW…nsions/src/main/resources/extensions/CreateFlowFile.py17CODE
LOW…nsions/src/main/resources/extensions/PopulateRecord.py18CODE
LOW…ions/src/main/resources/extensions/TestStateManager.py16CODE
LOW…ions/src/main/resources/extensions/TestStateManager.py16CODE
LOW…ions/src/main/resources/extensions/TestStateManager.py18CODE
LOW…ions/src/main/resources/extensions/TestStateManager.py18CODE
Excessive Try-Catch Wrapping4 hits · 4 pts
SeverityFileLineSnippetContext
LOW…sions/src/main/resources/extensions/HashRecordField.py81 except Exception as exc:CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py278 except Exception as e:CODE
LOW…ework/src/main/python/framework/ProcessorInspection.py481 except Exception as e:CODE
LOW…ramework/src/main/python/framework/ExtensionManager.py206 except Exception:CODE
AI Structural Patterns3 hits · 3 pts
SeverityFileLineSnippetContext
LOW…nsion-api/src/main/python/src/nifiapi/documentation.py123CODE
LOW…xtension-api/src/main/python/src/nifiapi/properties.py112CODE
LOW…ramework/src/main/python/framework/ExtensionDetails.py24CODE