This is an automated email from the ASF dual-hosted git repository.
markap14 pushed a change to branch NIFI-15258
in repository https://gitbox.apache.org/repos/asf/nifi.git
omit 3169477b9a NIFI-15559: Enforce data permissions when purging data from
a Connector. (#10867)
omit c949b0ddd9 NIFI-15355 Connector Configuration Repository (#10876)
omit f486bf0b40 NIFI-15565: Code cleanup; improvements to .cursorrules to
provide bet… (#10869)
omit 98a8201034 NIFI-15539: Updating the actions in FlowFileQueueResource
to support … (#10846)
omit 073ad66a1c NIFI-15558: Sensitive Parameter References should resolve
to value. (#10863)
omit 89f23372bd NIFI-15544: If a Connector requires processors or
controller services that are unavailable, make Connector invalid but not
ghosted (#10851)
omit 9822e3e491 NIFI-15488: Added significant number of debug log messages
as well as some info/error for connector-related events (#10803)
omit 3e395f80a3 NIFI-15557: Allow Connectors to enable a Controller Service
using overridden property values (#10862)
omit 3f981da5b3 NIFI-15549: Adding endpoints for viewing and clearing state
for compo… (#10855)
omit a339750c6b NIFI-15480 Added ability to drop FlowFiles selectively
using a Predicate (#10848)
omit a65897d912 NIFI-15538: When starting/stopping components allow
specifying whethe… (#10843)
omit 7dc9cf250e NIFI-15514: Ensure that Parameter Contexts are assigned to
all Proces… (#10815)
omit 4e3292bbb1 NIFI-15511: Added endpoints for purging all FlowFiles for a
given Con… (#10833)
omit 9e213984b4 NIFI-15536: Change Connector API to use DescribedValue vs
AllowableValue (#10841)
omit c46e2900a6 NIFI-15509: Enable Component reload additional classpath
resources if needed (#10812)
omit c8728b5ca0 NIFI-15525: Ensure that we call onStepConfigured when we
restore flow; ensure that we synchronized Parmaeter Providers before Connectors
(#10835)
omit 4dbf84d7b0 NIFI-15529: Fix to StatelessGroupLifecycle to ensure that
we set the desired state of Stateless Group Node before attempting to schedule;
updated StandardProcessScheduler.startStatelessGroup to make it more clear if
this is left out again at some point (#10832)
omit 1348bb6fa3 NIFI-15467: Ensure that Connectors' versions are
automatically resolv… (#10811)
omit 2b72f7a588 NIFI-15465 Allow client-specified connector component ids
(#10768)
omit d386883011 NIFI-15495 Restart Connectors that reference assets that
were synchro… (#10806)
omit cb479b5f0c NIFI-15258: Fixes for system tests that needed to be
updated from 2.7.0-SNAPSHOT to 2.8.0-SNAPSHOT (#10807)
omit b412d59077 NIFI-15497: Fixed unit tests (#10805)
omit 60da16560f NIFI-15485: Include provider name when providing fqn for
secrets (#10801)
omit ed1f478f25 NIFI-15490: If any processors or controller services are
missing, make Connector invalid (#10799)
omit f43ef32d9a NIFI-15489: Addressed the 4 bugs called out in Jira: Wrong
delimiter in StandardConnectorPropertyValue.asList,
ConnectorValidationContextBridge.getProperty() does not resolve property value
properly; StandaloneProcessGroupLifecycle.stop() does not await controller
service disabling; switched hashmap in StandaloneProcessGroupLifecycle to
ConcurrentHashMap (#10798)
omit 135d3f0d70 NIFI-15461: Added ability to initiate drainage of
Connector's FlowFiles and calce; added tests to verify; some bug fixes (#10767)
omit afaa1be9b2 NIFI-15258: Addressed checkstyle violations
omit 109faf50a0 NIFI-15258: Fixes necessary after rebasing against main
omit 6af93e06f5 NIFI-15481: Updated ConnectorActions to reflect that
starting is not … (#10782)
omit 7a288a57bf NIFI-15451: Added ability for Connectors to retrieve
bundles availabl… (#10756)
omit cda2304051 NIFI-15482: MockConnectorAssetManager requires SPI file to
start (#10783)
omit b0481062fa NIFI-15472: Added addAsset methods to ConnectorTestRunner
(#10776)
omit b7420f7535 NIFI-15453: Adding an endpoint to return all controller
services for … (#10770)
omit 1be2089dae NIFI-15376: Adding dependencies to the configuration step
dto. (#10674)
omit 58735ea30e NIFI-15446: When invoking ConnectorMethod, make sure to
serialize/des… (#10750)
omit 8414bc7fcd NIFI-15468: Ensure that we properly initialize
ConnectorNode even if a Ghost Connector is created (#10775)
omit 4c98a8842f NIFI-15439: Ensure that Process Groups are accessible from
the approp… (#10742)
omit 8332e6db55 NIFI-15440: Implementation of ConnectorActions (#10748)
omit e07c90b7a6 NIFI-15445: Removed 'disabled' state from Connectors; also
fixed bug … (#10749)
omit acd54791a5 NIFI-15434: Ensure that we start or stop connectors on flow
sync (#10737)
omit fae768c537 NIFI-15433: If connector validation throws an Exception
keep trying u… (#10736)
omit ce1b4150a0 NIFI-15427: Added abiliy to drop flowfiles / drain
flowfiles from a C… (#10730)
omit dac8e8a013 NIFI-15430: Ensure that if we fail to initialize a
Connector, we crea… (#10733)
omit f931e1497e NIFI-15429: Adding an optional query parameter for
specifying which p… (#10732)
omit 39fe9e1dae NIFI-15353: Adding support for rendering Connector
Documentation. (#10683)
omit 7417597727 NIFI-15356: Adding authorization to the
StandardNiFiConnectorWebContext. (#10660)
omit 5b8af8d409 NIFI-15370: Add Connector ID to process groups and do not
register create process groups if they have a connector ID. (#10673)
omit e60e994d4e NIFI-15367: Ensure that Connectors' implicit parameter
contexts are n… (#10665)
omit 59b2ad0dca NIFI-15369: Allow ConfigurationStep to depend on another
(ConfigurationStep,Property) tuple (#10669)
omit e1f0916fe7 NIFI-15361: Allowing configuration step documentation to be
returned … (#10667)
omit dd971a1b27 NIFI-15315 Add support for assets in connectors (#10647)
omit 3a33552408 NIFI-15343: Adding an endpoint to return available secrets
to the con… (#10645)
omit c5f53200e4 NIFI-15352: Added ConnectorClient to toolkit-cli so that it
can be us… (#10654)
omit 7f44f3a9d7 NIFI-15258: Enable Custom UI to retrieve connector with
flow contexts (#10652)
omit f4c577540e NIFI-15336: Created AuthorizableSecret and implemented
ParameterProviderSecretProvider to provide the Parameter Provider as the
associated Authorizable (#10644)
omit 36a0ba24de NIFI-15312: Implementation of Parameter Provider based
Secrets Manager; updated mock framework to support secrets; validation cleanup
(#10638)
omit a470e8b9fa NIFI-15330: Allow GhostConnector to be updated (#10632)
omit 21de437b8a NIFI-15326: Adding support of configuration step
documentation. (#10631)
omit 9063b3ebc1 NIFI-15322: Require all property descriptors within a
PropertyGroup / ConfigurationStep are unique (#10626)
omit 798594c8ef NIFI-15323: Adding operate permissions to the
ConnectorEntity. (#10625)
omit c3393ee65f NIFI-15259: Added REST API for Connectors
omit 673db8e21d NIFI-15258: Addressed PMD findings
omit f80a0b7387 NIFI-15258: Fixed checkstyle violations/pmd
omit e04d6729dc NIFI-15258: Fixed vulnerable lz4 dependency
omit 9d87f0947b NIFI-15258: Initial implementation of Connectors
add d36ce3ccaa NIFI-15365 Fixed Verification for Temporary Processors and
Controller Services (#10688)
add 9783ddd9ec NIFI-15492 Expanded unit test for RingBufferEventRepository
add fd6fe92d9e NIFI-15493 Bump Groovy to 5.0.4, GCP BOM to 26.74.0,
Swagger to 2.2.42, and others (#10797)
add 6ab4faf2e9 NIFI-15491 - address security vulnerability with node-tar
dependency
add c31d02121a NIFI-15496 - Address Lodash Prototype Pollution
Vulnerability in "_.unset" and "_.omit" functions
add f81bfc3934 NIFI-15475 Blocked concurrent commits overwriting changes
with git-based Registry Clients (#10778)
add d4e67fd6cf NIFI-15507 Bump NiFi API to 2.6.0, Jersey to 4.0.1, Spring
Boot to 4.0.2, and others (#10810)
add 363addbe62 NIFI-15505 Added tests for property migration of Controller
Services in standard-services (#10808)
add 87f1487136 NIFI-15506 Replaced mock Processor classes for Controller
Services NoOpProcessor (#10814)
add a1e4f62a04 NIFI-15515 Bump Apache MINA SSH to 2.17.1, Logback to
1.5.26, Kinesis to 3.3.0, and others (#10819)
add 3611a2fe93 NIFI-15410 Improved auditing of stopping
RemoteProcessGroups (#10817)
add 3745552302 NIFI-15513 Added property migration tests for snowflake,
social-media, splunk, update-attribute, websocket, windows-event-log, workday
and zendesk (#10820)
add 666f60b685 NIFI-15522 Moved BootstrapCommunicator interface to MiNiFi
Framework API
add 4f99d4a378 NIFI-15518 - UI - address moderate vulnerability detected
in hono dependency
add 2aa11aadfd NIFI-15508 Added Record Gauge support to Standard Process
Session
add f40205b536 NIFI-10502 Replaced "Flow File" with "FlowFile" across
component descriptions
add 5b9b2b0783 NIFI-15517 Updated Email Processors with explicit Executor
to resolve constructor deprecation (#10821)
add 8e0050ac6a NIFI-15528 Removed invalid ReadsAttribute annotation from
UpdateCounter
add 039382b699 NIFI-15527 Added UpdateGauge Processor to standard bundle
add e8b1cd483f NIFI-15530 Removed SLF4J debug references from Property
Encryptor
add 29d5040714 NIFI-15526 Added Fast Reader Enabled property to Avro
Reader (#10829)
add 28b5c6a101 NIFI-15501 Added Unknown MIME Type Routing to
ModifyCompression Processor (#10828)
add 072fb85d50 NIFI-15524 Added Endpoint URL and Path Style Access to S3
FileIO Iceberg Provider (#10825)
add d9f9147306 NIFI-15474 Support timestamp truncation in RecordPath DSL
add ca768efa25 NIFI-15448 Add option for using Predefined Schemas in
GenerateRecord (#10752)
add 2610c5cacb NIFI-15523 Fixed Provenance EventIterator factory not
returning items (#10837)
add 51b9814164 NIFI-15534 Bump Jetty to 12.1.6, Jersey to 4.0.2, Azure BOM
to 1.3.4, GCP BOM to 26.75.0, and others (#10838)
add 2c55656e3d NIFI-14233 Fixed Python Processor imported Property
Dependencies (#10616)
add a1a00a3346 NIFI-15512 Added Parameter Context Validation for
synchronous updates (#10840)
add 2bddbbb9a4 NIFI-15537 - Set appropriate sandbox and referrerpolicy to
use with custom UI iframes
add 410dec6323 NIFI-14254 Fixed Event Time Sorting for Provenance Events
(#10809)
add 4c841b3291 NIFI-15531 Repositioned logging for NAR expansion to
include extension mapping (#10836)
add 43d9008897 NIFI-15543 Added disabled reason to testProcessRestarted
for Windows in PythonControllerInteractionIT (#10847)
add d1fbda477d NIFI-15552 Bump Apache Parent POM to v37, Elasticsearch to
9.3.0, Slack Bolt to 1.47.0, and others (#10856)
add d7ba6d871f NIFI-15551 Handle duplicate keys when collecting existing
asset references during synchronization
add 17b917796f NIFI-15542 Replaced deprecated
org.eclipse.jetty.http.BadMessageException with
org.eclipse.jetty.http.HttpException.RuntimeException
add 96ba9cc710 NIFI-15550 - Add optional header prefix property in
ConsumeKafka
add 24f5afcceb NIFI-15553 Replaced the use of JARs in
TestExecuteStreamCommand with the use of Java files (#10860)
add 1c61b548ac NIFI-15555 Added non-heap used tracking to Prometheus
Metrics (#10858)
add c55be0dcd1 NIFI-15556 Add support for Parameter Tags to AWS Secrets
Manager Parameter Provider (#10859)
add fcbc059157 NIFI-15541 Fixed Parameter Context binding for new Process
Groups on Version Upgrades (#10844)
add 9652fd2e36 NIFI-15548 Fixed ParquetReader ClassCastException for
java.time Logical Types (#10850)
add 89f1d4fef0 NIFI-15547 Fixed Parameter Provider compatible version
fallback on Import Flow (#10849)
add 7a21729b66 NIFI-15442 Added support for property migration in Registry
Clients and Parameter Providers (#10861)
add 83259a166c NIFI-15449 Fixed NAR deletion blocking indefinitely when
Python processor is initializing (#10753)
add 5bd4d78223 NIFI-15545 Added current partition lag method to Kafka
Consumer Service (#10852)
add b468145961 NIFI-15494 Added Component Type in Provenance Lineage
Display (#10800)
add e915e94e2e NIFI-15562 Fixed Symbolic Link resolution for directories
in ListSFTP (#10866)
add d1fa36a92b NIFI-15519 Skipped saving Flow Configuration on shutdown to
keep expected Processor states (#10864)
add 42df8ed0e5 NIFI-15561 Ignored Sensitive Status for Parameter
References in Ghosted Components (#10865)
add de6f17c06b NIFI-15566 Set DefaultsMode.STANDARD in S3 components
(#10870)
add ede26f48d7 NIFI-15464 Commit pending offsets for revoked partitions in
ConsumeKafka (#10769)
add 8506a919e4 NIFI-15569 Bump Netty to 4.2.10.Final, logback to 1.5.28,
Kotlin to 2.3.10, and others (#10873)
add 23b21f12f8 NIFI-15572 Added deprecation log and banner to NiFi
Registry (#10875)
add 119f8881fb NIFI-15567 Streamlined Component Authorizable Evaluation
Methods
add ca545ec7f9 NIFI-15578 - Address dependency issue with
@modelcontextprotocol/sdk (#10882)
new 5cd976881d NIFI-15258: Initial implementation of Connectors
new 08dbfabd44 NIFI-15258: Fixed vulnerable lz4 dependency
new 03da272f5e NIFI-15258: Fixed checkstyle violations/pmd
new 72285026a1 NIFI-15258: Addressed PMD findings
new 4271a51ce6 NIFI-15259: Added REST API for Connectors
new f7f6b1e894 NIFI-15323: Adding operate permissions to the
ConnectorEntity. (#10625)
new 99f16ea932 NIFI-15322: Require all property descriptors within a
PropertyGroup / ConfigurationStep are unique (#10626)
new e1c2420417 NIFI-15326: Adding support of configuration step
documentation. (#10631)
new 6a3609caa7 NIFI-15330: Allow GhostConnector to be updated (#10632)
new 0d306a5d77 NIFI-15312: Implementation of Parameter Provider based
Secrets Manager; updated mock framework to support secrets; validation cleanup
(#10638)
new aab779c087 NIFI-15336: Created AuthorizableSecret and implemented
ParameterProviderSecretProvider to provide the Parameter Provider as the
associated Authorizable (#10644)
new 41be9f5a85 NIFI-15258: Enable Custom UI to retrieve connector with
flow contexts (#10652)
new 4f8b6047d7 NIFI-15352: Added ConnectorClient to toolkit-cli so that it
can be us… (#10654)
new 8b18062810 NIFI-15343: Adding an endpoint to return available secrets
to the con… (#10645)
new 339860f275 NIFI-15315 Add support for assets in connectors (#10647)
new 752fcdede2 NIFI-15361: Allowing configuration step documentation to be
returned … (#10667)
new e7032a6382 NIFI-15369: Allow ConfigurationStep to depend on another
(ConfigurationStep,Property) tuple (#10669)
new b256cf7f00 NIFI-15367: Ensure that Connectors' implicit parameter
contexts are n… (#10665)
new 96f1bdba44 NIFI-15370: Add Connector ID to process groups and do not
register create process groups if they have a connector ID. (#10673)
new d5697340d7 NIFI-15356: Adding authorization to the
StandardNiFiConnectorWebContext. (#10660)
new 2d20310a2e NIFI-15353: Adding support for rendering Connector
Documentation. (#10683)
new 60369f9ccf NIFI-15429: Adding an optional query parameter for
specifying which p… (#10732)
new 002d672ef7 NIFI-15430: Ensure that if we fail to initialize a
Connector, we crea… (#10733)
new 3539adaa53 NIFI-15427: Added abiliy to drop flowfiles / drain
flowfiles from a C… (#10730)
new ccfaf0ffa8 NIFI-15433: If connector validation throws an Exception
keep trying u… (#10736)
new fe7e606d44 NIFI-15434: Ensure that we start or stop connectors on flow
sync (#10737)
new c7e34a15c0 NIFI-15445: Removed 'disabled' state from Connectors; also
fixed bug … (#10749)
new c7c0c859ca NIFI-15440: Implementation of ConnectorActions (#10748)
new 80f3971708 NIFI-15439: Ensure that Process Groups are accessible from
the approp… (#10742)
new 8c1a99c18e NIFI-15468: Ensure that we properly initialize
ConnectorNode even if a Ghost Connector is created (#10775)
new b028ba24f3 NIFI-15446: When invoking ConnectorMethod, make sure to
serialize/des… (#10750)
new 97e59eced9 NIFI-15376: Adding dependencies to the configuration step
dto. (#10674)
new bb47590ad5 NIFI-15453: Adding an endpoint to return all controller
services for … (#10770)
new e3add13298 NIFI-15472: Added addAsset methods to ConnectorTestRunner
(#10776)
new 76643f4e3e NIFI-15482: MockConnectorAssetManager requires SPI file to
start (#10783)
new 830b5dc3f8 NIFI-15451: Added ability for Connectors to retrieve
bundles availabl… (#10756)
new 649ae3e3f8 NIFI-15481: Updated ConnectorActions to reflect that
starting is not … (#10782)
new f7a7963f3c NIFI-15258: Fixes necessary after rebasing against main
new 793d4adfef NIFI-15258: Addressed checkstyle violations
new c361a200cd NIFI-15461: Added ability to initiate drainage of
Connector's FlowFiles and calce; added tests to verify; some bug fixes (#10767)
new 72c6a4ec64 NIFI-15489: Addressed the 4 bugs called out in Jira: Wrong
delimiter in StandardConnectorPropertyValue.asList,
ConnectorValidationContextBridge.getProperty() does not resolve property value
properly; StandaloneProcessGroupLifecycle.stop() does not await controller
service disabling; switched hashmap in StandaloneProcessGroupLifecycle to
ConcurrentHashMap (#10798)
new 0a166d2938 NIFI-15490: If any processors or controller services are
missing, make Connector invalid (#10799)
new 31b8052413 NIFI-15485: Include provider name when providing fqn for
secrets (#10801)
new c0772f22a6 NIFI-15497: Fixed unit tests (#10805)
new 818e58e3c6 NIFI-15258: Fixes for system tests that needed to be
updated from 2.7.0-SNAPSHOT to 2.8.0-SNAPSHOT (#10807)
new f25c1e27b4 NIFI-15495 Restart Connectors that reference assets that
were synchro… (#10806)
new 9afd695940 NIFI-15465 Allow client-specified connector component ids
(#10768)
new 24ffeda3d0 NIFI-15467: Ensure that Connectors' versions are
automatically resolv… (#10811)
new fb2922cab4 NIFI-15529: Fix to StatelessGroupLifecycle to ensure that
we set the desired state of Stateless Group Node before attempting to schedule;
updated StandardProcessScheduler.startStatelessGroup to make it more clear if
this is left out again at some point (#10832)
new 2ee543934e NIFI-15525: Ensure that we call onStepConfigured when we
restore flow; ensure that we synchronized Parmaeter Providers before Connectors
(#10835)
new 65b3b82dcc NIFI-15509: Enable Component reload additional classpath
resources if needed (#10812)
new 26bbc9f6c0 NIFI-15536: Change Connector API to use DescribedValue vs
AllowableValue (#10841)
new 8d6a43e9f8 NIFI-15511: Added endpoints for purging all FlowFiles for a
given Con… (#10833)
new a5cb19dd4c NIFI-15514: Ensure that Parameter Contexts are assigned to
all Proces… (#10815)
new a5b99f27ed NIFI-15538: When starting/stopping components allow
specifying whethe… (#10843)
new b0fd8105b7 NIFI-15480 Added ability to drop FlowFiles selectively
using a Predicate (#10848)
new 8a04dca62c NIFI-15549: Adding endpoints for viewing and clearing state
for compo… (#10855)
new 4013e7ee5f NIFI-15557: Allow Connectors to enable a Controller Service
using overridden property values (#10862)
new 299c4097ac NIFI-15488: Added significant number of debug log messages
as well as some info/error for connector-related events (#10803)
new 837580cfdc NIFI-15544: If a Connector requires processors or
controller services that are unavailable, make Connector invalid but not
ghosted (#10851)
new 54ece65710 NIFI-15558: Sensitive Parameter References should resolve
to value. (#10863)
new 3abd4ab966 NIFI-15539: Updating the actions in FlowFileQueueResource
to support … (#10846)
new 43936047b1 NIFI-15565: Code cleanup; improvements to .cursorrules to
provide bet… (#10869)
new 78591672ba NIFI-15355 Connector Configuration Repository (#10876)
new 2d4937087a NIFI-15559: Enforce data permissions when purging data from
a Connector. (#10867)
new 8bc373e3c7 NIFI-15258: Fixes as a result of rebasing against main
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3169477b9a)
\
N -- N -- N refs/heads/NIFI-15258 (8bc373e3c7)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 66 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../minifi}/bootstrap/BootstrapCommunicator.java | 2 +-
.../nifi/minifi}/bootstrap/CommandResult.java | 2 +-
.../c2/BootstrapC2OperationRestartHandler.java | 8 +-
.../apache/nifi/minifi/c2/C2NifiClientService.java | 2 +-
.../c2/BootstrapC2OperationRestartHandlerTest.java | 8 +-
.../nifi/minifi/bootstrap/BootstrapListener.java | 6 +-
nifi-code-coverage/pom.xml | 2 +-
nifi-commons/nifi-calcite-utils/pom.xml | 2 +-
.../apache/nifi/provenance/lineage/EventNode.java | 5 +
.../org/apache/nifi/util/FlowFilePackagerV2.java | 12 +-
nifi-commons/nifi-metrics/pom.xml | 4 +-
.../org/apache/nifi/metrics/jvm/JmxJvmMetrics.java | 12 +
.../org/apache/nifi/metrics/jvm/JvmMetrics.java | 18 +
nifi-commons/nifi-property-encryptor/pom.xml | 4 -
.../encrypt/StandardPropertySecretKeyProvider.java | 7 -
.../{NoArgStringFunction.java => Divide.java} | 39 +-
.../{NoArgStringFunction.java => Multiply.java} | 39 +-
.../functions/{FieldName.java => ToNumber.java} | 27 +-
.../nifi/record/path/math/MathBinaryEvaluator.java | 55 +
.../nifi/record/path/math/MathBinaryOperator.java} | 12 +-
.../nifi/record/path/math/MathDivideOperator.java} | 31 +-
.../nifi/record/path/math/MathEvaluator.java | 10 +-
.../record/path/math/MathMultiplyOperator.java | 18 +-
.../apache/nifi/record/path/math/MathOperator.java | 8 +-
.../nifi/record/path/math/MathTypeUtils.java | 56 +
.../nifi/record/path/paths/RecordPathCompiler.java | 15 +
.../apache/nifi/record/path/TestRecordPath.java | 282 +++-
.../flowfile/attributes/FlowFileMediaType.java | 2 +-
.../attributes/StandardFlowFileMediaType.java | 2 +-
.../server/StandardConnectorMockServer.java | 2 +
.../src/main/asciidoc/administration-guide.adoc | 9 +
nifi-docs/src/main/asciidoc/record-path-guide.adoc | 99 ++
.../bitbucket/BitbucketFlowRegistryClient.java | 7 +
.../bitbucket/BitbucketRepositoryClient.java | 15 +-
.../processors/aws/s3/AbstractS3Processor.java | 3 +-
.../nifi-aws-bundle/nifi-aws-kinesis/pom.xml | 2 +-
.../processors/aws/kinesis/ConsumeKinesis.java | 16 +-
.../aws/AwsSecretsManagerParameterProvider.java | 78 +-
.../TestAwsSecretsManagerParameterProvider.java | 237 ++-
.../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +-
.../provider/service/MockAWSProcessor.java | 71 -
...entialsProviderControllerServiceStrategies.java | 5 +-
nifi-extension-bundles/nifi-aws-bundle/pom.xml | 2 +-
.../azure/devops/AzureDevOpsRepositoryClient.java | 23 +-
.../processors/compress/ModifyCompression.java | 33 +-
.../processors/compress/TestModifyCompression.java | 35 +
.../nifi-confluent-protobuf-antlr-parser/pom.xml | 1 -
.../nifi-couchbase-standard-services/pom.xml | 2 +-
.../nifi/processors/dropbox/ListDropboxTest.java | 32 +
.../TestControllerServiceProcessor.java | 52 -
.../integration/AbstractElasticsearch_IT.java | 5 +-
.../integration/ElasticSearchLookupService_IT.java | 3 -
.../unit/ElasticSearchClientServiceImplTest.java | 5 +-
.../unit/ElasticSearchLookupServiceTest.java | 6 +-
.../unit/ElasticSearchStringLookupServiceTest.java | 6 +-
.../nifi-elasticsearch-bundle/pom.xml | 2 +-
.../nifi-email-processors/pom.xml | 2 +-
.../processors/email/AbstractEmailProcessor.java | 5 +-
.../additionalDetails.md | 2 +-
.../additionalDetails.md | 2 +-
.../nifi/processors/email/TestConsumeEmail.java | 22 +
.../processors/email/TestExtractEmailHeaders.java | 61 +-
.../nifi/processors/TestGeoEnrichIPRecord.java | 45 +-
.../apache/nifi/processors/evtx/ParseEvtxTest.java | 12 +
.../flow/git/AbstractGitFlowRegistryClient.java | 32 +-
.../flow/git/client/GitCreateContentRequest.java | 13 +
.../flow/git/client/GitRepositoryClient.java | 17 +
.../git/AbstractGitFlowRegistryClientTest.java | 5 +
.../java/org/apache/nifi/avro/AvroTypeUtil.java | 20 +
.../processors/hadoop/AbstractPutHDFSRecord.java | 10 +-
...bstractGetGcpVisionAnnotateOperationStatus.java | 6 +-
.../vision/AbstractStartGcpVisionOperation.java | 2 +-
.../GetGcpVisionAnnotateFilesOperationStatus.java | 4 +-
.../GetGcpVisionAnnotateImagesOperationStatus.java | 4 +-
.../processors/gcp/bigquery/PutBigQueryTest.java | 40 +-
...PCredentialsControllerServiceMigrationTest.java | 26 +
.../processors/gcp/drive/FetchGoogleDriveTest.java | 22 +-
.../gcp/drive/ListGoogleDriveSimpleTest.java | 41 +-
.../processors/gcp/drive/PutGoogleDriveTest.java | 28 +-
.../processors/gcp/pubsub/ConsumeGCPubSubTest.java | 99 +-
.../processors/gcp/pubsub/PublishGCPubSubTest.java | 41 +-
.../gcp/storage/DeleteGCSObjectTest.java | 32 +
.../processors/gcp/storage/FetchGCSObjectTest.java | 41 +-
.../processors/gcp/storage/ListGCSBucketTest.java | 36 +
.../processors/gcp/storage/PutGCSObjectTest.java | 53 +-
...tGcpVisionAnnotateFilesOperationStatusTest.java | 4 +-
...GcpVisionAnnotateImagesOperationStatusTest.java | 4 +-
.../StartGcpVisionAnnotateFilesOperationTest.java | 41 +-
.../StartGcpVisionAnnotateImagesOperationTest.java | 27 +-
nifi-extension-bundles/nifi-gcp-bundle/pom.xml | 2 +-
.../apache/nifi/github/GitHubRepositoryClient.java | 28 +
.../nifi/github/GitHubFlowRegistryClientTest.java | 83 +
.../apache/nifi/gitlab/GitLabRepositoryClient.java | 7 +
.../graph/ExecuteGraphQueryRecordTest.java | 27 +-
.../processors/graph/TestExecuteGraphQuery.java | 32 +-
.../nifi/graph/TestNeo4JCypherClientService.java | 51 +
.../groovyx/ExecuteGroovyScriptTest.java | 14 +
.../apache/nifi/processors/hadoop/PutHDFSTest.java | 51 +-
.../hadoop/TestCreateHadoopSequenceFile.java | 47 +-
.../nifi/processors/hadoop/TestDeleteHDFS.java | 34 +-
.../processors/hadoop/TestGetHDFSFileInfo.java | 101 +-
.../nifi/processors/hadoop/TestListHDFS.java | 38 +-
.../iceberg/aws/S3IcebergFileIOProvider.java | 32 +-
.../nifi-iotdb-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-iotdb-bundle/pom.xml | 2 +-
.../jms/cf/JMSConnectionFactoryProviderTest.java | 71 +-
.../nifi/kafka/processors/ConsumeKafkaIT.java | 48 +
.../kafka/processors/ConsumeKafkaRebalanceIT.java | 360 ++++
.../apache/nifi/kafka/processors/ConsumeKafka.java | 54 +-
.../nifi/kafka/processors/common/KafkaUtils.java | 9 +-
.../FlowFileStreamKafkaMessageConverter.java | 5 +-
.../kafka/processors/common/KafkaUtilsTest.java | 169 ++
.../service/api/consumer/KafkaConsumerService.java | 49 +
.../nifi-kafka-service-aws/pom.xml | 2 +-
.../nifi-kafka-service-shared/pom.xml | 2 +-
.../service/consumer/Kafka3AssignmentService.java | 6 +
.../service/consumer/Kafka3ConsumerService.java | 172 +-
.../service/Kafka3ConnectionServiceBaseIT.java | 53 +-
.../consumer/Kafka3ConsumerServiceTest.java | 287 ++++
.../nifi/mongodb/MongoDBControllerServiceIT.java | 7 +-
.../nifi/mongodb/MongoDBControllerServiceTest.java | 17 +-
.../nifi/mongodb/MongoDBLookupServiceIT.java | 4 +-
.../mongodb/TestControllerServiceProcessor.java | 48 -
.../nifi/mongodb/TestLookupServiceProcessor.java | 48 -
nifi-extension-bundles/nifi-mongodb-bundle/pom.xml | 2 +-
.../nifi-opentelemetry-bundle/pom.xml | 2 +-
.../org/apache/nifi/parquet/ParquetTestUtils.java | 61 +
.../org/apache/nifi/parquet/TestParquetReader.java | 36 +
.../nifi/processors/parquet/FetchParquetTest.java | 52 +-
.../nifi/processors/parquet/PutParquetTest.java | 45 +-
.../nifi/processors/pgp/DecryptContentPGP.java | 2 +-
.../nifi/processors/pgp/EncryptContentPGP.java | 2 +-
.../apache/nifi/processors/pgp/SignContentPGP.java | 2 +-
.../nifi/processors/pgp/VerifyContentPGP.java | 2 +-
.../standard/StandardPGPPrivateKeyServiceTest.java | 6 +-
.../standard/StandardPGPPublicKeyServiceTest.java | 6 +-
.../nifi-protobuf-services/pom.xml | 2 +-
.../java/org/apache/nifi/py4j/PythonProcess.java | 74 +-
.../org/apache/nifi/py4j/StandardPythonBridge.java | 48 +-
.../nifi/py4j/StandardPythonProcessorBridge.java | 85 +-
.../python/processor/PythonProcessorProxy.java | 8 +
.../org/apache/nifi/py4j/PythonProcessTest.java | 295 ++--
.../py4j/StandardPythonProcessorBridgeTest.java | 176 ++
.../PythonControllerInteractionIT.java | 59 +-
.../nifi-slack-processors/pom.xml | 2 +-
.../apache/nifi/processors/smb/ListSmbTest.java | 69 +-
.../nifi-snmp-bundle/nifi-snmp-processors/pom.xml | 2 +-
.../snowflake/TestGetSnowflakeIngestStatus.java} | 32 +-
.../snowflake/TestPutSnowflakeInternalStage.java} | 29 +-
.../snowflake/TestStartSnowflakeIngest.java} | 32 +-
.../SnowflakeComputingConnectionPoolTest.java | 44 +
...ndardSnowflakeIngestManagerProviderService.java | 56 +
.../nifi-snowflake-bundle/pom.xml | 4 +-
.../processors/twitter/TestConsumeTwitter.java | 30 +
.../nifi/processors/splunk/TestPutSplunkHTTP.java | 71 +-
.../splunk/TestQuerySplunkIndexingStatus.java | 30 +-
.../nifi-standard-processors/pom.xml | 4 -
.../processors/standard/AbstractExecuteSQL.java | 15 +-
.../standard/AbstractQueryDatabaseTable.java | 9 +-
.../nifi/processors/standard/ExecuteSQL.java | 16 +-
.../nifi/processors/standard/ExecuteSQLRecord.java | 8 +-
.../nifi/processors/standard/GenerateRecord.java | 150 +-
.../nifi/processors/standard/MonitorActivity.java | 2 +-
.../processors/standard/QueryDatabaseTable.java | 6 +-
.../standard/QueryDatabaseTableRecord.java | 12 +-
.../nifi/processors/standard/UpdateCounter.java | 2 -
.../{UpdateCounter.java => UpdateGauge.java} | 72 +-
.../standard/faker/PredefinedRecordSchema.java | 757 +++++++++
.../processors/standard/util/SFTPTransfer.java | 8 +-
.../services/org.apache.nifi.processor.Processor | 1 +
.../standard/QueryDatabaseTableRecordTest.java | 7 +-
.../standard/QueryDatabaseTableTest.java | 7 +-
.../nifi/processors/standard/TestExecuteSQL.java | 1 +
.../processors/standard/TestExecuteSQLRecord.java | 1 +
.../standard/TestExecuteStreamCommand.java | 692 +++-----
.../processors/standard/TestGenerateRecord.java | 128 ++
.../nifi/processors/standard/TestUpdateGauge.java | 77 +
.../standard/util/TestServerSFTPTransfer.java | 29 +-
.../src/test/resources/ExecuteCommand/1mb.txt | 101 --
.../ExecuteCommand/TestDynamicEnvironment.jar | Bin 1200 -> 0 bytes
.../ExecuteCommand/TestIngestAndUpdate.jar | Bin 1170 -> 0 bytes
.../resources/ExecuteCommand/TestLogStdErr.jar | Bin 995 -> 0 bytes
.../test/resources/ExecuteCommand/TestSuccess.jar | Bin 827 -> 0 bytes
.../src/test/resources/ExecuteCommand/test.txt | 2 -
.../controller/ControllerStatusReportingTask.java | 6 +-
.../additionalDetails.md | 4 +-
.../java/org/apache/nifi/dbcp/DBCPServiceTest.java | 51 +-
.../record/sink/db/DatabaseRecordSinkTest.java | 75 +-
.../nifi/dbcp/HikariCPConnectionPoolTest.java | 30 +
.../cache/server/map/MapCacheServiceTlsTest.java | 4 +-
.../distributed/cache/server/map/MapCacheTest.java | 5 +-
.../map/TestDistributedMapServerAndClient.java | 4 +-
.../cache/server/set/SetCacheServiceTest.java | 5 +-
.../set/TestDistributedSetServerAndClient.java | 5 +-
.../service/StandardFileResourceServiceTest.java | 18 +
.../nifi/dbcp/TestHadoopDBCPConnectionPool.java | 81 +
.../key/service/StandardPrivateKeyServiceTest.java | 26 +-
.../nifi/lookup/TestCSVRecordLookupService.java | 56 +-
.../TestDistributedMapCacheLookupService.java | 38 +-
.../java/org/apache/nifi/lookup/TestProcessor.java | 46 -
.../lookup/TestPropertiesFileLookupService.java | 38 +-
.../apache/nifi/lookup/TestRestLookupService.java | 31 +
.../lookup/TestSimpleCsvFileLookupService.java | 66 +-
.../lookup/TestSimpleKeyValueLookupService.java | 3 +-
.../nifi/lookup/TestXMLFileLookupService.java | 37 +-
.../lookup/db/TestDatabaseRecordLookupService.java | 28 +
.../lookup/db/TestSimpleDatabaseLookupService.java | 23 +
.../nifi/lookup/maxmind/TestIPLookupService.java | 30 +-
.../StandardOauth2AccessTokenProviderTest.java | 44 +-
.../TestStandardProxyConfigurationService.java | 51 +
.../main/java/org/apache/nifi/avro/AvroReader.java | 20 +-
.../nifi/avro/AvroReaderWithEmbeddedSchema.java | 9 +-
.../nifi/avro/AvroReaderWithExplicitSchema.java | 15 +-
.../org/apache/nifi/avro/AvroRecordSetWriter.java | 2 +-
.../apache/nifi/avro/NonCachingDatumReader.java | 4 +
.../java/org/apache/nifi/avro/TestAvroReader.java | 60 +
.../apache/nifi/avro/TestAvroRecordSetWriter.java | 68 +
.../java/org/apache/nifi/cef/TestCEFReader.java | 65 +-
.../java/org/apache/nifi/csv/TestCSVReader.java | 65 +
.../apache/nifi/csv/TestCSVRecordSetWriter.java | 67 +
.../java/org/apache/nifi/grok/TestGrokReader.java | 35 +
.../apache/nifi/json/TestJsonRecordSetWriter.java | 69 +
.../org/apache/nifi/json/TestJsonTreeReader.java | 65 +
.../org/apache/nifi/lookup/TestReaderLookup.java | 8 +-
.../nifi/lookup/TestRecordSetWriterLookup.java | 28 +-
.../schema/inference/TestVolatileSchemaCache.java | 18 +
.../serialization/TestRecordReaderProcessor.java | 45 -
.../TestRecordSetWriterProcessor.java | 45 -
.../apache/nifi/syslog/TestSyslog5424Reader.java | 60 +
.../org/apache/nifi/syslog/TestSyslogReader.java | 60 +
.../java/org/apache/nifi/xml/TestXMLReader.java | 38 +
.../apache/nifi/xml/TestXMLRecordSetWriter.java | 61 +-
.../nifi/record/sink/TestEmailRecordSink.java | 36 +-
.../nifi/record/sink/TestLoggingRecordSink.java | 22 +-
.../org/apache/nifi/record/sink/TestProcessor.java | 45 -
.../record/sink/event/TestUDPEventRecordSink.java | 22 +
.../sink/lookup/TestRecordSinkServiceLookup.java | 5 +-
.../nifi/ssl/StandardSSLContextServiceTest.java | 20 +
.../StandardWebClientServiceProviderTest.java | 24 +
.../nifi-standard-shared-bom/pom.xml | 4 +-
.../update/attributes/TestUpdateAttribute.java | 11 +
.../processors/websocket/TestConnectWebSocket.java | 13 +
.../processors/websocket/TestListenWebSocket.java | 38 +-
.../processors/websocket/TestPutWebSocket.java | 15 +
.../jetty/AbstractJettyWebSocketService.java | 1 -
.../websocket/jetty/TestJettyWebSocketClient.java | 5 +-
.../websocket/jetty/TestJettyWebSocketServer.java | 42 +-
.../event/log/ConsumeWindowsEventLogTest.java | 17 +
.../processors/workday/GetWorkdayReportTest.java | 15 +-
.../nifi/processors/zendesk/GetZendeskTest.java | 24 +
.../processors/zendesk/PutZendeskTicketTest.java | 32 +-
.../services/zendesk/ZendeskRecordSinkTest.java | 163 +-
.../nifi/components/AsyncLoadedProcessor.java | 23 +-
.../controller/metrics/ComponentMetricContext.java | 24 +-
.../metrics/ComponentMetricReporter.java | 36 +-
...mponentMetricReporterConfigurationContext.java} | 16 +-
.../nifi/controller/metrics/CounterRecord.java | 23 +-
.../nifi/controller/metrics/GaugeRecord.java | 23 +-
.../lineage/ProvenanceEventLineageNode.java | 5 +
.../provenance/store/iterator/EventIterator.java | 9 +-
.../store/iterator/EventIteratorTest.java | 67 +
.../python/processor/PythonProcessorBridge.java | 17 +
.../nifi-python-framework/pom.xml | 1 -
.../main/python/framework/ProcessorInspection.py | 193 ++-
.../python/framework/TestProcessorInspection.py | 224 +++
.../ProcessorWithImportedDependency.py | 84 +
.../SharedProperties.py | 44 +
.../imported_property_dependency}/__init__.py | 1 +
.../nifi-questdb-bundle/nifi-questdb/pom.xml | 2 +-
.../org/apache/nifi/web/api/dto/ControllerDTO.java | 12 +-
.../web/api/dto/provenance/ProvenanceEventDTO.java | 16 +
.../dto/provenance/lineage/ProvenanceNodeDTO.java | 14 +
.../nifi/controller/StandardProcessorNode.java | 23 +-
.../metrics/DefaultComponentMetricReporter.java | 13 +-
...mponentMetricReporterConfigurationContext.java} | 8 +-
.../parameter/StandardParameterProviderNode.java | 29 +
.../repository/AbstractRepositoryContext.java | 62 +-
.../controller/repository/RepositoryContext.java | 6 +
.../repository/StandardProcessSession.java | 48 +-
.../service/StandardControllerServiceNode.java | 26 +-
.../StandardVersionedComponentSynchronizer.java | 96 +-
.../nifi/parameter/ParameterContextNameUtils.java | 141 ++
.../nifi/parameter/StandardParameterContext.java | 8 +
.../flow/FlowAnalyzingRegistryClientNode.java | 6 +
.../flow/StandardFlowRegistryClientNode.java | 29 +
.../repository/TestRingBufferEventRepository.java | 230 +--
.../parameter/TestStandardParameterContext.java | 93 +-
.../validation/VerifiableComponentFactory.java | 48 +
.../nifi/controller/AbstractComponentNode.java | 6 +-
.../org/apache/nifi/controller/AbstractPort.java | 2 +-
.../nifi/controller/ParameterProviderNode.java | 10 +
.../nifi/registry/flow/FlowRegistryClientNode.java | 9 +
.../nifi/asset/StandardAssetSynchronizer.java | 2 +-
.../StandardVerifiableComponentFactory.java | 87 +
.../apache/nifi/controller/ExtensionBuilder.java | 18 +-
.../org/apache/nifi/controller/FlowController.java | 33 +-
.../nifi/controller/StandardFlowService.java | 32 +-
.../nifi/controller/StandardReloadComponent.java | 10 +
.../nifi/controller/flow/StandardFlowManager.java | 2 +
.../flow/StandardStatelessGroupNodeFactory.java | 1 +
.../repository/StandardRepositoryContext.java | 18 +-
.../scheduling/RepositoryContextFactory.java | 31 +-
.../serialization/VersionedFlowSynchronizer.java | 28 +-
.../configuration/FlowControllerConfiguration.java | 91 +-
.../connector/StandardConnectorNodeIT.java | 6 +-
.../repository/StandardProcessSessionIT.java | 12 +-
.../scheduling/TestStandardProcessScheduler.java | 16 +-
.../StandardControllerServiceProviderTest.java | 2 +
.../TestStandardControllerServiceProvider.java | 5 +-
.../org/apache/nifi/nar/StandardNarLoader.java | 3 -
.../nar/StandardExtensionDiscoveringManager.java | 4 +-
.../status/history/NodeStatusDescriptor.java | 4 +-
.../apache/nifi/headless/HeadlessNiFiServer.java | 28 +-
.../main/java/org/apache/nifi/nar/NarUnpacker.java | 13 +-
.../connector/HostPortValidatorCustomizer.java | 4 +-
.../nifi/audit/RemoteProcessGroupAuditor.java | 11 +-
.../authorization/AuthorizeComponentReference.java | 86 +
.../authorization/AuthorizeParameterReference.java | 22 -
.../nifi/prometheusutil/JvmMetricsRegistry.java | 18 +
.../nifi/prometheusutil/PrometheusMetricsUtil.java | 3 +
.../web/StandardNiFiWebConfigurationContext.java | 30 +-
.../apache/nifi/web/api/ControllerResource.java | 88 +-
.../nifi/web/api/ControllerServiceResource.java | 9 +-
.../nifi/web/api/ParameterContextResource.java | 3 +
.../nifi/web/api/ParameterProviderResource.java | 6 +-
.../apache/nifi/web/api/ProcessGroupResource.java | 58 +-
.../org/apache/nifi/web/api/ProcessorResource.java | 9 +-
.../apache/nifi/web/api/ReportingTaskResource.java | 7 +-
.../org/apache/nifi/web/api/dto/DtoFactory.java | 1 +
.../nifi/web/controller/ControllerFacade.java | 6 +-
.../ParameterContextNameCollisionResolver.java | 44 +-
.../nifi/audit/TestRemoteProcessGroupAuditor.java | 2 +-
.../AuthorizeComponentReferenceTest.java | 82 +
.../feature/jolt-transform-json-ui.component.html | 2 +-
.../external-viewer/external-viewer.component.html | 4 +
.../app/pages/provenance/state/lineage/index.ts | 1 +
.../lineage/lineage.component.ts | 37 +-
.../provenance-event-table.component.ts | 5 +-
.../apps/nifi/src/app/state/shared/index.ts | 1 +
.../common/advanced-ui/advanced-ui.component.html | 3 +
.../bulletins-tip/bulletins-tip.component.html | 4 +-
nifi-frontend/src/main/frontend/package-lock.json | 1737 +++++++-------------
nifi-frontend/src/main/frontend/package.json | 3 +-
.../org/apache/nifi/util/MockProcessSession.java | 23 +
.../org/apache/nifi/util/SharedSessionState.java | 14 +
.../nifi/util/StandardProcessorTestRunner.java | 5 +
.../main/java/org/apache/nifi/util/TestRunner.java | 8 +
.../nifi/util/TestStandardProcessorTestRunner.java | 47 +-
.../nifi/registry/bootstrap/RunNiFiRegistry.java | 2 +
.../org/apache/nifi/registry/NiFiRegistry.java | 3 +
.../nifi-registry-core/nifi-registry-test/pom.xml | 2 +-
.../src/main/webapp/nf-registry.html | 6 +
.../main/webapp/theming/_structureElements.scss | 27 +
nifi-registry/pom.xml | 4 +-
.../nifi/stateless/engine/ComponentBuilder.java | 7 +-
.../stateless/engine/StandardStatelessEngine.java | 8 +
.../nifi/stateless/engine/StatelessEngine.java | 3 +
.../StatelessVerifiableComponentFactory.java | 92 ++
.../flow/StandardStatelessDataflowFactory.java | 5 +-
.../repository/StatelessRepositoryContext.java | 17 +-
.../StatelessRepositoryContextFactory.java | 15 +-
.../nifi-python-test-extensions-nar/pom.xml | 1 -
.../pom.xml | 7 +-
.../pom.xml | 6 +-
.../metrics/SystemTestComponentMetricReporter.java | 88 +
...nifi.controller.metrics.ComponentMetricReporter | 3 +-
.../pom.xml | 10 +-
.../nifi/processors/tests/system/UpdateMetric.java | 30 +-
.../services/org.apache.nifi.processor.Processor | 3 +-
nifi-system-tests/nifi-system-test-suite/pom.xml | 6 +
.../src/test/assembly/dependencies.xml | 1 +
.../ComponentMetricReporterIT.java} | 45 +-
.../parameters/ClusteredParameterContextIT.java | 6 +-
...ParameterSensitivityWithGhostedComponentIT.java | 158 ++
.../pg/ImportFlowWithIncompatibleBundleIT.java | 171 ++
.../python/PythonNarDeletionDuringInitIT.java | 298 ++++
.../registry/ParameterContextPreservationIT.java | 191 +++
.../restart/ProcessorAutoResumeAfterRestartIT.java | 146 ++
nifi-system-tests/pom.xml | 1 +
pom.xml | 55 +-
380 files changed, 11760 insertions(+), 4156 deletions(-)
rename {nifi-framework-api/src/main/java/org/apache/nifi =>
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-api/src/main/java/org/apache/nifi/minifi}/bootstrap/BootstrapCommunicator.java
(97%)
rename {nifi-framework-api/src/main/java/org/apache/nifi =>
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-api/src/main/java/org/apache/nifi/minifi}/bootstrap/CommandResult.java
(95%)
copy
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/functions/{NoArgStringFunction.java
=> Divide.java} (52%)
copy
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/functions/{NoArgStringFunction.java
=> Multiply.java} (52%)
copy
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/functions/{FieldName.java
=> ToNumber.java} (57%)
create mode 100644
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathBinaryEvaluator.java
copy
nifi-commons/{nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/model/HL7Component.java
=>
nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathBinaryOperator.java}
(82%)
copy
nifi-commons/{nifi-schema-utils/src/main/java/org/apache/nifi/repository/schema/SingleRecordIterator.java
=>
nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathDivideOperator.java}
(61%)
copy
nifi-frontend/src/main/frontend/apps/nifi/src/app/_app.component-theme.scss =>
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathEvaluator.java
(82%)
copy
nifi-extension-bundles/nifi-websocket-bundle/nifi-websocket-services-api/src/main/java/org/apache/nifi/websocket/AbstractWebSocketSession.java
=>
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathMultiplyOperator.java
(72%)
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/RunStatus.java
=>
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathOperator.java
(88%)
create mode 100644
nifi-commons/nifi-record-path/src/main/java/org/apache/nifi/record/path/math/MathTypeUtils.java
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/credentials/provider/service/MockAWSProcessor.java
delete mode 100644
nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-client-service/src/test/java/org/apache/nifi/elasticsearch/TestControllerServiceProcessor.java
create mode 100644
nifi-extension-bundles/nifi-graph-bundle/nifi-neo4j-cypher-service/src/test/java/org/apache/nifi/graph/TestNeo4JCypherClientService.java
create mode 100644
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaRebalanceIT.java
create mode 100644
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/kafka/processors/common/KafkaUtilsTest.java
create mode 100644
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/test/java/org/apache/nifi/kafka/service/consumer/Kafka3ConsumerServiceTest.java
delete mode 100644
nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/src/test/java/org/apache/nifi/mongodb/TestControllerServiceProcessor.java
delete mode 100644
nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/src/test/java/org/apache/nifi/mongodb/TestLookupServiceProcessor.java
create mode 100644
nifi-extension-bundles/nifi-py4j-extension-bundle/nifi-py4j-bridge/src/test/java/org/apache/nifi/py4j/StandardPythonProcessorBridgeTest.java
copy
nifi-extension-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/SplitXmlTest.java
=>
nifi-snowflake-bundle/nifi-snowflake-processors/src/test/java/org/apache/nifi/processors/snowflake/TestGetSnowflakeIngestStatus.java}
(56%)
copy
nifi-extension-bundles/{nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/storage/TestDeleteAzureDataLakeStorage.java
=>
nifi-snowflake-bundle/nifi-snowflake-processors/src/test/java/org/apache/nifi/processors/snowflake/TestPutSnowflakeInternalStage.java}
(51%)
copy
nifi-extension-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/SplitXmlTest.java
=>
nifi-snowflake-bundle/nifi-snowflake-processors/src/test/java/org/apache/nifi/processors/snowflake/TestStartSnowflakeIngest.java}
(57%)
create mode 100644
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/test/java/org/apache/nifi/snowflake/service/TestStandardSnowflakeIngestManagerProviderService.java
copy
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/{UpdateCounter.java
=> UpdateGauge.java} (60%)
create mode 100644
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/faker/PredefinedRecordSchema.java
create mode 100644
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestUpdateGauge.java
delete mode 100644
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/ExecuteCommand/1mb.txt
delete mode 100755
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/ExecuteCommand/TestDynamicEnvironment.jar
delete mode 100755
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar
delete mode 100755
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/ExecuteCommand/TestLogStdErr.jar
delete mode 100755
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/ExecuteCommand/TestSuccess.jar
delete mode 100755
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/ExecuteCommand/test.txt
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-hadoop-dbcp-service-bundle/nifi-hadoop-dbcp-service/src/test/java/org/apache/nifi/dbcp/TestHadoopDBCPConnectionPool.java
delete mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/test/java/org/apache/nifi/lookup/TestProcessor.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-proxy-configuration-bundle/nifi-proxy-configuration/src/test/java/org/apache/nifi/proxy/TestStandardProxyConfigurationService.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/avro/TestAvroReader.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/avro/TestAvroRecordSetWriter.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/csv/TestCSVReader.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/csv/TestCSVRecordSetWriter.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/json/TestJsonRecordSetWriter.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/json/TestJsonTreeReader.java
delete mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/serialization/TestRecordReaderProcessor.java
delete mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/serialization/TestRecordSetWriterProcessor.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/syslog/TestSyslog5424Reader.java
create mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/syslog/TestSyslogReader.java
delete mode 100644
nifi-extension-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/TestProcessor.java
copy
nifi-commons/nifi-property-utils/src/main/java/org/apache/nifi/properties/ApplicationProperties.java
=>
nifi-framework-api/src/main/java/org/apache/nifi/controller/metrics/ComponentMetricContext.java
(64%)
copy
nifi-commons/nifi-web-client-api/src/main/java/org/apache/nifi/web/client/api/HttpResponseEntity.java
=>
nifi-framework-api/src/main/java/org/apache/nifi/controller/metrics/ComponentMetricReporter.java
(53%)
copy
nifi-framework-api/src/main/java/org/apache/nifi/{action/FlowActionReporterConfigurationContext.java
=> controller/metrics/ComponentMetricReporterConfigurationContext.java} (68%)
copy
nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/jwt/jws/SigningKeyListener.java
=>
nifi-framework-api/src/main/java/org/apache/nifi/controller/metrics/CounterRecord.java
(64%)
copy
nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/jwt/jws/JwsSignerProvider.java
=>
nifi-framework-api/src/main/java/org/apache/nifi/controller/metrics/GaugeRecord.java
(64%)
create mode 100644
nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/store/iterator/EventIteratorTest.java
create mode 100644
nifi-framework-bundle/nifi-framework-extensions/nifi-py4j-framework-bundle/nifi-python-framework/src/test/python/framework/TestProcessorInspection.py
create mode 100644
nifi-framework-bundle/nifi-framework-extensions/nifi-py4j-framework-bundle/nifi-python-framework/src/test/resources/python/framework/imported_property_dependency/ProcessorWithImportedDependency.py
create mode 100644
nifi-framework-bundle/nifi-framework-extensions/nifi-py4j-framework-bundle/nifi-python-framework/src/test/resources/python/framework/imported_property_dependency/SharedProperties.py
copy
nifi-framework-bundle/nifi-framework-extensions/nifi-py4j-framework-bundle/{nifi-python-extension-api/src/main/python/src/nifiapi
=>
nifi-python-framework/src/test/resources/python/framework/imported_property_dependency}/__init__.py
(99%)
copy
nifi-bootstrap/src/main/java/org/apache/nifi/bootstrap/command/UnknownBootstrapCommand.java
=>
nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/metrics/DefaultComponentMetricReporter.java
(71%)
copy
nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/{action/StandardFlowActionReporterConfigurationContext.java
=>
controller/metrics/StandardComponentMetricReporterConfigurationContext.java}
(77%)
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/parameter/ParameterContextNameUtils.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/components/validation/VerifiableComponentFactory.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/validation/StandardVerifiableComponentFactory.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/authorization/AuthorizeComponentReference.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/authorization/AuthorizeComponentReferenceTest.java
create mode 100644
nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/StatelessVerifiableComponentFactory.java
copy
{nifi-connector-mock-bundle/nifi-connector-mock-test-bundle/nifi-connector-mock-test-connectors-nar
=>
nifi-system-tests/nifi-system-test-component-metric-reporter-bundle/nifi-system-test-component-metric-reporter-nar}/pom.xml
(85%)
copy
nifi-system-tests/{nifi-system-test-flow-action-reporter-bundle/nifi-system-test-flow-action-reporter
=>
nifi-system-test-component-metric-reporter-bundle/nifi-system-test-component-metric-reporter}/pom.xml
(90%)
create mode 100644
nifi-system-tests/nifi-system-test-component-metric-reporter-bundle/nifi-system-test-component-metric-reporter/src/main/java/org/apache/nifi/controller/metrics/SystemTestComponentMetricReporter.java
copy minifi/minifi-docker/dockerhub/DockerImage.txt =>
nifi-system-tests/nifi-system-test-component-metric-reporter-bundle/nifi-system-test-component-metric-reporter/src/main/resources/META-INF/services/org.apache.nifi.controller.metrics.ComponentMetricReporter
(91%)
copy nifi-system-tests/{nifi-system-test-authorizer-bundle =>
nifi-system-test-component-metric-reporter-bundle}/pom.xml (85%)
copy
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/components/connector/processors/LogFlowFileContents.java
=>
nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/processors/tests/system/UpdateMetric.java
(71%)
copy
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/{action/FlowActionReporterIT.java
=> metrics/ComponentMetricReporterIT.java} (51%)
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/parameters/ParameterSensitivityWithGhostedComponentIT.java
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/pg/ImportFlowWithIncompatibleBundleIT.java
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/python/PythonNarDeletionDuringInitIT.java
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/registry/ParameterContextPreservationIT.java
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/restart/ProcessorAutoResumeAfterRestartIT.java
