This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a change to branch NIFI-15258
in repository https://gitbox.apache.org/repos/asf/nifi.git
omit b1858b412f NIFI-15579: When synchronizing PG when Versioned flow for
stateless group node, do not synchronize parameter contexts if group is within
a Connector (#10884)
omit 556ec1ea46 NIFI-15581: Add support for ControllerService Mocks for
Connectors. (#10885)
omit 2ee0178e5d NIFI-15577: Including connector id in provenance event dto.
(#10883)
omit 8bc373e3c7 NIFI-15258: Fixes as a result of rebasing against main
omit 2d4937087a NIFI-15559: Enforce data permissions when purging data from
a Connector. (#10867)
omit 78591672ba NIFI-15355 Connector Configuration Repository (#10876)
omit 43936047b1 NIFI-15565: Code cleanup; improvements to .cursorrules to
provide bet… (#10869)
omit 3abd4ab966 NIFI-15539: Updating the actions in FlowFileQueueResource
to support … (#10846)
omit 54ece65710 NIFI-15558: Sensitive Parameter References should resolve
to value. (#10863)
omit 837580cfdc NIFI-15544: If a Connector requires processors or
controller services that are unavailable, make Connector invalid but not
ghosted (#10851)
omit 299c4097ac NIFI-15488: Added significant number of debug log messages
as well as some info/error for connector-related events (#10803)
omit 4013e7ee5f NIFI-15557: Allow Connectors to enable a Controller Service
using overridden property values (#10862)
omit 8a04dca62c NIFI-15549: Adding endpoints for viewing and clearing state
for compo… (#10855)
omit b0fd8105b7 NIFI-15480 Added ability to drop FlowFiles selectively
using a Predicate (#10848)
omit a5b99f27ed NIFI-15538: When starting/stopping components allow
specifying whethe… (#10843)
omit a5cb19dd4c NIFI-15514: Ensure that Parameter Contexts are assigned to
all Proces… (#10815)
omit 8d6a43e9f8 NIFI-15511: Added endpoints for purging all FlowFiles for a
given Con… (#10833)
omit 26bbc9f6c0 NIFI-15536: Change Connector API to use DescribedValue vs
AllowableValue (#10841)
omit 65b3b82dcc NIFI-15509: Enable Component reload additional classpath
resources if needed (#10812)
omit 2ee543934e NIFI-15525: Ensure that we call onStepConfigured when we
restore flow; ensure that we synchronized Parmaeter Providers before Connectors
(#10835)
omit 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)
omit 24ffeda3d0 NIFI-15467: Ensure that Connectors' versions are
automatically resolv… (#10811)
omit 9afd695940 NIFI-15465 Allow client-specified connector component ids
(#10768)
omit f25c1e27b4 NIFI-15495 Restart Connectors that reference assets that
were synchro… (#10806)
omit 818e58e3c6 NIFI-15258: Fixes for system tests that needed to be
updated from 2.7.0-SNAPSHOT to 2.8.0-SNAPSHOT (#10807)
omit c0772f22a6 NIFI-15497: Fixed unit tests (#10805)
omit 31b8052413 NIFI-15485: Include provider name when providing fqn for
secrets (#10801)
omit 0a166d2938 NIFI-15490: If any processors or controller services are
missing, make Connector invalid (#10799)
omit 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)
omit c361a200cd NIFI-15461: Added ability to initiate drainage of
Connector's FlowFiles and calce; added tests to verify; some bug fixes (#10767)
omit 793d4adfef NIFI-15258: Addressed checkstyle violations
omit f7a7963f3c NIFI-15258: Fixes necessary after rebasing against main
omit 649ae3e3f8 NIFI-15481: Updated ConnectorActions to reflect that
starting is not … (#10782)
omit 830b5dc3f8 NIFI-15451: Added ability for Connectors to retrieve
bundles availabl… (#10756)
omit 76643f4e3e NIFI-15482: MockConnectorAssetManager requires SPI file to
start (#10783)
omit e3add13298 NIFI-15472: Added addAsset methods to ConnectorTestRunner
(#10776)
omit bb47590ad5 NIFI-15453: Adding an endpoint to return all controller
services for … (#10770)
omit 97e59eced9 NIFI-15376: Adding dependencies to the configuration step
dto. (#10674)
omit b028ba24f3 NIFI-15446: When invoking ConnectorMethod, make sure to
serialize/des… (#10750)
omit 8c1a99c18e NIFI-15468: Ensure that we properly initialize
ConnectorNode even if a Ghost Connector is created (#10775)
omit 80f3971708 NIFI-15439: Ensure that Process Groups are accessible from
the approp… (#10742)
omit c7c0c859ca NIFI-15440: Implementation of ConnectorActions (#10748)
omit c7e34a15c0 NIFI-15445: Removed 'disabled' state from Connectors; also
fixed bug … (#10749)
omit fe7e606d44 NIFI-15434: Ensure that we start or stop connectors on flow
sync (#10737)
omit ccfaf0ffa8 NIFI-15433: If connector validation throws an Exception
keep trying u… (#10736)
omit 3539adaa53 NIFI-15427: Added abiliy to drop flowfiles / drain
flowfiles from a C… (#10730)
omit 002d672ef7 NIFI-15430: Ensure that if we fail to initialize a
Connector, we crea… (#10733)
omit 60369f9ccf NIFI-15429: Adding an optional query parameter for
specifying which p… (#10732)
omit 2d20310a2e NIFI-15353: Adding support for rendering Connector
Documentation. (#10683)
omit d5697340d7 NIFI-15356: Adding authorization to the
StandardNiFiConnectorWebContext. (#10660)
omit 96f1bdba44 NIFI-15370: Add Connector ID to process groups and do not
register create process groups if they have a connector ID. (#10673)
omit b256cf7f00 NIFI-15367: Ensure that Connectors' implicit parameter
contexts are n… (#10665)
omit e7032a6382 NIFI-15369: Allow ConfigurationStep to depend on another
(ConfigurationStep,Property) tuple (#10669)
omit 752fcdede2 NIFI-15361: Allowing configuration step documentation to be
returned … (#10667)
omit 339860f275 NIFI-15315 Add support for assets in connectors (#10647)
omit 8b18062810 NIFI-15343: Adding an endpoint to return available secrets
to the con… (#10645)
omit 4f8b6047d7 NIFI-15352: Added ConnectorClient to toolkit-cli so that it
can be us… (#10654)
omit 41be9f5a85 NIFI-15258: Enable Custom UI to retrieve connector with
flow contexts (#10652)
omit aab779c087 NIFI-15336: Created AuthorizableSecret and implemented
ParameterProviderSecretProvider to provide the Parameter Provider as the
associated Authorizable (#10644)
omit 0d306a5d77 NIFI-15312: Implementation of Parameter Provider based
Secrets Manager; updated mock framework to support secrets; validation cleanup
(#10638)
omit 6a3609caa7 NIFI-15330: Allow GhostConnector to be updated (#10632)
omit e1c2420417 NIFI-15326: Adding support of configuration step
documentation. (#10631)
omit 99f16ea932 NIFI-15322: Require all property descriptors within a
PropertyGroup / ConfigurationStep are unique (#10626)
omit f7f6b1e894 NIFI-15323: Adding operate permissions to the
ConnectorEntity. (#10625)
omit 4271a51ce6 NIFI-15259: Added REST API for Connectors
omit 72285026a1 NIFI-15258: Addressed PMD findings
omit 03da272f5e NIFI-15258: Fixed checkstyle violations/pmd
omit 08dbfabd44 NIFI-15258: Fixed vulnerable lz4 dependency
omit 5cd976881d NIFI-15258: Initial implementation of Connectors
add 8cfef99ff5 NIFI-15595 Fixed Prometheus Metrics for Framework Build
properties
add 5d82a84a72 NIFI-15585 Bump Spring to 7.0.4, Logback to 1.5.29, Box SDK
to 5.4.0, and others (#10889)
add 08058d3abd NIFI-15591 Add kafka.timestamp attribute in ConsumeKafka
for flow files emitted using ProcessingStrategy.RECORD
add a1c2855c0a NIFI-15584 Fixed NPE in DBCPConnectionPool for Dynamic
Properties with Null Value (#10888)
add 6e46f7e2ac NIFI-15575 Switched to Javadoc snippet tag for code
examples in comments (#10879)
add 3f8487d9ee NIFI-15573 Restored tooltips to buttons on Navigation and
Operation Panels (#10878)
add a4f7ef9799 NIFI-15589 Added UUID Type compatibility check to
DataTypeUtils (#10892)
add 67407bdb75 NIFI-15571 Updated version to 2.8.0
add 8493c4e883 NIFI-15571 Merged NIFI-15571-RC2
add 2827f0de26 NIFI-15571 Updated version to 2.9.0-SNAPSHOT
add edca3d4a6d NIFI-15600 Fixed Flow version change when flow contains
Ghost Parameter Provider (#10899)
add 65ed41e6ee NIFI-15583 Fixed S3 Processors use global instead of
regional endpoint for us-east-1 (#10887)
add 89c2f20e31 NIFI-15603 Fixed code-compliance scan workflow for PMD
(#10900)
new 7ac3e0f1e0 NIFI-15258: Initial implementation of Connectors
new 54edb9cf22 NIFI-15258: Fixed vulnerable lz4 dependency
new f586e6d331 NIFI-15258: Fixed checkstyle violations/pmd
new 57cb88c444 NIFI-15258: Addressed PMD findings
new abd60dc87e NIFI-15259: Added REST API for Connectors
new 5cb0d175c8 NIFI-15323: Adding operate permissions to the
ConnectorEntity. (#10625)
new 482c210f00 NIFI-15322: Require all property descriptors within a
PropertyGroup / ConfigurationStep are unique (#10626)
new 2d2cd52bf4 NIFI-15326: Adding support of configuration step
documentation. (#10631)
new 3d53d0a828 NIFI-15330: Allow GhostConnector to be updated (#10632)
new fb368d43e2 NIFI-15312: Implementation of Parameter Provider based
Secrets Manager; updated mock framework to support secrets; validation cleanup
(#10638)
new 2ea4cbbb91 NIFI-15336: Created AuthorizableSecret and implemented
ParameterProviderSecretProvider to provide the Parameter Provider as the
associated Authorizable (#10644)
new 4eef936c99 NIFI-15258: Enable Custom UI to retrieve connector with
flow contexts (#10652)
new ad80a0d3e7 NIFI-15352: Added ConnectorClient to toolkit-cli so that it
can be us… (#10654)
new fa15dd651d NIFI-15343: Adding an endpoint to return available secrets
to the con… (#10645)
new 2e55f8fc2a NIFI-15315 Add support for assets in connectors (#10647)
new 81fa7e5480 NIFI-15361: Allowing configuration step documentation to be
returned … (#10667)
new 2aa3f37eea NIFI-15369: Allow ConfigurationStep to depend on another
(ConfigurationStep,Property) tuple (#10669)
new 2d3b5dab4c NIFI-15367: Ensure that Connectors' implicit parameter
contexts are n… (#10665)
new c0f9775611 NIFI-15370: Add Connector ID to process groups and do not
register create process groups if they have a connector ID. (#10673)
new 1f71e98fe1 NIFI-15356: Adding authorization to the
StandardNiFiConnectorWebContext. (#10660)
new cca6a744ae NIFI-15353: Adding support for rendering Connector
Documentation. (#10683)
new a08106927f NIFI-15429: Adding an optional query parameter for
specifying which p… (#10732)
new 847296efea NIFI-15430: Ensure that if we fail to initialize a
Connector, we crea… (#10733)
new 0ee6cad6c9 NIFI-15427: Added abiliy to drop flowfiles / drain
flowfiles from a C… (#10730)
new 7f82dd354a NIFI-15433: If connector validation throws an Exception
keep trying u… (#10736)
new a132a3bf0c NIFI-15434: Ensure that we start or stop connectors on flow
sync (#10737)
new b947724874 NIFI-15445: Removed 'disabled' state from Connectors; also
fixed bug … (#10749)
new 04c506db94 NIFI-15440: Implementation of ConnectorActions (#10748)
new 02fc2e82a2 NIFI-15439: Ensure that Process Groups are accessible from
the approp… (#10742)
new 2268a0afe3 NIFI-15468: Ensure that we properly initialize
ConnectorNode even if a Ghost Connector is created (#10775)
new e0bdd7063f NIFI-15446: When invoking ConnectorMethod, make sure to
serialize/des… (#10750)
new eba8ff3b90 NIFI-15376: Adding dependencies to the configuration step
dto. (#10674)
new 3a899e9e1b NIFI-15453: Adding an endpoint to return all controller
services for … (#10770)
new 27f79c4ad5 NIFI-15472: Added addAsset methods to ConnectorTestRunner
(#10776)
new 2359a008ab NIFI-15482: MockConnectorAssetManager requires SPI file to
start (#10783)
new 6d8b66650a NIFI-15451: Added ability for Connectors to retrieve
bundles availabl… (#10756)
new bea7abbf3d NIFI-15481: Updated ConnectorActions to reflect that
starting is not … (#10782)
new ed599240eb NIFI-15258: Fixes necessary after rebasing against main
new 239876b6d6 NIFI-15258: Addressed checkstyle violations
new cb63f62e28 NIFI-15461: Added ability to initiate drainage of
Connector's FlowFiles and calce; added tests to verify; some bug fixes (#10767)
new 7dc60d8a4d 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 bf9bb43d44 NIFI-15490: If any processors or controller services are
missing, make Connector invalid (#10799)
new 8e90a96f19 NIFI-15485: Include provider name when providing fqn for
secrets (#10801)
new 4666dd34a4 NIFI-15497: Fixed unit tests (#10805)
new 6eac4c8e5e NIFI-15258: Fixes for system tests that needed to be
updated from 2.7.0-SNAPSHOT to 2.8.0-SNAPSHOT (#10807)
new ab9d42dc07 NIFI-15495 Restart Connectors that reference assets that
were synchro… (#10806)
new 897ac06124 NIFI-15465 Allow client-specified connector component ids
(#10768)
new 5c41b7999c NIFI-15467: Ensure that Connectors' versions are
automatically resolv… (#10811)
new 14c0b74424 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 b3c332ebb9 NIFI-15525: Ensure that we call onStepConfigured when we
restore flow; ensure that we synchronized Parmaeter Providers before Connectors
(#10835)
new 6b780b5c9d NIFI-15509: Enable Component reload additional classpath
resources if needed (#10812)
new 16db577fa0 NIFI-15536: Change Connector API to use DescribedValue vs
AllowableValue (#10841)
new 7b24be6979 NIFI-15511: Added endpoints for purging all FlowFiles for a
given Con… (#10833)
new 678702c49a NIFI-15514: Ensure that Parameter Contexts are assigned to
all Proces… (#10815)
new 768dbb3d20 NIFI-15538: When starting/stopping components allow
specifying whethe… (#10843)
new 747e043410 NIFI-15480 Added ability to drop FlowFiles selectively
using a Predicate (#10848)
new 3f138178c0 NIFI-15549: Adding endpoints for viewing and clearing state
for compo… (#10855)
new 2c0594e983 NIFI-15557: Allow Connectors to enable a Controller Service
using overridden property values (#10862)
new 002d27b34e NIFI-15488: Added significant number of debug log messages
as well as some info/error for connector-related events (#10803)
new bbb21b890e NIFI-15544: If a Connector requires processors or
controller services that are unavailable, make Connector invalid but not
ghosted (#10851)
new e4fb9fefb4 NIFI-15558: Sensitive Parameter References should resolve
to value. (#10863)
new 1b6e3d3773 NIFI-15539: Updating the actions in FlowFileQueueResource
to support … (#10846)
new 1ccb40719c NIFI-15565: Code cleanup; improvements to .cursorrules to
provide bet… (#10869)
new 1ae00bbadb NIFI-15355 Connector Configuration Repository (#10876)
new 5fe92e8bf1 NIFI-15559: Enforce data permissions when purging data from
a Connector. (#10867)
new 78ce1dd8e3 NIFI-15258: Fixes as a result of rebasing against main
new f184228362 NIFI-15577: Including connector id in provenance event dto.
(#10883)
new c744abde33 NIFI-15581: Add support for ControllerService Mocks for
Connectors. (#10885)
new 60ca5b563b NIFI-15579: When synchronizing PG when Versioned flow for
stateless group node, do not synchronize parameter contexts if group is within
a Connector (#10884)
new f61609dfe6 NIFI-15605 - Rebase Connectors branch with main for
2.9.0-SNAPSHOT
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 (b1858b412f)
\
N -- N -- N refs/heads/NIFI-15258 (f61609dfe6)
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 70 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:
.github/workflows/code-compliance.yml | 2 +-
c2/c2-client-bundle/c2-client-api/pom.xml | 4 +-
c2/c2-client-bundle/c2-client-base/pom.xml | 4 +-
c2/c2-client-bundle/c2-client-http/pom.xml | 10 +-
c2/c2-client-bundle/c2-client-service/pom.xml | 10 +-
c2/c2-client-bundle/pom.xml | 2 +-
c2/c2-protocol/c2-protocol-api/pom.xml | 4 +-
c2/c2-protocol/c2-protocol-component-api/pom.xml | 2 +-
c2/c2-protocol/pom.xml | 2 +-
c2/pom.xml | 2 +-
minifi/minifi-assembly/pom.xml | 52 +-
minifi/minifi-bom/pom.xml | 8 +-
minifi/minifi-bootstrap/pom.xml | 20 +-
minifi/minifi-commons/minifi-commons-api/pom.xml | 4 +-
.../minifi-commons-framework/pom.xml | 14 +-
minifi/minifi-commons/minifi-commons-utils/pom.xml | 2 +-
.../minifi-flow-status-report/pom.xml | 2 +-
minifi/minifi-commons/pom.xml | 2 +-
minifi/minifi-docker/pom.xml | 2 +-
minifi/minifi-docs/pom.xml | 2 +-
minifi/minifi-integration-tests/pom.xml | 6 +-
.../minifi-framework-nar/pom.xml | 6 +-
.../minifi-framework/minifi-framework-api/pom.xml | 6 +-
.../minifi-framework/minifi-framework-core/pom.xml | 38 +-
.../minifi-framework/minifi-nar-unloader/pom.xml | 14 +-
.../minifi-properties-loader/pom.xml | 10 +-
.../minifi-framework/minifi-resources/pom.xml | 2 +-
.../minifi-framework/minifi-runtime/pom.xml | 18 +-
.../minifi-framework/minifi-server/pom.xml | 18 +-
.../minifi-framework/pom.xml | 2 +-
.../minifi-server-nar/pom.xml | 8 +-
.../minifi-framework-bundle/pom.xml | 16 +-
.../minifi-provenance-repositories/pom.xml | 6 +-
.../minifi-provenance-repository-nar/pom.xml | 6 +-
.../minifi-provenance-repository-bundle/pom.xml | 2 +-
.../minifi-nar-bundles/minifi-standard-nar/pom.xml | 12 +-
.../minifi-update-attribute-nar/pom.xml | 8 +-
minifi/minifi-nar-bundles/pom.xml | 2 +-
.../minifi-toolkit/minifi-toolkit-assembly/pom.xml | 4 +-
.../minifi-toolkit-configuration/pom.xml | 10 +-
.../minifi-toolkit/minifi-toolkit-schema/pom.xml | 4 +-
minifi/minifi-toolkit/pom.xml | 2 +-
minifi/pom.xml | 2 +-
nifi-assembly/pom.xml | 298 +++++------
nifi-bom/pom.xml | 20 +-
nifi-bootstrap/pom.xml | 4 +-
nifi-code-coverage/pom.xml | 572 ++++++++++-----------
nifi-commons/nifi-build/pom.xml | 2 +-
nifi-commons/nifi-calcite-utils/pom.xml | 2 +-
.../java/org/apache/nifi/sql/CalciteDatabase.java | 8 +-
nifi-commons/nifi-connector-utils/pom.xml | 2 +-
nifi-commons/nifi-content-viewer-utils/pom.xml | 2 +-
nifi-commons/nifi-custom-ui-utils/pom.xml | 2 +-
nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +-
nifi-commons/nifi-deprecation-log/pom.xml | 2 +-
nifi-commons/nifi-expression-language/pom.xml | 8 +-
nifi-commons/nifi-flow-encryptor/pom.xml | 4 +-
nifi-commons/nifi-flowfile-packager/pom.xml | 2 +-
nifi-commons/nifi-hashicorp-vault-api/pom.xml | 2 +-
nifi-commons/nifi-hashicorp-vault/pom.xml | 8 +-
nifi-commons/nifi-hl7-query-language/pom.xml | 2 +-
nifi-commons/nifi-jetty-configuration/pom.xml | 2 +-
nifi-commons/nifi-json-schema-api/pom.xml | 2 +-
nifi-commons/nifi-json-schema-shared/pom.xml | 4 +-
nifi-commons/nifi-json-utils/pom.xml | 2 +-
nifi-commons/nifi-kubernetes-client/pom.xml | 2 +-
nifi-commons/nifi-metrics/pom.xml | 2 +-
nifi-commons/nifi-parameter/pom.xml | 2 +-
.../nifi-per-process-group-logging/pom.xml | 2 +-
nifi-commons/nifi-properties/pom.xml | 4 +-
nifi-commons/nifi-property-encryptor/pom.xml | 4 +-
nifi-commons/nifi-property-utils/pom.xml | 2 +-
nifi-commons/nifi-record-path/pom.xml | 8 +-
nifi-commons/nifi-record/pom.xml | 2 +-
.../nifi/serialization/record/RecordFieldType.java | 88 ++--
.../serialization/record/util/DataTypeUtils.java | 38 +-
.../serialization/record/TestDataTypeUtils.java | 22 +
nifi-commons/nifi-schema-utils/pom.xml | 2 +-
nifi-commons/nifi-security-cert-builder/pom.xml | 2 +-
nifi-commons/nifi-security-cert/pom.xml | 2 +-
nifi-commons/nifi-security-crypto-key/pom.xml | 2 +-
nifi-commons/nifi-security-identity/pom.xml | 2 +-
nifi-commons/nifi-security-kerberos-api/pom.xml | 2 +-
nifi-commons/nifi-security-kerberos/pom.xml | 4 +-
nifi-commons/nifi-security-proxied-entity/pom.xml | 2 +-
nifi-commons/nifi-security-ssl/pom.xml | 2 +-
nifi-commons/nifi-security-utils-api/pom.xml | 2 +-
nifi-commons/nifi-single-user-utils/pom.xml | 4 +-
nifi-commons/nifi-site-to-site-client/pom.xml | 12 +-
nifi-commons/nifi-swagger-integration/pom.xml | 2 +-
nifi-commons/nifi-utils/pom.xml | 2 +-
.../java/org/apache/nifi/util/FormatUtils.java | 14 +-
.../apache/nifi/util/NaiveSearchRingBuffer.java | 23 +-
.../org/apache/nifi/util/text/DateTimeMatcher.java | 18 +-
nifi-commons/nifi-uuid5/pom.xml | 2 +-
nifi-commons/nifi-web-client-api/pom.xml | 2 +-
nifi-commons/nifi-web-client/pom.xml | 4 +-
nifi-commons/nifi-web-servlet-shared/pom.xml | 2 +-
nifi-commons/nifi-write-ahead-log/pom.xml | 4 +-
nifi-commons/nifi-xml-processing/pom.xml | 2 +-
nifi-commons/pom.xml | 6 +-
.../nifi-connector-mock-api/pom.xml | 4 +-
.../nifi-connector-mock-server-nar/pom.xml | 6 +-
.../nifi-connector-mock-server/pom.xml | 12 +-
.../server/StandardConnectorMockServer.java | 2 +-
.../nifi-connector-mock-integration-tests/pom.xml | 22 +-
.../mock/connectors/tests/CreateConnectorIT.java | 2 +-
.../pom.xml | 4 +-
.../nifi-connector-mock-test-connectors/pom.xml | 4 +-
.../nifi-connector-mock-test-bundle/pom.xml | 2 +-
.../nifi-connector-mock/pom.xml | 24 +-
.../connector/StandardConnectorTestRunner.java | 2 +-
nifi-connector-mock-bundle/pom.xml | 2 +-
.../nifi-kafka-to-s3-connector/pom.xml | 2 +-
.../src/main/resources/flows/Kafka_to_S3.json | 44 +-
.../nifi-kafka-to-s3-integration-tests/pom.xml | 36 +-
.../nifi-kafka-to-s3-nar/pom.xml | 4 +-
nifi-connectors/nifi-kafka-to-s3-bundle/pom.xml | 2 +-
nifi-connectors/pom.xml | 4 +-
nifi-docker/dockerhub/pom.xml | 2 +-
nifi-docker/dockermaven/pom.xml | 2 +-
nifi-docker/pom.xml | 2 +-
nifi-docs/pom.xml | 2 +-
nifi-extension-bom/pom.xml | 4 +-
.../nifi-airtable-bundle/nifi-airtable-nar/pom.xml | 6 +-
.../nifi-airtable-processors/pom.xml | 4 +-
.../nifi-airtable-bundle/pom.xml | 2 +-
.../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 6 +-
.../nifi-amqp-bundle/nifi-amqp-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-amqp-bundle/pom.xml | 2 +-
.../nifi-apicurio-bundle/nifi-apicurio-nar/pom.xml | 6 +-
.../nifi-apicurio-schema-registry-service/pom.xml | 6 +-
.../nifi-apicurio-bundle/pom.xml | 2 +-
.../nifi-asn1-bundle/nifi-asn1-nar/pom.xml | 6 +-
.../nifi-asn1-bundle/nifi-asn1-services/pom.xml | 2 +-
nifi-extension-bundles/nifi-asn1-bundle/pom.xml | 2 +-
.../nifi-atlassian-extensions/pom.xml | 4 +-
.../nifi-atlassian-nar/pom.xml | 6 +-
.../nifi-atlassian-bundle/pom.xml | 2 +-
.../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +-
.../nifi-avro-bundle/nifi-avro-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-avro-bundle/pom.xml | 2 +-
.../nifi-aws-abstract-processors/pom.xml | 4 +-
.../processors/aws/s3/AbstractS3Processor.java | 30 +-
.../processors/aws/s3/AbstractS3ProcessorTest.java | 120 +++++
.../nifi-aws-bundle/nifi-aws-kinesis-nar/pom.xml | 2 +-
.../nifi-aws-bundle/nifi-aws-kinesis/pom.xml | 4 +-
.../nifi-aws-bundle/nifi-aws-nar/pom.xml | 12 +-
.../nifi-aws-parameter-providers/pom.xml | 2 +-
.../aws/AwsSecretsManagerParameterProvider.java | 6 +-
.../nifi-aws-parameter-value-providers/pom.xml | 6 +-
.../AwsSecretsManagerParameterValueProvider.java | 11 +-
.../nifi-aws-bundle/nifi-aws-processors/pom.xml | 20 +-
.../strategies/FileCredentialsStrategy.java | 8 +-
.../nifi-aws-bundle/nifi-aws-regions/pom.xml | 2 +-
.../nifi-aws-schema-registry-service/pom.xml | 6 +-
.../nifi-aws-service-api-nar/pom.xml | 4 +-
.../nifi-aws-bundle/nifi-aws-service-api/pom.xml | 2 +-
nifi-extension-bundles/nifi-aws-bundle/pom.xml | 4 +-
.../nifi-azure-bundle/nifi-azure-nar/pom.xml | 12 +-
.../nifi-azure-parameter-providers/pom.xml | 4 +-
.../AzureKeyVaultSecretsParameterProvider.java | 7 +-
.../nifi-azure-processors/pom.xml | 24 +-
.../nifi-azure-registry-clients/pom.xml | 4 +-
.../nifi-azure-reporting-task/pom.xml | 6 +-
.../nifi-azure-services-api-nar/pom.xml | 6 +-
.../nifi-azure-services-api/pom.xml | 2 +-
nifi-extension-bundles/nifi-azure-bundle/pom.xml | 4 +-
.../nifi-box-bundle/nifi-box-nar/pom.xml | 6 +-
.../nifi-box-bundle/nifi-box-processors/pom.xml | 10 +-
.../nifi-box-services-api-nar/pom.xml | 6 +-
.../nifi-box-bundle/nifi-box-services-api/pom.xml | 2 +-
.../nifi-box-bundle/nifi-box-services-nar/pom.xml | 6 +-
.../nifi-box-bundle/nifi-box-services/pom.xml | 8 +-
nifi-extension-bundles/nifi-box-bundle/pom.xml | 4 +-
.../nifi-cdc/nifi-cdc-api/pom.xml | 2 +-
.../nifi-cdc-mysql-nar/pom.xml | 4 +-
.../nifi-cdc-mysql-processors/pom.xml | 6 +-
.../nifi-cdc/nifi-cdc-mysql-bundle/pom.xml | 4 +-
nifi-extension-bundles/nifi-cdc/pom.xml | 2 +-
.../nifi-cipher-bundle/nifi-cipher-nar/pom.xml | 6 +-
.../nifi-cipher-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-cipher-bundle/pom.xml | 2 +-
.../nifi-compress-bundle/nifi-compress-nar/pom.xml | 4 +-
.../nifi-compress-processors/pom.xml | 4 +-
.../nifi-compress-bundle/pom.xml | 2 +-
.../nifi-confluent-platform-nar/pom.xml | 2 +-
.../nifi-confluent-platform-schema-api/pom.xml | 2 +-
.../nifi-confluent-protobuf-antlr-parser/pom.xml | 2 +-
.../pom.xml | 2 +-
.../nifi-confluent-schema-registry-service/pom.xml | 4 +-
.../nifi-confluent-platform-bundle/pom.xml | 2 +-
.../nifi-couchbase-nar/pom.xml | 6 +-
.../nifi-couchbase-processors/pom.xml | 6 +-
.../nifi-couchbase-services-api-nar/pom.xml | 6 +-
.../nifi-couchbase-services-api/pom.xml | 2 +-
.../nifi-couchbase-standard-services-nar/pom.xml | 6 +-
.../nifi-couchbase-standard-services/pom.xml | 6 +-
.../nifi-couchbase-bundle/pom.xml | 2 +-
.../nifi-dropbox-processors-nar/pom.xml | 6 +-
.../nifi-dropbox-processors/pom.xml | 14 +-
.../nifi-dropbox-services-api-nar/pom.xml | 6 +-
.../nifi-dropbox-services-api/pom.xml | 2 +-
.../nifi-dropbox-services-nar/pom.xml | 6 +-
.../nifi-dropbox-services/pom.xml | 4 +-
nifi-extension-bundles/nifi-dropbox-bundle/pom.xml | 2 +-
.../pom.xml | 6 +-
.../nifi-elasticsearch-client-service-api/pom.xml | 2 +-
.../nifi-elasticsearch-client-service-nar/pom.xml | 6 +-
.../nifi-elasticsearch-client-service/pom.xml | 12 +-
.../nifi-elasticsearch-restapi-nar/pom.xml | 4 +-
.../nifi-elasticsearch-restapi-processors/pom.xml | 20 +-
.../nifi-elasticsearch-test-utils/pom.xml | 2 +-
.../nifi-elasticsearch-bundle/pom.xml | 4 +-
.../nifi-email-bundle/nifi-email-nar/pom.xml | 6 +-
.../nifi-email-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-email-bundle/pom.xml | 2 +-
.../nifi-enrich-bundle/nifi-enrich-nar/pom.xml | 6 +-
.../nifi-enrich-processors/pom.xml | 8 +-
nifi-extension-bundles/nifi-enrich-bundle/pom.xml | 2 +-
.../nifi-evtx-bundle/nifi-evtx-nar/pom.xml | 4 +-
.../nifi-evtx-bundle/nifi-evtx-processors/pom.xml | 4 +-
nifi-extension-bundles/nifi-evtx-bundle/pom.xml | 2 +-
.../nifi-extension-utils/nifi-bin-manager/pom.xml | 4 +-
.../nifi-conflict-resolution/pom.xml | 2 +-
.../nifi-database-test-utils/pom.xml | 2 +-
.../nifi-database-utils/pom.xml | 10 +-
.../nifi-extension-utils/nifi-dbcp-base/pom.xml | 14 +-
.../nifi-extension-utils/nifi-dbcp-utils/pom.xml | 2 +-
.../nifi-embedded-database-service/pom.xml | 4 +-
.../nifi-extension-utils/nifi-event-listen/pom.xml | 6 +-
.../nifi-extension-utils/nifi-event-put/pom.xml | 6 +-
.../nifi-event-transport/pom.xml | 8 +-
.../nifi-file-transfer/pom.xml | 8 +-
.../nifi-git-flow-registry/pom.xml | 4 +-
.../nifi-extension-utils/nifi-hadoop-utils/pom.xml | 8 +-
.../nifi-listed-entity/pom.xml | 10 +-
.../nifi-migration-utils/pom.xml | 2 +-
.../nifi-extension-utils/nifi-put-pattern/pom.xml | 2 +-
.../nifi-record-path-property/pom.xml | 6 +-
.../nifi-avro-record-utils/pom.xml | 10 +-
.../nifi-hadoop-record-utils/pom.xml | 10 +-
.../nifi-json-record-utils/pom.xml | 8 +-
.../nifi-mock-record-utils/pom.xml | 12 +-
.../nifi-schema-inference-utils/pom.xml | 6 +-
.../nifi-standard-record-utils/pom.xml | 10 +-
.../nifi-yaml-record-utils/pom.xml | 6 +-
.../nifi-extension-utils/nifi-record-utils/pom.xml | 2 +-
.../nifi-reporting-utils/pom.xml | 4 +-
.../nifi-resource-transfer/pom.xml | 4 +-
.../nifi-service-utils/pom.xml | 2 +-
.../nifi-extension-utils/nifi-syslog-utils/pom.xml | 2 +-
.../nifi-extension-utils/pom.xml | 2 +-
.../nifi-flow-registry-client-nar/pom.xml | 6 +-
.../nifi-flow-registry-client-services/pom.xml | 8 +-
.../nifi-flow-registry-client-bundle/pom.xml | 2 +-
.../nifi-gcp-bundle/nifi-gcp-nar/pom.xml | 8 +-
.../nifi-gcp-parameter-providers/pom.xml | 6 +-
.../nifi-gcp-bundle/nifi-gcp-processors/pom.xml | 16 +-
.../nifi-gcp-services-api-nar/pom.xml | 6 +-
.../nifi-gcp-bundle/nifi-gcp-services-api/pom.xml | 2 +-
nifi-extension-bundles/nifi-gcp-bundle/pom.xml | 2 +-
.../nifi-geohash-bundle/nifi-geohash-nar/pom.xml | 6 +-
.../nifi-geohash-processors/pom.xml | 6 +-
nifi-extension-bundles/nifi-geohash-bundle/pom.xml | 2 +-
.../nifi-github-extensions/pom.xml | 4 +-
.../nifi-github-bundle/nifi-github-nar/pom.xml | 6 +-
nifi-extension-bundles/nifi-github-bundle/pom.xml | 2 +-
.../nifi-gitlab-extensions/pom.xml | 4 +-
.../nifi-gitlab-bundle/nifi-gitlab-nar/pom.xml | 6 +-
nifi-extension-bundles/nifi-gitlab-bundle/pom.xml | 2 +-
.../nifi-graph-client-service-api-nar/pom.xml | 6 +-
.../nifi-graph-client-service-api/pom.xml | 2 +-
.../nifi-graph-bundle/nifi-graph-nar/pom.xml | 6 +-
.../nifi-graph-processors/pom.xml | 12 +-
.../nifi-graph-test-clients/pom.xml | 4 +-
.../nifi-neo4j-cypher-service-nar/pom.xml | 6 +-
.../nifi-neo4j-cypher-service/pom.xml | 10 +-
.../nifi-other-graph-services-nar/pom.xml | 6 +-
.../nifi-other-graph-services/pom.xml | 8 +-
nifi-extension-bundles/nifi-graph-bundle/pom.xml | 2 +-
.../nifi-groovyx-bundle/nifi-groovyx-nar/pom.xml | 6 +-
.../nifi-groovyx-processors/pom.xml | 4 +-
.../groovyx/flow/ProcessSessionWrap.java | 22 +-
nifi-extension-bundles/nifi-groovyx-bundle/pom.xml | 2 +-
.../nifi-hadoop-bundle/nifi-hadoop-nar/pom.xml | 6 +-
.../nifi-hdfs-processors/pom.xml | 12 +-
nifi-extension-bundles/nifi-hadoop-bundle/pom.xml | 2 +-
.../nifi-hadoop-libraries-nar/pom.xml | 4 +-
.../nifi-hadoop-libraries-bundle/pom.xml | 2 +-
.../pom.xml | 6 +-
.../pom.xml | 4 +-
.../nifi-hashicorp-vault-client-service/pom.xml | 8 +-
.../nifi-hashicorp-vault-nar/pom.xml | 12 +-
.../pom.xml | 6 +-
.../pom.xml | 8 +-
.../HashiCorpVaultParameterValueProvider.java | 11 +-
.../nifi-hashicorp-vault-bundle/pom.xml | 2 +-
.../nifi-hazelcast-services-api-nar/pom.xml | 6 +-
.../nifi-hazelcast-services-api/pom.xml | 2 +-
.../nifi-hazelcast-services-nar/pom.xml | 6 +-
.../nifi-hazelcast-services/pom.xml | 4 +-
.../nifi-hazelcast-bundle/pom.xml | 2 +-
.../nifi-hl7-bundle/nifi-hl7-nar/pom.xml | 4 +-
.../nifi-hl7-bundle/nifi-hl7-processors/pom.xml | 6 +-
nifi-extension-bundles/nifi-hl7-bundle/pom.xml | 2 +-
.../nifi-hubspot-bundle/nifi-hubspot-nar/pom.xml | 6 +-
.../nifi-hubspot-processors/pom.xml | 4 +-
nifi-extension-bundles/nifi-hubspot-bundle/pom.xml | 2 +-
.../nifi-iceberg-aws-nar/pom.xml | 2 +-
.../nifi-iceberg-bundle/nifi-iceberg-aws/pom.xml | 2 +-
.../nifi-iceberg-azure-nar/pom.xml | 2 +-
.../nifi-iceberg-bundle/nifi-iceberg-azure/pom.xml | 2 +-
.../nifi-iceberg-parquet-writer-nar/pom.xml | 2 +-
.../nifi-iceberg-parquet-writer/pom.xml | 2 +-
.../nifi-iceberg-processors-nar/pom.xml | 2 +-
.../nifi-iceberg-processors/pom.xml | 2 +-
.../nifi-iceberg-rest-catalog-nar/pom.xml | 2 +-
.../nifi-iceberg-rest-catalog/pom.xml | 2 +-
.../nifi-iceberg-service-api-nar/pom.xml | 2 +-
.../nifi-iceberg-service-api/pom.xml | 2 +-
.../nifi-iceberg-shared-nar/pom.xml | 4 +-
nifi-extension-bundles/nifi-iceberg-bundle/pom.xml | 4 +-
.../nifi-iotdb-bundle/nifi-iotdb-nar/pom.xml | 6 +-
.../nifi-iotdb-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-iotdb-bundle/pom.xml | 2 +-
.../nifi-jms-cf-service-nar/pom.xml | 6 +-
.../nifi-jms-bundle/nifi-jms-cf-service/pom.xml | 2 +-
.../nifi-jms-processors-nar/pom.xml | 6 +-
.../nifi-jms-bundle/nifi-jms-processors/pom.xml | 6 +-
nifi-extension-bundles/nifi-jms-bundle/pom.xml | 2 +-
.../nifi-jolt-bundle/nifi-jolt-nar/pom.xml | 6 +-
.../nifi-jolt-bundle/nifi-jolt-processors/pom.xml | 8 +-
.../nifi-jolt-transform-json-ui/pom.xml | 12 +-
.../nifi-jolt-bundle/nifi-jolt-utils/pom.xml | 2 +-
nifi-extension-bundles/nifi-jolt-bundle/pom.xml | 4 +-
.../nifi-jslt-bundle/nifi-jslt-nar/pom.xml | 6 +-
.../nifi-jslt-bundle/nifi-jslt-processors/pom.xml | 2 +-
nifi-extension-bundles/nifi-jslt-bundle/pom.xml | 2 +-
.../nifi-kafka-3-integration/pom.xml | 12 +-
.../kafka/processors/ConsumeKafkaRecordIT.java | 1 +
.../nifi-kafka-3-service-nar/pom.xml | 6 +-
.../nifi-kafka-bundle/nifi-kafka-3-service/pom.xml | 4 +-
.../nifi-kafka-code-coverage/pom.xml | 12 +-
.../nifi-kafka-bundle/nifi-kafka-nar/pom.xml | 6 +-
.../nifi-kafka-processors/pom.xml | 8 +-
.../apache/nifi/kafka/processors/ConsumeKafka.java | 3 +-
.../AbstractRecordStreamKafkaMessageConverter.java | 14 +-
.../RecordStreamKafkaMessageConverterTest.java | 18 +-
.../nifi-kafka-service-api-nar/pom.xml | 6 +-
.../nifi-kafka-service-api/pom.xml | 2 +-
.../nifi-kafka-service-aws-nar/pom.xml | 2 +-
.../nifi-kafka-service-aws/pom.xml | 2 +-
.../nifi-kafka-service-shared/pom.xml | 10 +-
.../service/consumer/Kafka3AssignmentService.java | 1 +
.../nifi-kafka-bundle/nifi-kafka-shared/pom.xml | 2 +-
nifi-extension-bundles/nifi-kafka-bundle/pom.xml | 2 +-
.../nifi-media-bundle/nifi-media-nar/pom.xml | 6 +-
.../nifi-media-processors/pom.xml | 4 +-
nifi-extension-bundles/nifi-media-bundle/pom.xml | 2 +-
.../nifi-mongodb-client-service-api-nar/pom.xml | 6 +-
.../nifi-mongodb-client-service-api/pom.xml | 2 +-
.../nifi-mongodb-bundle/nifi-mongodb-nar/pom.xml | 6 +-
.../nifi-mongodb-processors/pom.xml | 12 +-
.../nifi-mongodb-services-nar/pom.xml | 6 +-
.../nifi-mongodb-services/pom.xml | 8 +-
nifi-extension-bundles/nifi-mongodb-bundle/pom.xml | 2 +-
.../nifi-mqtt-bundle/nifi-mqtt-nar/pom.xml | 6 +-
.../nifi-mqtt-bundle/nifi-mqtt-processors/pom.xml | 8 +-
nifi-extension-bundles/nifi-mqtt-bundle/pom.xml | 2 +-
.../nifi-network-processors-nar/pom.xml | 6 +-
.../nifi-network-processors/pom.xml | 4 +-
.../nifi-network-bundle/nifi-network-utils/pom.xml | 2 +-
nifi-extension-bundles/nifi-network-bundle/pom.xml | 2 +-
.../nifi-opentelemetry-nar/pom.xml | 6 +-
.../nifi-opentelemetry-processors/pom.xml | 10 +-
.../nifi-opentelemetry-bundle/pom.xml | 2 +-
.../nifi-parquet-content-viewer/pom.xml | 12 +-
.../nifi-parquet-bundle/nifi-parquet-nar/pom.xml | 8 +-
.../nifi-parquet-processors/pom.xml | 8 +-
.../nifi-parquet-shared/pom.xml | 2 +-
nifi-extension-bundles/nifi-parquet-bundle/pom.xml | 2 +-
.../nifi-pgp-bundle/nifi-pgp-nar/pom.xml | 6 +-
.../nifi-pgp-bundle/nifi-pgp-processors/pom.xml | 6 +-
.../nifi-pgp-service-api-nar/pom.xml | 6 +-
.../nifi-pgp-bundle/nifi-pgp-service-api/pom.xml | 2 +-
.../nifi-pgp-bundle/nifi-pgp-service-nar/pom.xml | 6 +-
.../nifi-pgp-bundle/nifi-pgp-service/pom.xml | 6 +-
.../nifi-pgp-bundle/nifi-pgp-test-utils/pom.xml | 2 +-
nifi-extension-bundles/nifi-pgp-bundle/pom.xml | 2 +-
.../nifi-poi-bundle/nifi-poi-nar/pom.xml | 6 +-
.../nifi-poi-bundle/nifi-poi-services/pom.xml | 6 +-
nifi-extension-bundles/nifi-poi-bundle/pom.xml | 2 +-
.../nifi-protobuf-services-nar/pom.xml | 2 +-
.../nifi-protobuf-services/pom.xml | 2 +-
.../nifi-protobuf-bundle/pom.xml | 2 +-
.../nifi-py4j-bridge/pom.xml | 8 +-
.../nifi-py4j-integration-tests/pom.xml | 12 +-
.../nifi-py4j-nar/pom.xml | 6 +-
.../nifi-python-test-extensions/pom.xml | 2 +-
.../nifi-py4j-extension-bundle/pom.xml | 2 +-
.../nifi-redis-extensions/pom.xml | 8 +-
.../nifi-redis-bundle/nifi-redis-nar/pom.xml | 6 +-
.../nifi-redis-service-api-nar/pom.xml | 6 +-
.../nifi-redis-service-api/pom.xml | 2 +-
.../nifi-redis-bundle/nifi-redis-utils/pom.xml | 4 +-
nifi-extension-bundles/nifi-redis-bundle/pom.xml | 2 +-
.../nifi-registry-bundle/nifi-registry-nar/pom.xml | 6 +-
.../nifi-registry-service/pom.xml | 6 +-
.../nifi-registry-bundle/pom.xml | 2 +-
.../nifi-salesforce-nar/pom.xml | 6 +-
.../nifi-salesforce-processors/pom.xml | 6 +-
.../nifi-salesforce-bundle/pom.xml | 2 +-
.../nifi-scripting-nar/pom.xml | 4 +-
.../nifi-scripting-processors/pom.xml | 4 +-
.../nifi-scripting-bundle/pom.xml | 8 +-
.../nifi-shopify-bundle/nifi-shopify-nar/pom.xml | 6 +-
.../nifi-shopify-processors/pom.xml | 4 +-
nifi-extension-bundles/nifi-shopify-bundle/pom.xml | 2 +-
.../nifi-site-to-site-reporting-nar/pom.xml | 6 +-
.../nifi-site-to-site-reporting-task/pom.xml | 12 +-
.../nifi-site-to-site-reporting-bundle/pom.xml | 2 +-
.../nifi-slack-bundle/nifi-slack-nar/pom.xml | 6 +-
.../nifi-slack-processors/pom.xml | 4 +-
nifi-extension-bundles/nifi-slack-bundle/pom.xml | 2 +-
.../nifi-smb-client-api-nar/pom.xml | 6 +-
.../nifi-smb-bundle/nifi-smb-client-api/pom.xml | 4 +-
.../nifi-smb-bundle/nifi-smb-nar/pom.xml | 6 +-
.../nifi-smb-bundle/nifi-smb-processors/pom.xml | 8 +-
.../nifi-smb-smbj-client-nar/pom.xml | 6 +-
.../nifi-smb-bundle/nifi-smb-smbj-client/pom.xml | 6 +-
.../nifi-smb-bundle/nifi-smb-smbj-common/pom.xml | 2 +-
nifi-extension-bundles/nifi-smb-bundle/pom.xml | 2 +-
.../nifi-snmp-bundle/nifi-snmp-nar/pom.xml | 6 +-
.../nifi-snmp-bundle/nifi-snmp-processors/pom.xml | 4 +-
nifi-extension-bundles/nifi-snmp-bundle/pom.xml | 2 +-
.../nifi-snowflake-processors-nar/pom.xml | 6 +-
.../nifi-snowflake-processors/pom.xml | 10 +-
.../nifi-snowflake-services-api-nar/pom.xml | 6 +-
.../nifi-snowflake-services-api/pom.xml | 2 +-
.../nifi-snowflake-services-nar/pom.xml | 6 +-
.../nifi-snowflake-services/pom.xml | 6 +-
.../nifi-snowflake-bundle/pom.xml | 2 +-
.../nifi-social-media-nar/pom.xml | 6 +-
.../nifi-twitter-processors/pom.xml | 2 +-
.../nifi-social-media-bundle/pom.xml | 2 +-
.../nifi-splunk-bundle/nifi-splunk-nar/pom.xml | 6 +-
.../nifi-splunk-processors/pom.xml | 6 +-
nifi-extension-bundles/nifi-splunk-bundle/pom.xml | 2 +-
.../nifi-sql-reporting-nar/pom.xml | 4 +-
.../nifi-sql-reporting-tasks/pom.xml | 10 +-
.../nifi-sql-reporting-bundle/pom.xml | 4 +-
.../nifi-standard-content-viewer-nar/pom.xml | 6 +-
.../nifi-standard-content-viewer/pom.xml | 10 +-
.../nifi-standard-bundle/nifi-standard-nar/pom.xml | 4 +-
.../nifi-standard-parameter-providers/pom.xml | 4 +-
.../nifi-standard-processors/pom.xml | 68 +--
.../nifi/processors/standard/TestQueryRecord.java | 58 +--
.../nifi-standard-reporting-tasks/pom.xml | 2 +-
.../nifi-standard-rules/pom.xml | 2 +-
.../nifi-standard-bundle/pom.xml | 12 +-
.../nifi-standard-services-api-bom/pom.xml | 46 +-
.../nifi-database-dialect-service-api/pom.xml | 2 +-
.../nifi-database-dialect-service-nar/pom.xml | 6 +-
.../nifi-database-dialect-service/pom.xml | 2 +-
.../nifi-database-dialect-service-bundle/pom.xml | 2 +-
.../nifi-db-schema-registry-service-nar/pom.xml | 6 +-
.../nifi-db-schema-registry-service/pom.xml | 4 +-
.../nifi-db-schema-registry-bundle/pom.xml | 2 +-
.../nifi-dbcp-service-api/pom.xml | 2 +-
.../nifi-dbcp-service-nar/pom.xml | 8 +-
.../nifi-dbcp-service/pom.xml | 12 +-
.../org/apache/nifi/dbcp/DBCPConnectionPool.java | 1 +
.../java/org/apache/nifi/dbcp/DBCPServiceTest.java | 31 ++
.../nifi-hikari-dbcp-service/pom.xml | 6 +-
.../nifi-dbcp-service-bundle/pom.xml | 2 +-
.../pom.xml | 2 +-
.../nifi-distributed-cache-client-service/pom.xml | 6 +-
.../nifi-distributed-cache-protocol/pom.xml | 2 +-
.../nifi-distributed-cache-server/pom.xml | 14 +-
.../nifi-distributed-cache-services-nar/pom.xml | 10 +-
.../nifi-distributed-cache-services-bundle/pom.xml | 2 +-
.../nifi-file-resource-service-api/pom.xml | 2 +-
.../nifi-file-resource-service-nar/pom.xml | 6 +-
.../nifi-file-resource-service/pom.xml | 2 +-
.../nifi-file-resource-service-bundle/pom.xml | 2 +-
.../nifi-hadoop-dbcp-service-nar/pom.xml | 6 +-
.../nifi-hadoop-dbcp-service/pom.xml | 8 +-
.../nifi-hadoop-dbcp-service-bundle/pom.xml | 2 +-
.../nifi-http-context-map-api/pom.xml | 2 +-
.../nifi-http-context-map-nar/pom.xml | 6 +-
.../nifi-http-context-map/pom.xml | 2 +-
.../nifi-http-context-map-bundle/pom.xml | 2 +-
.../nifi-kerberos-user-service-api/pom.xml | 2 +-
.../nifi-kerberos-user-service-nar/pom.xml | 6 +-
.../nifi-kerberos-user-service/pom.xml | 4 +-
.../nifi-kerberos-user-service-bundle/pom.xml | 2 +-
.../nifi-key-service-api/pom.xml | 2 +-
.../nifi-key-service-nar/pom.xml | 6 +-
.../nifi-key-service/pom.xml | 2 +-
.../nifi-key-service-bundle/pom.xml | 2 +-
.../nifi-lookup-service-api/pom.xml | 2 +-
.../nifi-lookup-services-nar/pom.xml | 6 +-
.../nifi-lookup-services/pom.xml | 8 +-
.../nifi-lookup-services-bundle/pom.xml | 2 +-
.../nifi-oauth2-provider-api/pom.xml | 2 +-
.../nifi-oauth2-provider-nar/pom.xml | 6 +-
.../nifi-oauth2-provider-service/pom.xml | 2 +-
.../nifi-oauth2-provider-bundle/pom.xml | 2 +-
.../nifi-proxy-configuration-api/pom.xml | 2 +-
.../nifi-proxy-configuration-nar/pom.xml | 6 +-
.../nifi-proxy-configuration/pom.xml | 2 +-
.../nifi-proxy-configuration-bundle/pom.xml | 2 +-
.../nifi-record-serialization-service-api/pom.xml | 2 +-
.../nifi-record-serialization-services-nar/pom.xml | 6 +-
.../pom.xml | 6 +-
.../nifi-record-serialization-services/pom.xml | 18 +-
.../pom.xml | 2 +-
.../nifi-record-sink-api/pom.xml | 2 +-
.../nifi-record-sink-service-nar/pom.xml | 6 +-
.../nifi-record-sink-service/pom.xml | 10 +-
.../nifi-record-sink-service-bundle/pom.xml | 2 +-
.../nifi-schema-registry-service-api/pom.xml | 2 +-
.../nifi-ssl-context-service-nar/pom.xml | 6 +-
.../nifi-ssl-context-service/pom.xml | 6 +-
.../nifi-ssl-context-bundle/pom.xml | 2 +-
.../nifi-ssl-context-service-api/pom.xml | 2 +-
.../nifi-standard-services-api-nar/pom.xml | 2 +-
.../nifi-web-client-provider-api/pom.xml | 2 +-
.../nifi-web-client-provider-service-nar/pom.xml | 6 +-
.../nifi-web-client-provider-service/pom.xml | 8 +-
.../nifi-web-client-provider-bundle/pom.xml | 2 +-
.../nifi-standard-services/pom.xml | 2 +-
.../nifi-standard-shared-bom/pom.xml | 2 +-
.../nifi-standard-shared-nar/pom.xml | 4 +-
.../nifi-standard-shared-bundle/pom.xml | 2 +-
.../nifi-stateful-analysis-nar/pom.xml | 2 +-
.../nifi-stateful-analysis-processors/pom.xml | 4 +-
.../nifi-stateful-analysis-bundle/pom.xml | 4 +-
.../nifi-update-attribute-model/pom.xml | 4 +-
.../nifi-update-attribute-nar/pom.xml | 12 +-
.../nifi-update-attribute-processor/pom.xml | 4 +-
.../nifi-update-attribute-ui/pom.xml | 14 +-
.../nifi-update-attribute-bundle/pom.xml | 2 +-
.../nifi-websocket-processors-nar/pom.xml | 6 +-
.../nifi-websocket-processors/pom.xml | 6 +-
.../processors/websocket/TestConnectWebSocket.java | 1 +
.../nifi-websocket-services-api-nar/pom.xml | 6 +-
.../nifi-websocket-services-api/pom.xml | 2 +-
.../nifi-websocket-services-jetty-nar/pom.xml | 6 +-
.../nifi-websocket-services-jetty/pom.xml | 8 +-
.../nifi-websocket-bundle/pom.xml | 2 +-
.../nifi-windows-event-log-nar/pom.xml | 4 +-
.../nifi-windows-event-log-processors/pom.xml | 4 +-
.../nifi-windows-event-log-bundle/pom.xml | 2 +-
.../nifi-workday-processors-nar/pom.xml | 6 +-
.../nifi-workday-processors/pom.xml | 6 +-
nifi-extension-bundles/nifi-workday-bundle/pom.xml | 2 +-
.../nifi-zendesk-common/pom.xml | 4 +-
.../nifi-zendesk-bundle/nifi-zendesk-nar/pom.xml | 6 +-
.../nifi-zendesk-processors/pom.xml | 6 +-
.../nifi-zendesk-services-nar/pom.xml | 6 +-
.../nifi-zendesk-services/pom.xml | 6 +-
nifi-extension-bundles/nifi-zendesk-bundle/pom.xml | 2 +-
nifi-extension-bundles/pom.xml | 2 +-
nifi-framework-api/pom.xml | 2 +-
.../controller/ControllerServiceProxyWrapper.java | 142 ++---
.../pom.xml | 6 +-
.../nifi-framework-kubernetes-nar/pom.xml | 8 +-
.../pom.xml | 6 +-
.../nifi-framework-kubernetes-bundle/pom.xml | 2 +-
.../nifi-framework-cluster-zookeeper/pom.xml | 4 +-
.../pom.xml | 8 +-
.../nifi-framework-zookeeper-nar/pom.xml | 8 +-
.../pom.xml | 4 +-
.../nifi-framework-zookeeper-bundle/pom.xml | 2 +-
.../nifi-kerberos-iaa-providers-nar/pom.xml | 4 +-
.../nifi-kerberos-iaa-providers/pom.xml | 6 +-
.../nifi-kerberos-iaa-providers-bundle/pom.xml | 2 +-
.../nifi-ldap-iaa-providers-nar/pom.xml | 4 +-
.../nifi-ldap-iaa-providers/pom.xml | 12 +-
.../nifi-ldap-iaa-providers-bundle/pom.xml | 2 +-
.../nifi-persistent-provenance-repository/pom.xml | 8 +-
.../nifi-provenance-repository-nar/pom.xml | 2 +-
.../nifi-volatile-provenance-repository/pom.xml | 6 +-
.../nifi-provenance-repository-bundle/pom.xml | 6 +-
.../nifi-python-extension-api/pom.xml | 2 +-
.../nifi-python-framework-api/pom.xml | 2 +-
.../nifi-python-framework/pom.xml | 2 +-
.../nifi-py4j-framework-bundle/pom.xml | 2 +-
.../nifi-questdb-status-history-nar/pom.xml | 6 +-
.../nifi-questdb-status-history/pom.xml | 8 +-
.../nifi-questdb-bundle/nifi-questdb/pom.xml | 4 +-
.../nifi-questdb-bundle/pom.xml | 2 +-
.../nifi-single-user-iaa-providers-nar/pom.xml | 4 +-
.../nifi-single-user-iaa-providers/pom.xml | 6 +-
.../nifi-single-user-iaa-providers-bundle/pom.xml | 2 +-
.../nifi-framework-extensions/pom.xml | 2 +-
.../nifi-framework-nar-bom/pom.xml | 52 +-
nifi-framework-bundle/nifi-framework-nar/pom.xml | 4 +-
.../nifi-framework/nifi-administration/pom.xml | 4 +-
.../nifi-framework/nifi-authorizer/pom.xml | 16 +-
.../nifi-framework/nifi-client-dto/pom.xml | 4 +-
.../nifi-framework/nifi-file-authorizer/pom.xml | 16 +-
.../nifi-flowfile-repo-serialization/pom.xml | 10 +-
.../nifi-framework-authorization-providers/pom.xml | 8 +-
.../nifi-framework-authorization/pom.xml | 4 +-
.../nifi-framework-cluster-protocol/pom.xml | 12 +-
.../nifi-framework/nifi-framework-cluster/pom.xml | 38 +-
.../impl/FileBasedClusterNodeFirewall.java | 14 +-
.../nifi-framework-components/pom.xml | 36 +-
.../nifi-framework/nifi-framework-core-api/pom.xml | 18 +-
.../org/apache/nifi/controller/ComponentNode.java | 18 +-
.../nifi-framework/nifi-framework-core/pom.xml | 76 +--
.../nifi-framework-external-resource-utils/pom.xml | 8 +-
.../nifi-framework-leader-election-shared/pom.xml | 4 +-
.../nifi-framework-nar-loading-utils/pom.xml | 6 +-
.../nifi-framework-nar-utils/pom.xml | 2 +-
.../nifi-framework-status-history-shared/pom.xml | 2 +-
.../nifi-framework/nifi-headless-server/pom.xml | 16 +-
.../nifi-framework/nifi-mock-authorizer/pom.xml | 2 +-
.../nifi-framework/nifi-nar-utils/pom.xml | 2 +-
.../nifi-framework/nifi-properties-loader/pom.xml | 2 +-
.../nifi-framework/nifi-repository-models/pom.xml | 2 +-
.../nifi-framework/nifi-resources/pom.xml | 2 +-
.../nifi-framework/nifi-runtime/pom.xml | 2 +-
.../nifi-framework/nifi-site-to-site/pom.xml | 18 +-
.../nifi-standard-prioritizers/pom.xml | 2 +-
.../nifi-framework/nifi-user-actions/pom.xml | 2 +-
.../nifi-framework/nifi-web/nifi-jetty/pom.xml | 26 +-
.../nifi-web/nifi-ui-extension/pom.xml | 2 +-
.../nifi-framework/nifi-web/nifi-ui/pom.xml | 4 +-
.../nifi-framework/nifi-web/nifi-web-api/pom.xml | 34 +-
.../nifi/prometheusutil/VersionInfoRegistry.java | 16 +-
.../apache/nifi/web/StandardNiFiServiceFacade.java | 9 +
.../org/apache/nifi/web/api/VersionsResource.java | 1 +
.../nifi-web/nifi-web-optimistic-locking/pom.xml | 6 +-
.../nifi-web/nifi-web-security/pom.xml | 36 +-
.../nifi-framework/nifi-web/pom.xml | 2 +-
nifi-framework-bundle/nifi-framework/pom.xml | 2 +-
nifi-framework-bundle/nifi-jetty-nar/pom.xml | 2 +-
nifi-framework-bundle/nifi-server-nar-bom/pom.xml | 4 +-
nifi-framework-bundle/nifi-server-nar/pom.xml | 8 +-
nifi-framework-bundle/pom.xml | 2 +-
nifi-frontend/pom.xml | 2 +-
.../navigation-control.component.html | 10 +-
.../navigation-control.component.ts | 3 +-
.../operation-control.component.html | 10 +
.../operation-control.component.ts | 3 +-
.../nifi-extension-manifest-model/pom.xml | 2 +-
.../nifi-extension-manifest-parser/pom.xml | 4 +-
nifi-manifest/nifi-runtime-manifest-core/pom.xml | 8 +-
nifi-manifest/nifi-runtime-manifest-test/pom.xml | 6 +-
nifi-manifest/nifi-runtime-manifest/pom.xml | 4 +-
nifi-manifest/pom.xml | 2 +-
.../nifi-processor-bundle-archetype/pom.xml | 2 +-
.../nifi-service-bundle-archetype/pom.xml | 2 +-
nifi-maven-archetypes/pom.xml | 2 +-
nifi-mock/pom.xml | 6 +-
nifi-registry/nifi-registry-assembly/pom.xml | 6 +-
.../nifi-registry-bootstrap/pom.xml | 2 +-
.../nifi-registry-bundle-utils/pom.xml | 6 +-
.../nifi-registry-client/pom.xml | 12 +-
.../nifi-registry-data-model/pom.xml | 6 +-
.../nifi-registry-docker/pom.xml | 2 +-
.../nifi-registry-core/nifi-registry-docs/pom.xml | 2 +-
.../nifi-registry-flow-diff/pom.xml | 2 +-
.../nifi-registry-framework/pom.xml | 16 +-
.../nifi-registry-core/nifi-registry-jetty/pom.xml | 10 +-
.../nifi-registry-properties-loader/pom.xml | 2 +-
.../nifi-registry-properties/pom.xml | 2 +-
.../nifi-registry-provider-api/pom.xml | 2 +-
.../nifi-registry-resources/pom.xml | 2 +-
.../nifi-registry-revision-api/pom.xml | 2 +-
.../nifi-registry-revision-common/pom.xml | 4 +-
.../nifi-registry-revision-entity-model/pom.xml | 2 +-
.../nifi-registry-revision-entity-service/pom.xml | 6 +-
.../nifi-registry-revision-spring-jdbc/pom.xml | 6 +-
.../nifi-registry-revision/pom.xml | 2 +-
.../nifi-registry-runtime/pom.xml | 4 +-
.../nifi-registry-security-api/pom.xml | 2 +-
.../nifi-registry-security-utils/pom.xml | 2 +-
.../nifi-registry-core/nifi-registry-test/pom.xml | 4 +-
.../nifi-registry-core/nifi-registry-utils/pom.xml | 2 +-
.../nifi-registry-web-api/pom.xml | 18 +-
.../nifi-registry-web-docs/pom.xml | 2 +-
.../nifi-registry-web-ui/pom.xml | 2 +-
nifi-registry/nifi-registry-core/pom.xml | 2 +-
.../nifi-registry-docker-maven/dockermaven/pom.xml | 2 +-
nifi-registry/nifi-registry-docker-maven/pom.xml | 2 +-
.../nifi-registry-aws-assembly/pom.xml | 4 +-
.../nifi-registry-aws-extensions/pom.xml | 2 +-
.../nifi-registry-aws/pom.xml | 2 +-
nifi-registry/nifi-registry-extensions/pom.xml | 2 +-
.../nifi-registry-toolkit-assembly/pom.xml | 4 +-
.../nifi-registry-toolkit-persistence/pom.xml | 4 +-
nifi-registry/nifi-registry-toolkit/pom.xml | 2 +-
nifi-registry/pom.xml | 26 +-
nifi-server-api/pom.xml | 6 +-
nifi-stateless/nifi-stateless-api/pom.xml | 2 +-
nifi-stateless/nifi-stateless-assembly/pom.xml | 10 +-
nifi-stateless/nifi-stateless-bootstrap/pom.xml | 2 +-
.../nifi-stateless-engine/pom.xml | 32 +-
.../nifi-stateless-nar/pom.xml | 4 +-
nifi-stateless/nifi-stateless-bundle/pom.xml | 2 +-
nifi-stateless/nifi-stateless-resources/pom.xml | 2 +-
nifi-stateless/pom.xml | 2 +-
.../nifi-alternate-config-extensions-nar/pom.xml | 6 +-
.../nifi-alternate-config-extensions/pom.xml | 4 +-
.../pom.xml | 2 +-
.../nifi-python-test-extensions-nar/pom.xml | 4 +-
.../nifi-stateless-system-test-suite/pom.xml | 36 +-
.../nifi-system-test-authorizer-nar/pom.xml | 4 +-
.../nifi-system-test-authorizer/pom.xml | 4 +-
.../nifi-system-test-authorizer-bundle/pom.xml | 2 +-
.../pom.xml | 4 +-
.../pom.xml | 4 +-
.../pom.xml | 2 +-
.../nifi-system-test-extensions-nar/pom.xml | 8 +-
.../pom.xml | 6 +-
.../pom.xml | 2 +-
.../pom.xml | 6 +-
.../nifi-system-test-extensions-services/pom.xml | 8 +-
.../nifi-system-test-extensions/pom.xml | 12 +-
.../nifi-system-test-extensions-bundle/pom.xml | 2 +-
.../nifi-system-test-extensions2-nar/pom.xml | 8 +-
.../nifi-system-test-extensions2/pom.xml | 4 +-
.../nifi-system-test-extensions2-bundle/pom.xml | 2 +-
.../pom.xml | 4 +-
.../nifi-system-test-flow-action-reporter/pom.xml | 4 +-
.../pom.xml | 2 +-
.../nifi-nar-provider-assembly/pom.xml | 8 +-
.../nifi-nar-provider-processors-nar/pom.xml | 8 +-
.../nifi-nar-provider-processors/pom.xml | 8 +-
.../nifi-nar-provider-service-api-nar/pom.xml | 8 +-
.../nifi-nar-provider-service-api/pom.xml | 2 +-
.../nifi-nar-provider-service-nar/pom.xml | 8 +-
.../nifi-nar-provider-service/pom.xml | 8 +-
.../nifi-system-test-nar-provider-bundles/pom.xml | 2 +-
nifi-system-tests/nifi-system-test-suite/pom.xml | 62 +--
nifi-system-tests/pom.xml | 2 +-
nifi-toolkit/nifi-toolkit-api/pom.xml | 2 +-
nifi-toolkit/nifi-toolkit-assembly/pom.xml | 4 +-
nifi-toolkit/nifi-toolkit-cli/pom.xml | 16 +-
nifi-toolkit/nifi-toolkit-client/pom.xml | 14 +-
nifi-toolkit/pom.xml | 2 +-
pmd-ruleset.xml | 2 +-
pom.xml | 12 +-
748 files changed, 3013 insertions(+), 2737 deletions(-)
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/test/java/org/apache/nifi/processors/aws/s3/AbstractS3ProcessorTest.java
