Apache NiFi
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.
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? 474 finding(s).
Are imports declared and package/API names verified? 518 finding(s).
Are wrappers, guards, and repeated structures necessary? 209 finding(s).
Which changes need focused human review? 1059 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 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.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …fi/processors/mqtt/adapters/PahoMqttClientAdapter.java | 147 | return new org.eclipse.paho.client.mqttv3.MqttClient(brokerUri.toString(), clientProperties.getClientId(), n | CODE |
| CRITICAL | …s.cf.JMSConnectionFactoryProvider/additionalDetails.md | 68 | _com.ibm.mq.jms.MQConnectionFactory.setChannel(String)_ would imply 'channel' property and | CODE |
| CRITICAL | …s.cf.JMSConnectionFactoryProvider/additionalDetails.md | 69 | _com.ibm.mq.jms.MQConnectionFactory.setTransportType(int)_ would imply 'transportType' property. For the list of | CODE |
| CRITICAL | …g/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java | 52 | + "specific ConnectionFactory's implementation. For example, 'com.ibm.mq.jms.MQConnectionFactory.setChan | CODE |
| CRITICAL | …g/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java | 53 | + "property and 'com.ibm.mq.jms.MQConnectionFactory.setTransportType(int)' would imply 'transportType' p | CODE |
| CRITICAL | …i.processors.standard.QueryRecord/additionalDetails.md | 163 | 3860 [pool-2-thread-1] ERROR org.apache.nifi.processors.standard.QueryRecord - QueryRecord[id=135e9bc8-0372-4c1e-9c82-9d | CODE |
| CRITICAL | …rocessors/standard/db/impl/PhoenixDatabaseAdapter.java | 112 | if (org.apache.nifi.util.StringUtils.isEmpty(table)) { | CODE |
| CRITICAL⚡ | …st/java/org/apache/nifi/grok/TestGrokRecordReader.java | 185 | assertTrue(stackTrace.contains(" at org.apache.nifi.cluster.coordination.node.NodeClusterCoor | CODE |
| CRITICAL⚡ | …st/java/org/apache/nifi/grok/TestGrokRecordReader.java | 188 | assertTrue(stackTrace.contains("at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator. | CODE |
| CRITICAL⚡ | …st/java/org/apache/nifi/grok/TestGrokRecordReader.java | 195 | assertTrue(raw.contains(" at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator | CODE |
| CRITICAL⚡ | …st/java/org/apache/nifi/grok/TestGrokRecordReader.java | 198 | assertTrue(raw.contains("at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElec | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 175 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 176 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 177 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 178 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 179 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 180 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 181 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClust | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 190 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCo | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 191 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCo | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 192 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCo | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 193 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCo | CODE |
| CRITICAL⚡ | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 194 | at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCo | CODE |
| CRITICAL | …s/org.apache.nifi.grok.GrokReader/additionalDetails.md | 220 | | STACK\_TRACE | org.apache.nifi.exception.UnitTestException: Testing to ensure we are able to capture stack traces<br> | CODE |
| CRITICAL | …/processors/azure/storage/PutAzureDataLakeStorage.java | 250 | // com.azure.storage.common.Utility.convertStreamToByteBuffer() throws an exception | COMMENT |
| CRITICAL | …factory/strategies/WebIdentityCredentialsStrategy.java | 111 | final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazo | CODE |
| CRITICAL | …/factory/strategies/AssumeRoleCredentialsStrategy.java | 136 | final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazo | CODE |
| CRITICAL | …apache/nifi/processors/aws/kinesis/ConsumeKinesis.java | 433 | final software.amazon.awssdk.http.nio.netty.ProxyConfiguration.Builder nettyProxyBuilder = software.amaz | CODE |
| CRITICAL | …apache/nifi/processors/aws/kinesis/ConsumeKinesis.java | 481 | software.amazon.awssdk.http.apache5.ProxyConfiguration.builder().endpoint(proxyEndpoint); | CODE |
| CRITICAL | …/nifi/aws/schemaregistry/AmazonGlueSchemaRegistry.java | 251 | final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazon.aw | CODE |
| CRITICAL | …che/nifi/processors/aws/AbstractAwsAsyncProcessor.java | 69 | final software.amazon.awssdk.http.nio.netty.ProxyConfiguration.Builder proxyConfigBuilder = software.ama | CODE |
| CRITICAL | …ache/nifi/processors/aws/AbstractAwsSyncProcessor.java | 70 | final software.amazon.awssdk.http.apache5.ProxyConfiguration.Builder proxyConfigBuilder = software.amazo | CODE |
| CRITICAL | …/ui/common/edit-tenant/edit-tenant-dialog.component.ts | 183 | users.push(...this.request.userGroup.component.users.map((user) => user.id)); | CODE |
| CRITICAL | …/ui/common/edit-tenant/edit-tenant-dialog.component.ts | 196 | userGroups.push(...this.request.user.component.userGroups.map((userGroup) => userGroup.id)); | CODE |
| CRITICAL | …/ui/common/edit-tenant/edit-tenant-dialog.component.ts | 219 | const userGroups: string[] = this.request.user.component.userGroups.map((userGroup) => userGroup.id); | CODE |
| CRITICAL | …src/app/pages/flow-designer/state/flow/flow.reducer.ts | 301 | const componentIndex: number = draftState.flow.processGroupFlow.flow.connections.findIndex( | CODE |
| CRITICAL | …src/app/pages/flow-designer/state/flow/flow.reducer.ts | 318 | const componentIndex: number = draftState.flow.processGroupFlow.flow.processors.findIndex( | CODE |
| CRITICAL | …src/app/pages/flow-designer/state/flow/flow.reducer.ts | 334 | const componentIndex: number = draftState.flow.processGroupFlow.flow.inputPorts.findIndex( | CODE |
| CRITICAL | …src/app/pages/flow-designer/state/flow/flow.reducer.ts | 350 | const componentIndex: number = draftState.flow.processGroupFlow.flow.remoteProcessGroups.findIndex( | CODE |
| CRITICAL | …src/app/pages/flow-designer/state/flow/flow.reducer.ts | 369 | const componentIndex: number = draftState.flow.processGroupFlow.flow.processGroups.findIndex( | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 229 | final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.Configu | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 240 | final org.apache.nifi.extension.manifest.ConfigurationStepDependency dependency = new org.apache.nifi.extension. | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 245 | final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.Configu | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 257 | final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.C | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 261 | final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.Configu | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 281 | final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.C | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 286 | final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.Configu | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 313 | final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.C | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 317 | final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.Configu | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 337 | final org.apache.nifi.extension.manifest.ConnectorPropertyGroup group = new org.apache.nifi.extension.manifest.C | CODE |
| CRITICAL | …/impl/StandardRuntimeManifestBuilderConnectorTest.java | 341 | final org.apache.nifi.extension.manifest.ConfigurationStep step = new org.apache.nifi.extension.manifest.Configu | CODE |
| CRITICAL | …time/manifest/impl/StandardRuntimeManifestBuilder.java | 354 | final org.apache.nifi.c2.protocol.component.api.Attribute c2Attribute = new org.apache.nifi.c2.protocol.componen | CODE |
| CRITICAL | …time/manifest/impl/StandardRuntimeManifestBuilder.java | 361 | final org.apache.nifi.c2.protocol.component.api.DynamicRelationship c2DynamicRelationship = new org.apache.nifi. | CODE |
| CRITICAL | …time/manifest/impl/StandardRuntimeManifestBuilder.java | 625 | final org.apache.nifi.c2.protocol.component.api.Stateful componentStateful = new org.apache.nifi.c2.protocol | CODE |
| CRITICAL | …time/manifest/impl/StandardRuntimeManifestBuilder.java | 653 | final org.apache.nifi.c2.protocol.component.api.SystemResourceConsideration c2consideration = new org.apache.nif | CODE |
| CRITICAL | …time/manifest/impl/StandardRuntimeManifestBuilder.java | 696 | final org.apache.nifi.c2.protocol.component.api.DynamicProperty c2DynamicProperty = new org.apache.nifi.c2.proto | CODE |
| CRITICAL | …va/org/apache/nifi/connectors/kafkas3/KafkaToS3IT.java | 108 | org.apache.kafka.common.security.plain.PlainLoginModule.class.getName(), | CODE |
| CRITICAL | …security/authorization/file/FileUserGroupProvider.java | 285 | new org.apache.nifi.registry.security.authorization.file.tenants.generated.Group(); | CODE |
| CRITICAL | …security/authorization/file/FileUserGroupProvider.java | 292 | new org.apache.nifi.registry.security.authorization.file.tenants.generated.Group.User(); | CODE |
| CRITICAL | …security/authorization/file/FileUserGroupProvider.java | 357 | new org.apache.nifi.registry.security.authorization.file.tenants.generated.Group.User(); | CODE |
| 34 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …g/apache/nifi/processors/mongodb/PutMongoRecordIT.java | 114 | recordReader.addRecord("John Doe", 48, "Soccer"); | CODE |
| LOW | …g/apache/nifi/processors/mongodb/PutMongoRecordIT.java | 115 | recordReader.addRecord("Jane Doe", 47, "Tennis"); | CODE |
| LOW | …g/apache/nifi/processors/mongodb/PutMongoRecordIT.java | 161 | recordReader.addRecord(1, new MapRecord(personSchema, Map.of("name", "John Doe", | CODE |
| LOW | …g/apache/nifi/processors/mongodb/PutMongoRecordIT.java | 163 | recordReader.addRecord(2, new MapRecord(personSchema, Map.of("name", "Jane Doe", "age", | CODE |
| LOW | …rs/src/test/resources/bigquery/streaming-bad-data.json | 3 | "name": "John Doe", | CODE |
| LOW | …rs/src/test/resources/bigquery/streaming-bad-data.json | 22 | "name": "Jane Doe", | CODE |
| LOW | …sources/bigquery/streaming-correct-data-with-date.json | 4 | "name": "John Doe", | CODE |
| LOW | …sources/bigquery/streaming-correct-data-with-date.json | 29 | "name": "Jane Doe", | CODE |
| LOW | …gquery/streaming-correct-data-with-date-formatted.json | 4 | "name": "John Doe", | CODE |
| LOW | …gquery/streaming-correct-data-with-date-formatted.json | 32 | "name": "Jane Doe", | CODE |
| LOW | …rc/test/resources/bigquery/streaming-correct-data.json | 4 | "name": "John Doe", | CODE |
| LOW | …rc/test/resources/bigquery/streaming-correct-data.json | 23 | "name": "Jane Doe", | CODE |
| LOW | …apache/nifi/processors/gcp/bigquery/PutBigQueryIT.java | 196 | assertEquals("Jane Doe", firstElt.get("name").getStringValue()); | CODE |
| LOW | …apache/nifi/processors/gcp/bigquery/PutBigQueryIT.java | 532 | john = firstElt.get("name").getStringValue().equals("John Doe") ? firstElt : sndElt; | CODE |
| LOW | …apache/nifi/processors/gcp/bigquery/PutBigQueryIT.java | 533 | jane = firstElt.get("name").getStringValue().equals("Jane Doe") ? firstElt : sndElt; | CODE |
| LOW | …i/processors/box/ListBoxFileMetadataInstancesTest.java | 89 | .add("Author", "John Doe"); | CODE |
| LOW | …i/processors/box/ListBoxFileMetadataTemplatesTest.java | 87 | when(mockJsonValue4.asString()).thenReturn("John Doe"); | CODE |
| LOW | …ocessors/box/ExtractStructuredBoxFileMetadataTest.java | 130 | jsonAnswer.add("author", "John Doe"); | STRING |
| LOW | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 130 | final org.apache.nifi.serialization.record.Record record = new MapRecord(personSchema, Collections.singletonMap( | CODE |
| LOW | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 138 | assertEquals("John Doe", avroRecord.get("name")); | CODE |
| LOW⚡ | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 172 | final org.apache.nifi.serialization.record.Record record = new MapRecord(personSchema, Collections.singletonMap( | CODE |
| LOW⚡ | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 180 | assertEquals("John Doe", avroRecord.get("name")); | CODE |
| LOW⚡ | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 190 | final org.apache.nifi.serialization.record.Record record = new MapRecord(personSchema, Collections.singletonMap( | CODE |
| LOW⚡ | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 198 | assertEquals("John Doe", avroRecord.get("name")); | CODE |
| LOW | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 514 | record.put("name", "John Doe"); | CODE |
| LOW | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 519 | assertEquals("John Doe", map.get("name")); | CODE |
| LOW | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 530 | record.put("name", "John Doe"); | CODE |
| LOW | …c/test/java/org/apache/nifi/avro/TestAvroTypeUtil.java | 537 | assertEquals("John Doe", map.get("name")); | CODE |
| LOW | …ifi/schema/validation/TestStandardSchemaValidator.java | 335 | valueMap.put("name", "John Doe"); | CODE |
| LOW | …g/apache/nifi/github/GitHubFlowRegistryClientTest.java | 114 | final String serializedSnapshotContent = "placeholder"; | CODE |
| LOW | …g/apache/nifi/github/GitHubFlowRegistryClientTest.java | 144 | final String serializedSnapshotContent = "placeholder"; | CODE |
| LOW | …g/apache/nifi/github/GitHubFlowRegistryClientTest.java | 181 | final String serializedSnapshotContent = "placeholder"; | CODE |
| LOW | …est/resources/TestUpdateRecord/input/multi-arrays.json | 4 | "name" : "John Doe", | CODE |
| LOW | …est/resources/TestUpdateRecord/input/multi-arrays.json | 19 | "name" : "Jane Doe", | CODE |
| LOW | …dateRecord/output/updateArrays/multi-arrays-0and2.json | 19 | "name" : "Jane Doe", | CODE |
| LOW | …teRecord/output/updateArrays/multi-arrays-streets.json | 4 | "name" : "John Doe", | CODE |
| LOW | …teRecord/output/updateArrays/multi-arrays-streets.json | 19 | "name" : "Jane Doe", | CODE |
| LOW | …ources/TestRenameRecordField/input/complex-person.json | 2 | "name" : "John Doe", | CODE |
| LOW | …sources/TestRenameRecordField/input/simple-person.json | 2 | "name" : "John Doe", | CODE |
| LOW | …RenameRecordField/output/testRenameMultipleFields.json | 2 | "full_name" : "John Doe", | CODE |
| LOW | …rces/TestRenameRecordField/output/testRenameArray.json | 2 | "name" : "John Doe", | CODE |
| LOW | …nameRecordField/output/testRenameFieldStaticValue.json | 2 | "name" : "John Doe", | CODE |
| LOW | …dField/output/testRecursivelyReferencingAllFields.json | 2 | "NAME" : "John Doe", | CODE |
| LOW | …urces/TestRenameRecordField/output/testNestedPath.json | 2 | "name" : "John Doe", | CODE |
| LOW | …dField/output/testRecursivelyReferencingFieldName.json | 2 | "NAME" : "John Doe", | CODE |
| LOW | …eRecordField/output/testRenameFieldUsingAttribute.json | 2 | "name" : "John Doe", | CODE |
| LOW | …RenameRecordField/output/testReferencingFieldName.json | 2 | "UPDATED_name" : "John Doe", | CODE |
| LOW | …estForkRecord/single-element-nested-array-strings.json | 3 | "name": "John Doe", | CODE |
| LOW | …tForkRecord/two-elements-nested-nested-array-null.json | 4 | "name": "John Doe", | CODE |
| LOW | …tForkRecord/two-elements-nested-nested-array-null.json | 35 | "name": "John Doe", | CODE |
| LOW | …ources/TestForkRecord/single-element-nested-array.json | 3 | "name": "John Doe", | CODE |
| LOW | …TestForkRecord/single-element-nested-nested-array.json | 3 | "name": "John Doe", | CODE |
| LOW | …org/apache/nifi/processors/standard/TestPutRecord.java | 60 | recordReader.addRecord("John Doe", 48, "Soccer"); | CODE |
| LOW | …org/apache/nifi/processors/standard/TestPutRecord.java | 61 | recordReader.addRecord("Jane Doe", 47, "Tennis"); | CODE |
| LOW | …org/apache/nifi/processors/standard/TestPutRecord.java | 119 | recordReader.addRecord("John Doe", 48, "Soccer"); | CODE |
| LOW | …org/apache/nifi/processors/standard/TestPutRecord.java | 120 | recordReader.addRecord("Jane Doe", 47, "Tennis"); | CODE |
| LOW | …org/apache/nifi/processors/standard/TestPutRecord.java | 145 | recordReader.addRecord("John Doe", 48, "Soccer"); | CODE |
| LOW | …ache/nifi/processors/standard/TestFilterAttribute.java | 40 | private final String exampleContent = "lorem ipsum dolor sit amet"; | CODE |
| LOW | …ache/nifi/processors/standard/TestFilterAttribute.java | 40 | private final String exampleContent = "lorem ipsum dolor sit amet"; | CODE |
| LOW⚡ | …g/apache/nifi/processors/standard/TestQueryRecord.java | 148 | assertEquals("John Doe", output.getValue("name")); | CODE |
| 356 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | codecov.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .grype.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …fi-other-graph-services/src/test/resources/gremlin.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …he/nifi/processor/util/list/AbstractListProcessor.java | 761 | // If there have been files created, update the last timestamp we processed. | COMMENT |
| LOW | …che/nifi/processors/hadoop/SequenceFileWriterImpl.java | 61 | // This allows the Sequence File to say that the Values are of type BytesWritable (so they can be | COMMENT |
| LOW | …ache/nifi/processors/slack/consume/ConsumeChannel.java | 321 | String ts = stateMap.get(startingTimestampKey); | COMMENT |
| LOW | …rocessors/src/main/resources/default-grok-patterns.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …java/org/apache/nifi/processors/standard/TailFile.java | 821 | reader = createReader(file, position); | COMMENT |
| LOW | …rocessors/standard/AbstractDatabaseFetchProcessor.java | 501 | case TIMESTAMP: | COMMENT |
| LOW | …-services/src/main/resources/default-grok-patterns.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …a/org/apache/nifi/processors/aws/s3/FetchS3Object.java | 501 | final GetObjectRequest.Builder requestBuilder = GetObjectRequest.builder() | COMMENT |
| LOW | …/main/resources/extensions/ExitAfterFourInvocations.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …sions/src/main/resources/extensions/HashRecordField.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ons/src/main/resources/extensions/WriteNumpyVersion.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …/src/main/resources/extensions/ConditionalProcessor.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ons/src/main/resources/extensions/ConvertCsvToExcel.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ensions/src/main/resources/extensions/LookupAddress.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ns/src/main/resources/extensions/FailWithAttributes.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …main/resources/extensions/TestStateManagerException.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nsions/src/main/resources/extensions/CreateFlowFile.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nsions/src/main/resources/extensions/WriteMessageV2.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …c/main/resources/extensions/WritePropertyToFlowFile.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …tensions/src/main/resources/extensions/WriteMessage.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …s/src/main/resources/extensions/DetectObjectInImage.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ensions/src/main/resources/extensions/RouteFlowFile.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …xtensions/src/main/resources/extensions/LogContents.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nsions/src/main/resources/extensions/GenerateRecord.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nsions/src/main/resources/extensions/PopulateRecord.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …sions/src/main/resources/extensions/PrettyPrintJson.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nsions/src/main/resources/extensions/SetRecordField.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ions/src/main/resources/extensions/TestStateManager.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ensions/src/main/resources/extensions/CreateNothing.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …/resources/extensions/multi-processor/requirements.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ources/extensions/multi-processor/CreateHttpRequest.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …/main/resources/extensions/multi-processor/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …esources/extensions/multi-processor/ProtobufVersion.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ain/resources/extensions/multi-module/ProcessorUtil.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …src/main/resources/extensions/multi-module/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …/main/resources/extensions/multi-module/WriteNumber.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nents/searchable-select/searchable-select.component.ts | 861 | // Non-virtual mode: select through MatSelect's MatOption instances. This mirrors a | COMMENT |
| LOW | …d/src/services/codemirror-nifi-language/nfel/README.md | 21 | ${attr:contains('value')} | COMMENT |
| LOW | …d/src/services/codemirror-nifi-language/nfel/README.md | 141 | COMMENT | |
| LOW | …ps/nifi/src/app/ui/common/canvas/canvas.component.scss | 861 | &.neutral.transmitting { | COMMENT |
| LOW | …apps/nifi/src/app/ui/common/canvas/canvas.component.ts | 721 | } | COMMENT |
| LOW | …apps/nifi/src/app/ui/common/canvas/canvas.component.ts | 1221 | // Prevent zoom/pan when: | COMMENT |
| LOW | …s/layers/process-group-layer/process-group-renderer.ts | 1141 | // ------------------- | COMMENT |
| LOW | …/layers/connection-layer/connection-layer.component.ts | 261 | const _processGroupId = this.processGroupId(); | COMMENT |
| LOW | …apps/nifi/src/app/ui/common/canvas/utils/drag.utils.ts | 521 | COMMENT | |
| LOW | …apps/nifi/src/app/ui/common/canvas/utils/drag.utils.ts | 541 | }) | COMMENT |
| LOW | …apps/nifi/src/app/ui/common/canvas/utils/drag.utils.ts | 561 | // `mouseover.drop` headed for an underlying PG. | COMMENT |
| LOW | …apps/nifi-registry/src/app/service/droplets.service.ts | 21 | COMMENT | |
| LOW | …apps/nifi-registry/src/app/service/droplets.service.ts | 41 | // return throwError(() => mockError); | COMMENT |
| LOW | …apps/nifi-registry/src/app/service/droplets.service.ts | 61 | return this.httpClient.delete(`${DropletsService.API}/${href}?version=0`); | COMMENT |
| LOW | …apps/nifi-registry/src/app/service/droplets.service.ts | 81 | } | COMMENT |
| LOW | …apps/nifi-registry/src/app/service/droplets.service.ts | 101 | exportDropletVersionedSnapshot(dropletUri: string, versionNumber: number): Observable<any> { | COMMENT |
| LOW | …apps/nifi-registry/src/app/service/droplets.service.ts | 121 | COMMENT | |
| LOW | …/apps/nifi-registry/src/app/service/buckets.service.ts | 121 | COMMENT | |
| LOW | …/apps/nifi-registry/src/app/service/buckets.service.ts | 141 | // status: 404, | COMMENT |
| LOW | nifi-docs/src/main/asciidoc/asciidoc-mod.css | 141 | b.button:before{content:"[";padding:0 3px 0 2px} | COMMENT |
| 158 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 179 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 181 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 200 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 202 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 220 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 222 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 247 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 249 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 266 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 268 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 323 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 325 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 350 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 352 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 379 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 381 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 422 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 424 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 453 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 455 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 535 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 537 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 598 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 600 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 629 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 631 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 702 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 704 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 785 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 787 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 960 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 962 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 1021 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …onents/connector-wizard/connector-wizard.store.spec.ts | 1023 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM⚡ | …on-step/connector-configuration-step.component.spec.ts | 248 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM⚡ | …on-step/connector-configuration-step.component.spec.ts | 250 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM⚡ | …on-step/connector-configuration-step.component.spec.ts | 259 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM⚡ | …on-step/connector-configuration-step.component.spec.ts | 261 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 278 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 280 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 366 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 368 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 398 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 400 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 503 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 505 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 527 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 529 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 651 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 653 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 819 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 821 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 861 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 863 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 932 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 934 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 954 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 960 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 1110 | // ═══════════════════════════════════════════════════════ | COMMENT |
| MEDIUM | …on-step/connector-configuration-step.component.spec.ts | 1112 | // ═══════════════════════════════════════════════════════ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …istributed/cache/client/CacheClientRequestHandler.java | 37 | public class CacheClientRequestHandler extends ChannelInboundHandlerAdapter { | CODE |
| LOW | …ributed/cache/server/codec/SetCacheRequestHandler.java | 37 | public class SetCacheRequestHandler extends SimpleChannelInboundHandler<CacheRequest> { | CODE |
| LOW | …ted/cache/server/codec/CacheVersionRequestHandler.java | 34 | public class CacheVersionRequestHandler extends SimpleChannelInboundHandler<CacheVersionRequest> { | CODE |
| LOW | …ributed/cache/server/codec/MapCacheRequestHandler.java | 42 | public class MapCacheRequestHandler extends SimpleChannelInboundHandler<MapCacheRequest> { | CODE |
| LOW | …rocessors/opentelemetry/server/HttpRequestHandler.java | 55 | public class HttpRequestHandler extends SimpleChannelInboundHandler<FullHttpRequest> { | CODE |
| LOW | …ntend/libs/shared/src/types/connector-message.types.ts | 216 | export function isParentToConnectorMessage(data: unknown): data is ParentToConnectorMessage { | CODE |
| LOW | …ontend/libs/shared/src/types/entities/entities.spec.ts | 412 | function remoteProcessGroupSnapshot(id: string): RemoteProcessGroupStatusSnapshotDTO { | CODE |
| LOW | …ontend/libs/shared/src/types/entities/entities.spec.ts | 508 | function createRemoteProcessGroupEntity( | CODE |
| LOW | …d/libs/shared/src/utils/connector-permissions.utils.ts | 44 | export function getConnectorActionDisabledReason(entity: ConnectorEntity, actionName: ConnectorActionName): string { | CODE |
| LOW | …ontend/libs/shared/src/utils/dependency-value.utils.ts | 30 | export function isDependencyValueSatisfied( | CODE |
| LOW | …nd/libs/shared/src/utils/connector-validation.utils.ts | 85 | export function assetReferencesHaveMissingContent( | CODE |
| LOW | …nd/libs/shared/src/utils/connector-validation.utils.ts | 132 | function evaluatePropertyVisibility( | CODE |
| LOW | …c/components/connector-wizard/step-dependency.utils.ts | 75 | export function isStepDependencySatisfied( | CODE |
| LOW | …ents/connector-wizard/with-connector-wizard.feature.ts | 188 | function processVerificationResults(stepName: string, results: ConfigVerificationResult[]): void { | CODE |
| LOW | …apps/nifi/src/app/ui/common/overlap-detection.utils.ts | 43 | export function detectOverlappingConnections( | CODE |
| LOW | …ss-group/source-remote-process-group.component.spec.ts | 38 | function createMockRemoteProcessGroup(name: string, outputPorts: any[] = []): any { | CODE |
| LOW | …oup/destination-remote-process-group.component.spec.ts | 33 | function createMockRemoteProcessGroup(groupName = 'Test Remote Process Group', inputPorts: any[] = []) { | CODE |
| LOW | …/create-connection/create-connection.component.spec.ts | 202 | function createMockRemoteProcessGroup(id = 'remote-group-id'): ConnectionDialogEndpoint { | CODE |
| LOW | …/nifi/src/app/ui/common/utils/component-state.utils.ts | 24 | export function runnableSupportsModification(entity: any): boolean { | CODE |
| LOW | …/nifi/src/app/ui/common/utils/component-state.utils.ts | 35 | export function remoteProcessGroupSupportsModification(entity: any): boolean { | CODE |
| LOW | …/nifi/src/app/ui/common/utils/component-state.utils.ts | 45 | export function getComponentTypeForSource(connectableType: string): ComponentType | null { | CODE |
| LOW | …/nifi/src/app/ui/common/utils/component-state.utils.ts | 65 | export function getComponentTypeForDestination(connectableType: string): ComponentType | null { | CODE |
| LOW | …/nifi/src/app/ui/common/utils/component-state.utils.ts | 85 | export function getConnectableTypeForSource(type: ComponentType): ConnectableComponentType | '' { | CODE |
| LOW | …/nifi/src/app/ui/common/utils/component-state.utils.ts | 105 | export function getConnectableTypeForDestination(type: ComponentType): ConnectableComponentType | '' { | CODE |
| LOW | …rc/app/ui/common/canvas/connectable-behavior.helper.ts | 56 | export function resolveConnectablePosition(datum: ConnectableComponentDatum): Position { | CODE |
| LOW | …app/ui/common/canvas/layers/render-context-fixtures.ts | 29 | export function createBaseRenderContextFixture( | CODE |
| LOW | …cess-group-layer/remote-process-group-renderer.spec.ts | 39 | function createMockRemoteProcessGroup( | CODE |
| LOW | …ers/process-group-layer/process-group-renderer.spec.ts | 1134 | function setupWithControllableCanSelect(initialCanSelect: boolean) { | CODE |
| LOW | …p/ui/common/canvas/utils/connection-collision.utils.ts | 46 | export function calculateConnectionCollisionBendsByIds( | CODE |
| LOW | …p/ui/common/canvas/utils/connection-collision.utils.ts | 76 | export function calculateConnectionCollisionBends( | CODE |
| LOW | …rvice-table/controller-service-table.component.spec.ts | 52 | function createMockControllerServiceEntity(): ControllerServiceEntity { | CODE |
| LOW | …roperty-value-tip/property-value-tip.component.spec.ts | 196 | function getParameterValueCellText(): string { | CODE |
| LOW | …s/ui/connector-table/connector-table.component.spec.ts | 114 | function createMockFlowConfiguration( | CODE |
| LOW | …ui/connector-canvas/connector-canvas.component.spec.ts | 406 | function configureConnectorCanvasTestBed(options: SetupOptions = {}, storage?: ReturnType<typeof createMockStorage>) { | CODE |
| LOW | …ui/connector-canvas/connector-canvas.component.spec.ts | 443 | function createConnectorCanvasFixture(storage: ReturnType<typeof createMockStorage>): { | CODE |
| LOW | …-info-control/connector-info-control.component.spec.ts | 31 | function createMockConnectorEntity(overrides: Partial<ConnectorEntity> = {}): ConnectorEntity { | CODE |
| LOW | …i/connector-configure/connector-configure.component.ts | 51 | function connectorWizardConfigFactory(): ConnectorWizardConfig { | CODE |
| LOW | …/connectors-listing/connectors-listing.effects.spec.ts | 127 | function createChangeVersionRequest( | CODE |
| LOW | …/state/purge-connector/purge-connector.effects.spec.ts | 90 | function createMockDropRequestEntity( | CODE |
| LOW | …-canvas-entity/connector-canvas-entity.reducer.spec.ts | 38 | function createMockConnectorEntity(overrides: Partial<ConnectorEntity> = {}): ConnectorEntity { | CODE |
| LOW | …-canvas-entity/connector-canvas-entity.effects.spec.ts | 53 | function createMockConnectorEntity(overrides: Partial<ConnectorEntity> = {}): ConnectorEntity { | CODE |
| LOW | …e/connector-canvas/bind-connector-parameter-context.ts | 34 | export function bindConnectorParameterContext( | CODE |
| LOW | …ors/state/connector-canvas/connector-canvas.reducer.ts | 23 | function hasCurrentOrNewerRevision(current: Revision, incoming: Revision): boolean { | CODE |
| LOW | …tate/connector-canvas/connector-canvas.effects.spec.ts | 1778 | function controllerServicesSuccessAction(connectorId: string, processGroupId: string) { | CODE |
| LOW | …/pages/connectors/testing/parameter-context-fixture.ts | 27 | export function createParameterContextFixture( | CODE |
| LOW | …connectors/testing/connector-canvas-entity-fixtures.ts | 294 | export function makeRemoteProcessGroupDto(overrides: Partial<RemoteProcessGroupDTO> = {}): RemoteProcessGroupDTO { | CODE |
| LOW | …vices/management-controller-services.component.spec.ts | 35 | function createMockControllerServiceEntity(): ControllerServiceEntity { | CODE |
| LOW | …w-analysis-rules/flow-analysis-rules.component.spec.ts | 36 | function createMockFlowAnalysisRuleEntity(): FlowAnalysisRuleEntity { | CODE |
| LOW | …-rule-table/flow-analysis-rule-table.component.spec.ts | 54 | function createMockFlowAnalysisRuleEntity(): FlowAnalysisRuleEntity { | CODE |
| LOW | …ui/registry-clients/registry-clients.component.spec.ts | 33 | function createMockRegistryClientEntity(): RegistryClientEntity { | CODE |
| LOW | …y-client-table/registry-client-table.component.spec.ts | 49 | function createMockRegistryClientEntity(): RegistryClientEntity { | CODE |
| LOW | …ameter-providers/parameter-providers.component.spec.ts | 32 | function createMockParameterProviderEntity(): ParameterProviderEntity { | CODE |
| LOW | …ders-table/parameter-providers-table.component.spec.ts | 52 | function createMockParameterProviderEntity(): ParameterProviderEntity { | CODE |
| LOW | …ders-table/parameter-providers-table.component.spec.ts | 138 | function createMockFlowConfiguration(supportsManagedAuthorizer = true): FlowConfiguration { | CODE |
| LOW | …s/ui/reporting-tasks/reporting-tasks.component.spec.ts | 35 | function createMockReportingTaskEntity(): ReportingTaskEntity { | CODE |
| LOW | …ting-task-table/reporting-task-table.component.spec.ts | 51 | function createMockReportingTaskEntity(): ReportingTaskEntity { | CODE |
| LOW | …ting-task-table/reporting-task-table.component.spec.ts | 149 | function createMockFlowConfiguration(): FlowConfiguration { | CODE |
| LOW | …low-analysis-rules/flow-analysis-rules.effects.spec.ts | 586 | function createMockFlowAnalysisRuleEntity(): FlowAnalysisRuleEntity { | CODE |
| LOW | …tate/registry-clients/registry-clients.effects.spec.ts | 493 | function createMockRegistryClientEntity(): RegistryClientEntity { | CODE |
| LOW | …arameter-providers/parameter-providers.effects.spec.ts | 47 | function createMockParameterProviderEntity(): ParameterProviderEntity { | CODE |
| 79 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …java/org/apache/nifi/processors/standard/TailFile.java | 553 | // We need to check if the existing file is the same as the one referred to in the state file based on | COMMENT |
| LOW | …time/manifest/impl/StandardRuntimeManifestBuilder.java | 605 | // a non-null DeprecationNotice, so we need to check if the reason is also non-null before setting the boolean h | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 90 | // Step 1: Create Parameter Context "P" with param1 | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 93 | // Step 2: Create v1 - Process Group A with just a Processor X using param1 | COMMENT |
| LOW | …ts/system/registry/ParameterContextPreservationIT.java | 105 | // Step 3: Create v2 - Add Process Group B inside A, also attached to P | COMMENT |
| LOW | …ts/system/registry/ParameterContextPreservationIT.java | 118 | // Step 4: Clean up original flow | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 129 | // Step 5: Import v1 FIRST time - creates A1 with Parameter Context "P" | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 136 | // Step 6: Import v1 SECOND time - creates A2 with Parameter Context "P (1)" | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 147 | // Step 7: Upgrade A2 from v1 to v2 (this adds Process Group B) | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 150 | // Step 8: Verify the NEW Process Group B uses the CORRECT parameter context | COMMENT |
| LOW | …/main/java/org/apache/nifi/util/MockPropertyValue.java | 129 | // if we have a processor where input requirement is INPUT_ALLOWED, we need to check if there is an | COMMENT |
| LOW | …/nifi/stateless/flow/StandardStatelessFlowCurrent.java | 267 | // Check if the component made any progress or not. If so, continue on. If not, we need to check if prov | COMMENT |
| LOW | …a/org/apache/nifi/provenance/AbstractRecordWriter.java | 128 | // once we have obtained the lock, we need to check if the writer | COMMENT |
| LOW⚡ | …ponents/connector/TestStandardConnectorRepository.java | 1265 | // Step 1: provider.syncAssets() called | COMMENT |
| LOW⚡ | …ponents/connector/TestStandardConnectorRepository.java | 1267 | // Step 2: provider.load() called to reload updated config (may also have been called during addConnector) | COMMENT |
| LOW⚡ | …/components/connector/StandardConnectorRepository.java | 1065 | // Step 1: Sync Connector Assets from Provider | COMMENT |
| LOW⚡ | …/components/connector/StandardConnectorRepository.java | 1069 | // Step 2: Sync ConnectorNode Configuration from Provider | COMMENT |
| LOW | …ronization/StandardVersionedComponentSynchronizer.java | 362 | // If this update adds a new Controller Service, then we need to check if the service already exists at a hi | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1084 | // 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.java | 1085 | // Step 2: Retrieve flow from Flow Registry | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1086 | // Step 3: Resolve Bundle info | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1087 | // 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.java | 1088 | // Step 5: Replicate the request or call serviceFacade.updateProcessGroup | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1094 | // 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.java | 1095 | // Step 2: Retrieve flow from Flow Registry | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1099 | // Step 3: Enrich version control info came from UI | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1110 | // Step 4: Replace parameter contexts if necessary | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1115 | // Step 5: Resolve Bundle info | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1125 | // 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.java | 1134 | // Step 7: Replicate the request or call serviceFacade.updateProcessGroup | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1508 | // Step 0: Get the Versioned Flow Snapshot from the Flow Registry | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1513 | // Step 1: Determine which components will be affected by updating the version | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1528 | // Step 3: Verify that all components in the snapshot exist on all nodes | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1529 | // Step 4: Verify that Process Group is already under version control. If not, must start Version Co | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 190 | // Step 0: Obtain the versioned flow snapshot to use for the update | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 195 | // Step 1: Determine which components will be affected by updating the flow | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 210 | // Step 3: Verify that all components in the snapshot exist on all nodes | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 211 | // Step 4: Verify that Process Group can be updated. Only versioned flows care about the verifyNotDi | COMMENT |
| LOW | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 384 | // 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.java | 41 | // If Load Balancing is configured but client entity indicates that data is not being transferred, we need to ch | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/java/org/apache/nifi/processors/mqtt/ConsumeMQTT.java | 387 | // 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.java | 290 | // 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.java | 90 | // Step 1: Create Parameter Context "P" with param1 | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 93 | // Step 2: Create v1 - Process Group A with just a Processor X using param1 | COMMENT |
| LOW | …ts/system/registry/ParameterContextPreservationIT.java | 105 | // Step 3: Create v2 - Add Process Group B inside A, also attached to P | COMMENT |
| LOW | …ts/system/registry/ParameterContextPreservationIT.java | 118 | // Step 4: Clean up original flow | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 129 | // Step 5: Import v1 FIRST time - creates A1 with Parameter Context "P" | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 136 | // Step 6: Import v1 SECOND time - creates A2 with Parameter Context "P (1)" | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 147 | // Step 7: Upgrade A2 from v1 to v2 (this adds Process Group B) | COMMENT |
| LOW⚡ | …ts/system/registry/ParameterContextPreservationIT.java | 150 | // Step 8: Verify the NEW Process Group B uses the CORRECT parameter context | COMMENT |
| LOW⚡ | …ponents/connector/TestStandardConnectorRepository.java | 1265 | // Step 1: provider.syncAssets() called | COMMENT |
| LOW⚡ | …ponents/connector/TestStandardConnectorRepository.java | 1267 | // Step 2: provider.load() called to reload updated config (may also have been called during addConnector) | COMMENT |
| LOW⚡ | …/components/connector/StandardConnectorRepository.java | 1065 | // Step 1: Sync Connector Assets from Provider | COMMENT |
| LOW⚡ | …/components/connector/StandardConnectorRepository.java | 1069 | // Step 2: Sync ConnectorNode Configuration from Provider | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1084 | // 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.java | 1085 | // Step 2: Retrieve flow from Flow Registry | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1086 | // Step 3: Resolve Bundle info | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1087 | // 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.java | 1088 | // Step 5: Replicate the request or call serviceFacade.updateProcessGroup | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1094 | // 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.java | 1095 | // Step 2: Retrieve flow from Flow Registry | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1099 | // Step 3: Enrich version control info came from UI | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1110 | // Step 4: Replace parameter contexts if necessary | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1115 | // Step 5: Resolve Bundle info | COMMENT |
| LOW⚡ | …java/org/apache/nifi/web/api/ProcessGroupResource.java | 1125 | // 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.java | 1134 | // Step 7: Replicate the request or call serviceFacade.updateProcessGroup | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1508 | // Step 0: Get the Versioned Flow Snapshot from the Flow Registry | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1513 | // Step 1: Determine which components will be affected by updating the version | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1528 | // Step 3: Verify that all components in the snapshot exist on all nodes | COMMENT |
| LOW⚡ | …ain/java/org/apache/nifi/web/api/VersionsResource.java | 1529 | // Step 4: Verify that Process Group is already under version control. If not, must start Version Co | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 190 | // Step 0: Obtain the versioned flow snapshot to use for the update | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 195 | // Step 1: Determine which components will be affected by updating the flow | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 210 | // Step 3: Verify that all components in the snapshot exist on all nodes | COMMENT |
| LOW⚡ | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 211 | // Step 4: Verify that Process Group can be updated. Only versioned flows care about the verifyNotDi | COMMENT |
| LOW | …n/java/org/apache/nifi/web/api/FlowUpdateResource.java | 384 | // Step 9: Ensure that if any connection exists in the flow and does not exist in the proposed snapshot, | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …he/nifi/processors/hadoop/AbstractHadoopProcessor.java | 280 | // properties this processor sets. TODO: re-work ListHDFS to utilize Kerberos | COMMENT |
| MEDIUM | …/src/main/java/org/apache/nifi/util/db/JdbcCommon.java | 379 | // Delegate mapping to AvroTypeUtil in order to utilize logical types. | COMMENT |
| MEDIUM | …/src/main/java/org/apache/nifi/util/db/JdbcCommon.java | 432 | // Delegate mapping to AvroTypeUtil in order to utilize logical types. | COMMENT |
| MEDIUM | …/src/main/java/org/apache/nifi/util/db/JdbcCommon.java | 444 | // Delegate mapping to AvroTypeUtil in order to utilize logical types. | COMMENT |
| MEDIUM | …fluent/schemaregistry/ProtobufMessageIndexEncoder.java | 74 | // 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.py | 567 | # Otherwise just return self, in order to avoid the cost of making the call to Java for evaluateAttributeExpress | COMMENT |
| LOW⚡ | …rk/src/main/python/framework/PythonProcessorAdapter.py | 57 | # If no customValidate method, just return | COMMENT |
| MEDIUM | …/status/history/VolatileComponentStatusRepository.java | 359 | // Updated getStatusHistory to utilize the start/end/preferredDataPoints parameters passed into | COMMENT |
| MEDIUM | …ava/org/apache/nifi/web/StandardNiFiContentAccess.java | 200 | // user authorization is handled once we have the actual content so we can utilize the flow file attributes in t | COMMENT |
| MEDIUM | …ava/org/apache/nifi/web/StandardNiFiContentAccess.java | 205 | // user authorization is handled once we have the actual prov event so we can utilize the event attributes in th | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …s/src/main/resources/extensions/DetectObjectInImage.py | 92 | # Create a blob from the image. I.e., perform pre-processing steps | COMMENT |
| MEDIUM | …work/minifi-resources/src/main/resources/bin/minifi.sh | 191 | # Create the init script, overwriting anything currently present | COMMENT |
| MEDIUM | …stry-resources/src/main/resources/bin/nifi-registry.sh | 193 | # Create the init script, overwriting anything currently present | COMMENT |
| MEDIUM | …k/src/test/python/framework/TestProcessorInspection.py | 206 | # Create a minimal AST node that simulates a dependency list | COMMENT |
| MEDIUM | …thon-framework/src/main/python/framework/Controller.py | 101 | # Create the Controller | COMMENT |
| MEDIUM | …thon-framework/src/main/python/framework/Controller.py | 104 | # Create the Java Gateway for communicating with NiFi Java process | COMMENT |
| MEDIUM | …thon-framework/src/main/python/framework/Controller.py | 118 | # Initialize the JvmHolder class with the gateway jvm. | COMMENT |
| MEDIUM | …ramework/src/main/python/framework/ExtensionManager.py | 367 | # Create the module specification | COMMENT |
| MEDIUM | …ramework/src/main/python/framework/ExtensionManager.py | 371 | # Create the module from the specification | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …g/apache/nifi/processors/script/TestExecuteGroovy.java | 0 | gender,title,first,last female,miss,marlene,shaw male,mr,todd,graham | STRING |
| HIGH | …/apache/nifi/processors/script/TestExecuteClojure.java | 0 | gender,title,first,last female,miss,marlene,shaw male,mr,todd,graham | STRING |
| HIGH | …e/nifi/processors/groovyx/ExecuteGroovyScriptTest.java | 0 | gender,title,first,last female,miss,marlene,shaw male,mr,todd,graham | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nsions/src/main/resources/extensions/SetRecordField.py | 46 | # Return the result | COMMENT |
| LOW | …gistry-core/nifi-registry-docker/dockerhub/sh/start.sh | 28 | # Check if we are secured or unsecured | COMMENT |
| LOW | .github/scripts/collect-system-tests-coverage.sh | 87 | # Check if report was generated | COMMENT |
| LOW | nifi-docker/dockerhub/sh/common.sh | 52 | # Set Path to include local directory for Astral uv | COMMENT |
| LOW | nifi-docker/dockerhub/sh/start.sh | 104 | # Check if we are secured or unsecured | COMMENT |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 210 | # Check if this is a PropertyDescriptor assignment | COMMENT |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 282 | # Check if the imported name is a PropertyDescriptor in the source module | COMMENT |
| LOW | …ramework/src/main/python/framework/ExtensionManager.py | 402 | # Check if the instance has a method named 'implements' | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …xtension-api/src/main/python/src/nifiapi/properties.py | 87 | CODE | |
| LOW | …xtension-api/src/main/python/src/nifiapi/properties.py | 202 | CODE | |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 159 | CODE | |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 194 | CODE | |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 245 | CODE | |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 580 | CODE | |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 36 | CODE | |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 99 | CODE | |
| LOW | …ramework/src/main/python/framework/ExtensionManager.py | 183 | CODE | |
| LOW | …ramework/src/main/python/framework/ExtensionManager.py | 210 | CODE | |
| LOW | …ramework/src/main/python/framework/ExtensionManager.py | 331 | CODE | |
| LOW | …ramework/src/main/python/framework/ExtensionManager.py | 395 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …main/resources/extensions/TestStateManagerException.py | 16 | CODE | |
| LOW | …nsions/src/main/resources/extensions/CreateFlowFile.py | 17 | CODE | |
| LOW | …nsions/src/main/resources/extensions/CreateFlowFile.py | 17 | CODE | |
| LOW | …nsions/src/main/resources/extensions/PopulateRecord.py | 18 | CODE | |
| LOW | …ions/src/main/resources/extensions/TestStateManager.py | 16 | CODE | |
| LOW | …ions/src/main/resources/extensions/TestStateManager.py | 16 | CODE | |
| LOW | …ions/src/main/resources/extensions/TestStateManager.py | 18 | CODE | |
| LOW | …ions/src/main/resources/extensions/TestStateManager.py | 18 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …sions/src/main/resources/extensions/HashRecordField.py | 81 | except Exception as exc: | CODE |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 278 | except Exception as e: | CODE |
| LOW | …ework/src/main/python/framework/ProcessorInspection.py | 481 | except Exception as e: | CODE |
| LOW | …ramework/src/main/python/framework/ExtensionManager.py | 206 | except Exception: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nsion-api/src/main/python/src/nifiapi/documentation.py | 123 | CODE | |
| LOW | …xtension-api/src/main/python/src/nifiapi/properties.py | 112 | CODE | |
| LOW | …ramework/src/main/python/framework/ExtensionDetails.py | 24 | CODE |