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
discard 4553dccb4d8 NIFI-15648 - Resolve SECRET property values before
fetchAllowableValues and verify in working flow context (#10937)
discard 150bdf5e534 NIFI-15604: Expose VersionedExternalFlow that represents
the Active/Working flow from ConnectorTestRunner (#10901)
discard d227159fd59 NIFI-15680: Not including global parameter contexts and
parameters in connector search results. (#10980)
omit 945dd2e5ac3 NIFI-15663: Update to use new ComponentHierarchyScope
instead of on facade/lifecycle classes (#10958)
omit 9626e31b7d8 NIFI-15629 Add ConnectorRequestContext (#10924)
omit 304b95d1594 NIFI-15640: NPE in the applyFlow should NOT crash the
runtime. (#10931)
omit ff27361f9f8 NIFI-15621: Allow Configuration to Validate with
ValidationContext (#10916)
omit 4415f8f68e9 NIFI-15610 Add asset management to
ConnectorConfigurationProvider (#10909)
omit 5a31758bd08 NIFI-15615: Ensure that we include necessary values in the
ConnectorStatusDTO (#10913)
omit 0d7d9c8856e NIFI-15598: When enabling referenced controller services
in a connector, skip references from properties with unsatisfied dependencies
(#10897)
omit 5e0255d2567 NIFI-15618: Bug fixes around handling of FlowFileActivity
with child groups and stateless groups (#10912)
omit e2c09c2e2f1 NIFI-15611: Fetchable Values should pull from current
FlowContext (#10906)
omit 8ff7ded679f NIFI-15606: Connector Mock War implementation. (#10907)
omit f61609dfe6f NIFI-15605 - Rebase Connectors branch with main for
2.9.0-SNAPSHOT
omit 60ca5b563b7 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 c744abde332 NIFI-15581: Add support for ControllerService Mocks for
Connectors. (#10885)
omit f1842283628 NIFI-15577: Including connector id in provenance event
dto. (#10883)
omit 78ce1dd8e3e NIFI-15258: Fixes as a result of rebasing against main
omit 5fe92e8bf1b NIFI-15559: Enforce data permissions when purging data
from a Connector. (#10867)
omit 1ae00bbadb3 NIFI-15355 Connector Configuration Repository (#10876)
omit 1ccb40719c9 NIFI-15565: Code cleanup; improvements to .cursorrules to
provide bet… (#10869)
omit 1b6e3d3773b NIFI-15539: Updating the actions in FlowFileQueueResource
to support … (#10846)
omit e4fb9fefb49 NIFI-15558: Sensitive Parameter References should resolve
to value. (#10863)
omit bbb21b890ec NIFI-15544: If a Connector requires processors or
controller services that are unavailable, make Connector invalid but not
ghosted (#10851)
omit 002d27b34e0 NIFI-15488: Added significant number of debug log messages
as well as some info/error for connector-related events (#10803)
omit 2c0594e9837 NIFI-15557: Allow Connectors to enable a Controller
Service using overridden property values (#10862)
omit 3f138178c02 NIFI-15549: Adding endpoints for viewing and clearing
state for compo… (#10855)
omit 747e043410f NIFI-15480 Added ability to drop FlowFiles selectively
using a Predicate (#10848)
omit 768dbb3d20f NIFI-15538: When starting/stopping components allow
specifying whethe… (#10843)
omit 678702c49a7 NIFI-15514: Ensure that Parameter Contexts are assigned to
all Proces… (#10815)
omit 7b24be69793 NIFI-15511: Added endpoints for purging all FlowFiles for
a given Con… (#10833)
omit 16db577fa00 NIFI-15536: Change Connector API to use DescribedValue vs
AllowableValue (#10841)
omit 6b780b5c9da NIFI-15509: Enable Component reload additional classpath
resources if needed (#10812)
omit b3c332ebb93 NIFI-15525: Ensure that we call onStepConfigured when we
restore flow; ensure that we synchronized Parmaeter Providers before Connectors
(#10835)
omit 14c0b744246 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 5c41b7999c0 NIFI-15467: Ensure that Connectors' versions are
automatically resolv… (#10811)
omit 897ac061245 NIFI-15465 Allow client-specified connector component ids
(#10768)
omit ab9d42dc070 NIFI-15495 Restart Connectors that reference assets that
were synchro… (#10806)
omit 6eac4c8e5e3 NIFI-15258: Fixes for system tests that needed to be
updated from 2.7.0-SNAPSHOT to 2.8.0-SNAPSHOT (#10807)
omit 4666dd34a4d NIFI-15497: Fixed unit tests (#10805)
omit 8e90a96f195 NIFI-15485: Include provider name when providing fqn for
secrets (#10801)
omit bf9bb43d440 NIFI-15490: If any processors or controller services are
missing, make Connector invalid (#10799)
omit 7dc60d8a4d1 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 cb63f62e289 NIFI-15461: Added ability to initiate drainage of
Connector's FlowFiles and calce; added tests to verify; some bug fixes (#10767)
omit 239876b6d6f NIFI-15258: Addressed checkstyle violations
omit ed599240ebc NIFI-15258: Fixes necessary after rebasing against main
omit bea7abbf3d1 NIFI-15481: Updated ConnectorActions to reflect that
starting is not … (#10782)
omit 6d8b66650a1 NIFI-15451: Added ability for Connectors to retrieve
bundles availabl… (#10756)
omit 2359a008abe NIFI-15482: MockConnectorAssetManager requires SPI file to
start (#10783)
omit 27f79c4ad58 NIFI-15472: Added addAsset methods to ConnectorTestRunner
(#10776)
omit 3a899e9e1b3 NIFI-15453: Adding an endpoint to return all controller
services for … (#10770)
omit eba8ff3b90c NIFI-15376: Adding dependencies to the configuration step
dto. (#10674)
omit e0bdd7063f7 NIFI-15446: When invoking ConnectorMethod, make sure to
serialize/des… (#10750)
omit 2268a0afe3a NIFI-15468: Ensure that we properly initialize
ConnectorNode even if a Ghost Connector is created (#10775)
omit 02fc2e82a22 NIFI-15439: Ensure that Process Groups are accessible from
the approp… (#10742)
omit 04c506db940 NIFI-15440: Implementation of ConnectorActions (#10748)
omit b9477248740 NIFI-15445: Removed 'disabled' state from Connectors; also
fixed bug … (#10749)
omit a132a3bf0cd NIFI-15434: Ensure that we start or stop connectors on
flow sync (#10737)
omit 7f82dd354ad NIFI-15433: If connector validation throws an Exception
keep trying u… (#10736)
omit 0ee6cad6c9f NIFI-15427: Added abiliy to drop flowfiles / drain
flowfiles from a C… (#10730)
omit 847296efead NIFI-15430: Ensure that if we fail to initialize a
Connector, we crea… (#10733)
omit a08106927fb NIFI-15429: Adding an optional query parameter for
specifying which p… (#10732)
omit cca6a744aea NIFI-15353: Adding support for rendering Connector
Documentation. (#10683)
omit 1f71e98fe1b NIFI-15356: Adding authorization to the
StandardNiFiConnectorWebContext. (#10660)
omit c0f97756117 NIFI-15370: Add Connector ID to process groups and do not
register create process groups if they have a connector ID. (#10673)
omit 2d3b5dab4c4 NIFI-15367: Ensure that Connectors' implicit parameter
contexts are n… (#10665)
omit 2aa3f37eea1 NIFI-15369: Allow ConfigurationStep to depend on another
(ConfigurationStep,Property) tuple (#10669)
omit 81fa7e54804 NIFI-15361: Allowing configuration step documentation to
be returned … (#10667)
omit 2e55f8fc2a8 NIFI-15315 Add support for assets in connectors (#10647)
omit fa15dd651dc NIFI-15343: Adding an endpoint to return available secrets
to the con… (#10645)
omit ad80a0d3e7a NIFI-15352: Added ConnectorClient to toolkit-cli so that
it can be us… (#10654)
omit 4eef936c99d NIFI-15258: Enable Custom UI to retrieve connector with
flow contexts (#10652)
omit 2ea4cbbb912 NIFI-15336: Created AuthorizableSecret and implemented
ParameterProviderSecretProvider to provide the Parameter Provider as the
associated Authorizable (#10644)
omit fb368d43e21 NIFI-15312: Implementation of Parameter Provider based
Secrets Manager; updated mock framework to support secrets; validation cleanup
(#10638)
omit 3d53d0a828c NIFI-15330: Allow GhostConnector to be updated (#10632)
omit 2d2cd52bf4b NIFI-15326: Adding support of configuration step
documentation. (#10631)
omit 482c210f00c NIFI-15322: Require all property descriptors within a
PropertyGroup / ConfigurationStep are unique (#10626)
omit 5cb0d175c85 NIFI-15323: Adding operate permissions to the
ConnectorEntity. (#10625)
omit abd60dc87e7 NIFI-15259: Added REST API for Connectors
omit 57cb88c4442 NIFI-15258: Addressed PMD findings
omit f586e6d3311 NIFI-15258: Fixed checkstyle violations/pmd
omit 54edb9cf224 NIFI-15258: Fixed vulnerable lz4 dependency
omit 7ac3e0f1e05 NIFI-15258: Initial implementation of Connectors
add 86bd16364cc NIFI-15586 Add demarcator processing strategy to
ConsumeKinesis
add da8661d5ba4 NIFI-15607 Bump Spring Security to 7.0.3, JUnit to 6.0.3,
Logback to 1.5.32, and others (#10903)
add b8eb7e23c40 NIFI-15161 - Add support for Azure Federated Identity
Credentials
add 076dccc95bb NIFI-15612 Removed unnecessarily escaped characters.
add 84200f7d1f4 NIFI-11576 Fixed XMLReader to now allow for handling name
spaced attributes when the schema is inferred.
add b3f64ddd503 NIFI-15623 Bump Spring to 7.0.5, Kafka to 4.2.0, ActiveMQ
to 6.2.1, and others (#10917)
add 4fcb342443d NIFI-15620 Added Checkstyle rule preventing multiple blank
lines (#10915)
add 43f7845dc0f NIFI-15624 Fixed recording Gauges on Session Committed
add b4ab5b0d581 NIFI-15625 Remove Transfer-Encoding Header from Replicated
Requests (#10919)
add d4630195ce4 NIFI-15617 Added SEND Provenance Events to several
Processors (#10911)
add dd2f0010b21 NIFI-15626 Added Record Gauge support to Batched Sessions
add 87d70bd98c1 NIFI-15627 Added Record Gauge support to
ExecuteGroovyScript
add 15c570267b2 NIFI-15635 Bump Jackson to 2.21.1, JSON Path to 3.0.0,
Nimbus JWT to 10.8, and others (#10926)
add c8d45fd47d2 NIFI-15638 Add Checkstyle Rules UnusedLocalVariable,
InnerAssignment and AvoidNestedBlocks (#10928)
add 9ec75610fec NIFI-15636 Fixed NPE in StandardFlowComparator when
property descriptors are null in compareProperties (#10927)
add 0c540dfbcbf NIFI-15639: AbstractExecuteSQL will run more than just
select queries
add 625236b7f30 NIFI-14780 Removed introduction of default field name for
content when content is not set to be included and schema is inferred in
XMLReader.
add 7199bdf41bc NIFI-15643: Addressing dependabot issues. (#10933)
add efb54cb39ff NIFI-15628 - Add unique() expression language function
add 41a9406ae67 NIFI-15647 Add SSL configuration support for ActiveMQ
Artemis JMS connections
add b43be1d0e46 NIFI-15563 Added Current Lag gauge recording to
ConsumeKafka
add 4d6eb989152 NIFI-15650 Added Checkstyle Rules for Method Naming
(#10940)
add f6d146f314d NIFI-15381 - Improve UX for the view Show/Revert Local
Changes to account for environmental changes (#10681)
add b08c63a69c5 NIFI-15596 Corrected regex for FlowFile Expiration and
parsed as float to allow the "FlowFile Expiration Indicator" icon to be
displayed when value is a decimal without a leading integer or when leading
integer is 0. (#10893)
add 8231d2fc148 NIFI-15652 Fixed HashiCorp Vault test failures when
VAULT_TOKEN environment variable is set (#10942)
add f03ab1aa833 NIFI-15651 Bump NiFi NAR Plugin to 2.3.0, Protobuf to
4.34.0, Lucene to 10.4.0, and others (#10941)
add eff41e23dbb NIFI-15656 Bump PMD to 7.22.0, Mockito to 5.22.0, RabbitMQ
AMQP Client to 5.29.0, and others (#10947)
add 5854916aa39 NIFI-15649 Add compactDelimitedList() and
trimDelimitedList() Expression Language functions
add 34bf8af191c NIFI-15655 Fixed handling of missing port in Cluster
Leader Address
add 7c6484bf841 NIFI-15602 Standardized spelling of FlowFile (#10951)
add 7abf5f759cd NIFI-15665: Remove duplicate description call in
PROP_BROKER_URI
add 99436b99875 NIFI-15666: Complete NaiveSearchRingBuffer usage example
in Javadoc
add 8011bf482c3 NIFI-5779 Applied Secure Processing in TransformXml to
Sources
add 7474ad04b62 NIFI-15145 Add RecordLookup, KeyValueLookup, and
MapCacheClient Services for Couchbase (#10467)
add fc0b59ede40 NIFI-15672 Bump AWS SDK to 2.42.6, GCP SDK to 26.77,
Fabric8 k8s to 7.6.0, and others (#10967)
add 8c8d0c442d6 NIFI-15654 - Avoid overlapping connections, warn of
existing overlaps (#10943)
add 40c9a4a63fb NIFI-15678 Removed PMD Rules ExhaustiveSwitchHasDefault
and ImplicitSwitchFallThrough (#10977)
add 2fde6eea411 NIFI-15677: Restore special treatment of trigger serially
in the edit… (#10976)
add 811c0d09834 NIFI-15679 Add default cases to switches on nifi-api Enums
(#10978)
add 7acdd446e97 NIFI-15560 Allow RemoteProcessGroup to receive no files
via HTTP without stack trace in logs
add 75184260be1 NIFI-15685 - ListS3 V1 pagination fails when delimiter is
not set causing infinite loop for buckets with more than 1000 objects
add d2b0f13d1cf NIFI-15684 Bump NiFi API to 2.7.0, Jetty to 12.1.7, Maven
to 3.9.13, and others (#10982)
add 6be2570b2eb NIFI-15687 Reverted Current Lag gauge recording in
ConsumeKafka (#10984)
add 7c020cd02a5 NIFI-12082 - Fix additionalDetails of JSON Tree Reader to
have a valid schema example (#10985)
add b4cdd043060 NIFI-15690 Fixed ByteBuf leak in CacheRequestDecoder
readHeader (#10988)
add 5f593207bfd NIFI-15668 Stop Immediately when Run Once requested for
Invalid Processor (#10963)
new 6071ce67df4 NIFI-15258: Initial implementation of Connectors
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 (4553dccb4d8)
\
N -- N -- N refs/heads/NIFI-15258 (6071ce67df4)
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 1 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:
.mvn/wrapper/maven-wrapper.properties | 2 +-
.../apache/nifi/c2/protocol/api/AgentManifest.java | 1 -
.../nifi/c2/protocol/api/FlowQueueStatus.java | 6 +-
.../nifi/c2/protocol/api/ProcessorStatus.java | 8 +-
.../apache/nifi/c2/protocol/api/ResourceItem.java | 1 -
.../nifi/c2/protocol/component/api/Attribute.java | 1 -
.../component/api/ProcessorDefinition.java | 1 -
checkstyle-suppressions.xml | 28 +
checkstyle.xml | 20 +
minifi/minifi-bootstrap/pom.xml | 4 +-
.../ingestors/RestChangeIngestor.java | 1 -
.../bootstrap/status/PeriodicStatusReporter.java | 12 +-
.../bootstrap/status/reporters/StatusLogger.java | 2 -
.../WholeConfigDifferentiatorTest.java | 4 +-
.../ingestors/FileChangeIngestorTest.java | 1 -
.../service/StandardFlowPropertyEncryptor.java | 1 -
.../service/StandardFlowPropertyEncryptorTest.java | 1 -
.../command/UpdatePropertiesPropertyProvider.java | 2 -
.../syncresource/FileResourceRepository.java | 1 -
.../nifi/minifi/status/StatusConfigReporter.java | 2 +-
.../c2/BootstrapC2OperationRestartHandlerTest.java | 1 -
.../DefaultSyncResourceStrategyTest.java | 3 +-
.../minifi/status/StatusConfigReporterTest.java | 6 -
.../nifi/minifi/nar/NarAutoUnloadService.java | 2 -
.../main/java/org/apache/nifi/minifi/MiNiFi.java | 1 -
...ConfigSchemaToVersionedDataFlowTransformer.java | 2 +-
.../json/TransformNifiCommandFactory.java | 1 -
.../nifi/minifi/toolkit/schema/ConfigSchema.java | 2 +-
.../toolkit/schema/ControllerServiceSchema.java | 1 -
.../minifi/toolkit/schema/ProcessGroupSchema.java | 1 -
.../toolkit/schema/ProvenanceReportingSchema.java | 6 +-
.../minifi/toolkit/schema/RemotePortSchema.java | 2 +-
.../toolkit/schema/RemoteProcessGroupSchema.java | 5 +-
.../minifi/toolkit/schema/common/BaseSchema.java | 1 -
.../toolkit/schema/common/CommonPropertyKeys.java | 1 -
.../toolkit/schema/serialization/SchemaLoader.java | 1 -
.../minifi/toolkit/schema/v2/ConfigSchemaV2.java | 2 +-
.../toolkit/schema/v2/ProcessGroupSchemaV2.java | 1 -
nifi-code-coverage/pom.xml | 2 +-
nifi-commons/nifi-calcite-utils/pom.xml | 2 +-
.../main/java/org/apache/nifi/sql/NiFiTable.java | 2 -
.../sql/internal/NiFiProjectTableScanRule.java | 4 -
.../nifi/sql/internal/NiFiTableEnumerator.java | 5 -
.../org/apache/nifi/sql/TestCalciteDatabase.java | 1 -
.../nifi/provenance/StandardLineageResult.java | 4 +-
.../provenance/StandardProvenanceEventRecord.java | 1 -
.../language/antlr/AttributeExpressionLexer.g | 3 +
.../language/antlr/AttributeExpressionParser.g | 2 +-
.../nifi/attribute/expression/language/Query.java | 6 -
.../language/StandardAttributeExpression.java | 1 -
.../expression/language/StandardPreparedQuery.java | 1 -
.../language/compile/ExpressionCompiler.java | 25 +-
...tor.java => CompactDelimitedListEvaluator.java} | 46 +-
.../functions/InstantFormatEvaluator.java | 1 -
.../functions/NumberToInstantEvaluator.java | 1 -
.../functions/RandomNumberGeneratorEvaluator.java | 1 -
.../functions/TrimDelimitedListEvaluator.java | 94 +
.../evaluation/functions/UniqueEvaluator.java | 95 +
.../attribute/expression/language/TestQuery.java | 180 +-
.../nifi/flow/encryptor/JsonFlowEncryptorTest.java | 1 -
.../org/apache/nifi/util/FlowFileUnpackagerV2.java | 2 +-
.../org/apache/nifi/util/FlowFileUnpackagerV3.java | 2 +-
nifi-commons/nifi-hashicorp-vault/pom.xml | 2 +-
.../config/HashiCorpVaultConfiguration.java | 14 +-
.../hashicorp/TestHashiCorpVaultConfiguration.java | 25 +-
.../nifi/parameter/AbstractParameterParser.java | 2 -
.../ExpressionLanguageAwareParameterParser.java | 1 -
.../org/apache/nifi/parameter/ParameterLookup.java | 1 -
.../java/org/apache/nifi/util/NiFiProperties.java | 4 -
.../org/apache/nifi/record/path/RecordPath.java | 1 -
.../apache/nifi/record/path/filter/IsBlank.java | 1 -
.../path/filter/NumericBinaryOperatorFilter.java | 1 -
.../nifi/record/path/functions/Anchored.java | 1 -
.../nifi/record/path/functions/FieldName.java | 1 -
.../record/path/paths/DescendantFieldPath.java | 1 -
.../nifi/record/path/paths/WildcardChildPath.java | 1 -
.../nifi/record/path/paths/WildcardIndexPath.java | 1 -
.../apache/nifi/record/path/TestRecordPath.java | 1 -
.../nifi/serialization/SimpleRecordSchema.java | 8 +-
.../nifi/serialization/record/MapRecord.java | 2 -
.../apache/nifi/serialization/record/Record.java | 1 -
.../nifi/serialization/record/RecordFieldType.java | 3 -
.../serialization/record/SchemaIdentifier.java | 1 -
.../serialization/record/util/DataTypeUtils.java | 3 -
.../record/ResultSetRecordSetTest.java | 4 +-
.../serialization/record/TestDataTypeUtils.java | 3 -
.../nifi/serialization/record/TestMapRecord.java | 16 +-
.../apache/nifi/repository/schema/FieldType.java | 2 -
.../nifi/repository/schema/SchemaRecordReader.java | 3 -
.../ssl/StandardPemPrivateKeyReaderTest.java | 12 +-
.../ssl/StandardX509ExtendedTrustManagerTest.java | 2 -
.../java/org/apache/nifi/remote/PeerStatus.java | 2 +-
.../remote/client/AbstractPeerPersistence.java | 1 -
.../apache/nifi/remote/client/PeerSelector.java | 52 +-
.../nifi/remote/client/SiteToSiteClient.java | 2 -
.../protocol/http/HttpClientTransaction.java | 10 +-
.../protocol/socket/SocketClientTransaction.java | 1 -
.../apache/nifi/remote/util/ClusterUrlParser.java | 1 -
.../protocol/http/TestHttpClientTransaction.java | 8 +-
.../socket/TestSocketClientTransaction.java | 4 -
.../nifi/stream/io/RepeatingInputStream.java | 1 -
.../stream/io/util/AbstractTextDemarcator.java | 1 -
.../nifi/stream/io/util/StreamDemarcator.java | 1 -
.../nifi/stream/io/util/TextLineDemarcator.java | 4 +-
.../java/org/apache/nifi/util/FormatUtils.java | 2 -
.../apache/nifi/util/NaiveSearchRingBuffer.java | 7 +-
.../java/org/apache/nifi/util/file/FileUtils.java | 2 +-
.../nifi/util/text/RegexDateTimeMatcher.java | 3 -
.../stream/io/ByteCountingInputStreamTest.java | 8 +-
.../nifi/stream/io/util/StreamDemarcatorTest.java | 1 -
.../nifi/stream/io/util/TestLineDemarcator.java | 1 -
.../stream/io/util/TextLineDemarcatorTest.java | 1 -
.../java/org/apache/nifi/util/TestFormatUtils.java | 1 -
.../util/validator/TestStandardValidators.java | 2 -
.../web/client/StandardWebClientServiceTest.java | 1 -
.../java/org/apache/nifi/wali/HashMapSnapshot.java | 1 -
.../apache/nifi/wali/LengthDelimitedJournal.java | 3 -
.../nifi/wali/SequentialAccessWriteAheadLog.java | 2 -
.../org/apache/nifi/wali/SnapshotRecovery.java | 1 -
.../nifi/wali/TestLengthDelimitedJournal.java | 7 -
.../wali/TestSequentialAccessWriteAheadLog.java | 1 -
.../main/asciidoc/expression-language-guide.adoc | 103 +
.../nifi-amqp-bundle/nifi-amqp-processors/pom.xml | 2 +-
.../amqp/processors/AbstractAMQPProcessor.java | 2 -
.../apache/nifi/amqp/processors/PublishAMQP.java | 1 -
.../nifi/amqp/processors/ConsumeAMQPTest.java | 14 +-
.../nifi/amqp/processors/PublishAMQPTest.java | 1 -
.../schemaregistry/ApicurioSchemaRegistry.java | 1 -
.../apicurio/schemaregistry/util/SchemaUtils.java | 1 -
.../java/org/apache/nifi/jasn1/JASN1Reader.java | 1 -
.../org/apache/nifi/jasn1/JASN1ReaderTest.java | 1 -
.../nifi/jasn1/TestRecordSchemaProvider.java | 1 -
.../preprocess/AsnPreprocessorEngineTest.java | 21 +-
.../org/apache/nifi/jasn1/util/RecordTestUtil.java | 1 -
.../nifi/processors/aws/AbstractAwsProcessor.java | 3 -
.../aws/dynamodb/AbstractDynamoDBProcessor.java | 2 +-
.../nifi/processors/aws/dynamodb/ItemKeys.java | 2 +-
.../aws/kinesis/KinesisProcessorUtils.java | 4 +-
.../nifi-aws-bundle/nifi-aws-kinesis/pom.xml | 2 +-
.../processors/aws/kinesis/ConsumeKinesis.java | 79 +-
.../processors/aws/kinesis/ConsumeKinesisIT.java | 41 +-
.../processors/aws/kinesis/ConsumeKinesisTest.java | 10 +
.../nifi-aws-bundle/nifi-aws-processors/pom.xml | 4 +-
.../aws/cloudwatch/PutCloudWatchMetric.java | 3 +
.../strategies/AbstractCredentialsStrategy.java | 1 -
.../AWSCredentialsProviderControllerService.java | 2 -
.../nifi/processors/aws/dynamodb/PutDynamoDB.java | 3 +-
.../processors/aws/dynamodb/PutDynamoDBRecord.java | 3 +-
.../aws/kinesis/firehose/PutKinesisFirehose.java | 4 +-
.../aws/kinesis/stream/PutKinesisStream.java | 3 +-
.../record/AbstractKinesisRecordProcessor.java | 2 +-
.../record/converter/RecordConverterWrapper.java | 1 -
.../nifi/processors/aws/s3/CopyS3Object.java | 2 -
.../org/apache/nifi/processors/aws/s3/ListS3.java | 11 +-
.../apache/nifi/processors/aws/s3/PutS3Object.java | 8 +-
.../apache/nifi/processors/aws/s3/TagS3Object.java | 1 -
.../s3/encryption/StandardS3EncryptionService.java | 1 -
.../org/apache/nifi/processors/aws/sns/PutSNS.java | 2 -
.../aws/cloudwatch/ITPutCloudWatchMetric.java | 2 +-
.../aws/cloudwatch/MockPutCloudWatchMetric.java | 1 -
.../aws/cloudwatch/TestPutCloudWatchMetric.java | 1 -
...entialsProviderControllerServiceStrategies.java | 2 -
.../aws/dynamodb/PutDynamoDBRecordTest.java | 1 -
.../kinesis/stream/TestConsumeKinesisStream.java | 2 -
.../nifi/processors/aws/s3/AbstractS3IT.java | 1 -
.../nifi/processors/aws/s3/ITPutS3Object.java | 38 +-
.../nifi/processors/aws/s3/TestFetchS3Object.java | 1 -
.../apache/nifi/processors/aws/s3/TestListS3.java | 94 +-
.../TestStandardS3EncryptionServiceValidation.java | 7 -
.../nifi/processors/aws/s3/util/S3UtilTest.java | 5 -
.../nifi/processors/aws/sqs/ITDeleteSQS.java | 1 -
.../nifi/processors/aws/region/RegionUtilTest.java | 1 -
nifi-extension-bundles/nifi-aws-bundle/pom.xml | 2 +-
.../nifi-azure-processors/pom.xml | 11 +-
.../azure/data/explorer/PutAzureDataExplorer.java | 1 +
.../azure/eventhub/ConsumeAzureEventHub.java | 95 +-
.../azure/eventhub/GetAzureEventHub.java | 12 +-
.../azure/eventhub/PutAzureEventHub.java | 12 +-
.../azure/eventhub/utils/AzureEventHubUtils.java | 98 +-
.../azure/storage/CopyAzureBlobStorage_v12.java | 11 +-
.../azure/storage/PutAzureDataLakeStorage.java | 2 +-
.../queue/AbstractAzureQueueStorage_v12.java | 11 +-
.../azure/storage/utils/AzureStorageUtils.java | 12 +-
.../storage/utils/BlobServiceClientFactory.java | 14 +-
.../utils/DataLakeServiceClientFactory.java | 4 +
.../StandardAzureCredentialsControllerService.java | 30 +-
...andardAzureIdentityFederationTokenProvider.java | 135 +
.../data/explorer/StandardKustoIngestService.java | 9 +-
.../storage/ADLSCredentialsControllerService.java | 9 +
.../ADLSCredentialsControllerServiceLookup.java | 2 +-
...rageCredentialsControllerServiceLookup_v12.java | 2 +-
...ureStorageCredentialsControllerService_v12.java | 14 +-
.../util/AzureWorkloadIdentityCredentialUtils.java | 130 +
.../AzureEventHubAuthenticationStrategy.java | 3 +-
.../azure/eventhubs/AzureEventHubComponent.java | 9 +
.../BlobStorageAuthenticationStrategy.java | 3 +-
.../org.apache.nifi.controller.ControllerService | 1 +
.../additionalDetails.md | 55 +
.../additionalDetails.md | 8 +-
.../azure/eventhub/GetAzureEventHubTest.java | 23 +
.../azure/eventhub/PutAzureEventHubTest.java | 23 +
.../azure/eventhub/TestConsumeAzureEventHub.java | 48 +-
.../storage/TestClientSideEncryptionSupport.java | 32 +-
.../azure/MockIdentityFederationTokenProvider.java | 21 +-
...tStandardAzureCredentialsControllerService.java | 40 +-
...andardAzureIdentityFederationTokenProvider.java | 94 +
.../TestADLSCredentialsControllerService.java | 44 +
...ureStorageCredentialsControllerService_v12.java | 48 +
.../TestAzureWorkloadIdentityCredentialUtils.java | 125 +
.../devops/AzureDevOpsFlowRegistryClient.java | 1 -
.../AzureLogAnalyticsProvenanceReportingTask.java | 4 +-
.../nifi/reporting/azure/loganalytics/Metric.java | 1 -
.../azure/loganalytics/MetricsBuilder.java | 18 +-
.../api/AzureLogAnalyticsMetricsFactory.java | 1 -
.../TestAzureLogAnalyticsReportingTask.java | 2 -
...a => AzureIdentityFederationTokenProvider.java} | 20 +-
.../azure/data/explorer/KustoIngestService.java | 7 +
.../azure/storage/ADLSCredentialsDetails.java | 18 +-
.../AzureStorageCredentialsDetails_v12.java | 37 +-
.../azure/storage/AzureStorageCredentialsType.java | 3 +-
.../box/UpdateBoxFileMetadataInstance.java | 1 -
.../nifi/processors/box/AbstractBoxFileTest.java | 17 +-
.../box/FetchBoxFileRepresentationTest.java | 1 -
.../nifi/processors/box/FetchBoxFileTest.java | 6 -
.../nifi/processors/box/ListBoxFileTest.java | 1 -
.../apache/nifi/processors/box/PutBoxFileTest.java | 1 -
.../JsonConfigBasedBoxClientService.java | 1 -
.../org/apache/nifi/cdc/event/BaseEventInfo.java | 2 -
.../java/org/apache/nifi/cdc/event/EventInfo.java | 1 -
.../nifi/cdc/event/io/AbstractEventWriter.java | 2 +-
.../org/apache/nifi/cdc/event/io/EventWriter.java | 2 +-
.../nifi-cdc-mysql-processors/pom.xml | 2 +-
.../mysql/event/CommitTransactionEventInfo.java | 1 -
.../cdc/mysql/processors/CaptureChangeMySQL.java | 10 +-
.../apache/nifi/cdc/mysql/MockBinlogClient.java | 1 -
.../mysql/processors/CaptureChangeMySQLTest.java | 5 +-
.../nifi-compress-processors/pom.xml | 2 +-
.../schema/AntlrProtobufMessageSchemaParser.java | 1 -
.../ConfluentProtobufMessageNameResolver.java | 2 -
.../ConfluentProtobufMessageNameResolverTest.java | 2 -
.../schemaregistry/ConfluentSchemaRegistry.java | 2 -
.../client/CachingSchemaRegistryClient.java | 1 -
.../client/RestSchemaRegistryClient.java | 1 -
.../nifi-couchbase-nar/pom.xml | 5 +
.../couchbase/AbstractCouchbaseProcessor.java | 22 +-
.../nifi/processors/couchbase/PutCouchbase.java | 2 -
.../couchbase/AbstractCouchbaseProcessorTest.java | 41 +
.../processors/couchbase/GetCouchbaseTest.java | 71 +-
.../processors/couchbase/PutCouchbaseTest.java | 48 +-
.../nifi/services/couchbase/CouchbaseClient.java | 11 +
...ory.java => CouchbaseCasMismatchException.java} | 9 +-
...egory.java => CouchbaseDocExistsException.java} | 9 +-
...ory.java => CouchbaseDocNotFoundException.java} | 9 +-
.../couchbase/exception/CouchbaseException.java | 2 +-
...seContext.java => CouchbaseLookupInResult.java} | 2 +-
.../nifi-couchbase-services}/pom.xml | 40 +-
.../couchbase/AbstractCouchbaseService.java | 93 +
.../couchbase/CouchbaseKeyValueLookupService.java | 85 +
.../couchbase/CouchbaseMapCacheClient.java | 209 +
.../couchbase/CouchbaseRecordLookupService.java | 103 +
.../org.apache.nifi.controller.ControllerService | 5 +-
.../couchbase/AbstractCouchbaseServiceTest.java} | 26 +-
.../CouchbaseKeyValueLookupServiceTest.java | 98 +
.../couchbase/CouchbaseMapCacheClientTest.java | 116 +
.../CouchbaseRecordLookupServiceTest.java | 112 +
.../nifi-couchbase-standard-services/pom.xml | 2 +-
.../couchbase/StandardCouchbaseClient.java | 139 +-
.../StandardCouchbaseConnectionService.java | 13 +-
...uchbaseClient.java => CouchbaseClientTest.java} | 84 +-
.../nifi-couchbase-bundle/pom.xml | 1 +
.../nifi/processors/dropbox/ListDropbox.java | 1 -
.../nifi/processors/dropbox/PutDropboxTest.java | 1 -
.../elasticsearch/ElasticSearchClientService.java | 1 -
.../nifi-elasticsearch-client-service/pom.xml | 2 +-
.../elasticsearch/ElasticSearchLookupService.java | 4 +-
.../integration/ElasticSearchClientService_IT.java | 71 +-
.../AbstractJsonQueryElasticsearch.java | 2 +-
.../elasticsearch/AbstractPutElasticsearch.java | 4 +-
.../elasticsearch/ConsumeElasticsearch.java | 2 +-
.../elasticsearch/ElasticsearchRestProcessor.java | 4 +-
.../elasticsearch/JsonQueryElasticsearch.java | 2 +-
.../PaginatedJsonQueryElasticsearch.java | 2 +-
.../elasticsearch/PutElasticsearchRecord.java | 2 +-
.../elasticsearch/SearchElasticsearch.java | 2 +-
.../PaginatedJsonQueryElasticsearchTest.java | 2 +-
.../elasticsearch/PutElasticsearchJsonTest.java | 1 -
.../elasticsearch/PutElasticsearchRecordTest.java | 1 -
.../nifi-elasticsearch-bundle/pom.xml | 2 +-
.../nifi-email-processors/pom.xml | 2 +-
.../processors/email/ExtractEmailAttachments.java | 2 +-
.../processors/email/TestExtractEmailHeaders.java | 1 -
.../apache/nifi/processors/AbstractEnrichIP.java | 4 +-
.../org/apache/nifi/processors/ISPEnrichIP.java | 2 -
.../nifi/processors/TestGeoEnrichIPRecord.java | 1 -
.../apache/nifi/processors/TestISPEnrichIP.java | 4 -
.../evtx/parser/bxml/value/SIDTypeNode.java | 10 +-
.../org/apache/nifi/processor/util/bin/Bin.java | 2 +-
.../apache/nifi/processor/util/bin/BinFiles.java | 8 +-
.../apache/nifi/processor/util/bin/BinManager.java | 2 +-
.../processor/util/bin/BinProcessingResult.java | 4 +-
.../nifi/dbcp/AbstractDBCPConnectionPool.java | 1 -
.../nifi/dbcp/utils/DefaultDataSourceValues.java | 1 -
.../processor/util/listen/EventBatcherTest.java | 4 +-
.../ByteArrayMessageNettyEventServerFactory.java | 1 -
.../util/file/transfer/FetchFileTransfer.java | 4 +-
.../processors/hadoop/AbstractHadoopProcessor.java | 1 -
.../processors/hadoop/ExtendedConfiguration.java | 8 +-
.../processor/util/list/AbstractListProcessor.java | 1 -
.../util/list/ListProcessorTestWatcher.java | 2 +-
.../nifi/processor/util/list/ListableEntity.java | 1 -
.../processor/util/pattern/PartialFunctions.java | 1 -
.../nifi/processor/util/pattern/PutGroup.java | 2 -
.../java/org/apache/nifi/avro/AvroTypeUtil.java | 2 -
.../SchemaRegistryRecordSetWriter.java | 2 +-
.../org/apache/nifi/avro/TestAvroTypeUtil.java | 2 -
.../processors/hadoop/AbstractFetchHDFSRecord.java | 2 -
.../processors/hadoop/AbstractPutHDFSRecord.java | 13 +-
.../nifi/json/AbstractJsonRowRecordReader.java | 4 -
.../apache/nifi/json/JsonPathRowRecordReader.java | 1 -
.../apache/nifi/json/JsonTreeRowRecordReader.java | 1 -
.../java/org/apache/nifi/json/WriteJsonResult.java | 3 -
.../serialization/record/MockCsvRecordWriter.java | 1 -
.../inference/HierarchicalSchemaInference.java | 1 -
.../java/org/apache/nifi/csv/CSVValidators.java | 1 -
.../schema/validation/StandardValidationError.java | 1 -
.../validation/TestStandardSchemaValidator.java | 5 -
.../provenance/ParentProcessGroupSearchNode.java | 1 -
.../util/provenance/ProvenanceEventConsumer.java | 2 -
.../syslog/keyproviders/SimpleKeyProvider.java | 1 -
.../keyproviders/SyslogPrefixedKeyProvider.java | 1 -
.../syslog/BaseStrictSyslog5424ParserTest.java | 1 -
.../nifi-gcp-bundle/nifi-gcp-processors/pom.xml | 2 +-
.../nifi/processors/gcp/AbstractGCPProcessor.java | 1 -
.../nifi/processors/gcp/bigquery/PutBigQuery.java | 1 +
.../processors/gcp/drive/FetchGoogleDrive.java | 3 -
.../processors/gcp/storage/DeleteGCSObject.java | 1 -
.../nifi/processors/gcp/storage/ListGCSBucket.java | 2 -
.../nifi/processors/gcp/storage/PutGCSObject.java | 3 -
.../processors/gcp/storage/StorageAttributes.java | 1 -
.../apache/nifi/processors/gcp/storage/Util.java | 1 -
.../vision/AbstractStartGcpVisionOperation.java | 1 -
.../processors/gcp/bigquery/PutBigQueryIT.java | 1 -
.../processors/gcp/bigquery/PutBigQueryTest.java | 4 -
.../factory/CredentialsFactoryTest.java | 1 -
.../gcp/drive/AbstractGoogleDriveIT.java | 1 -
.../gcp/drive/AbstractGoogleDriveTest.java | 1 -
.../processors/gcp/drive/ListGoogleDriveIT.java | 22 +-
.../processors/gcp/drive/PutGoogleDriveIT.java | 1 -
.../processors/gcp/pubsub/PublishGCPubSubTest.java | 1 -
.../gcp/storage/DeleteGCSObjectTest.java | 2 -
.../processors/gcp/storage/FetchGCSObjectIT.java | 1 -
.../processors/gcp/storage/FetchGCSObjectTest.java | 4 -
.../processors/gcp/storage/ListGCSBucketIT.java | 4 -
.../processors/gcp/storage/PutGCSObjectIT.java | 1 -
.../processors/gcp/storage/PutGCSObjectTest.java | 3 -
nifi-extension-bundles/nifi-gcp-bundle/pom.xml | 2 +-
.../nifi/processors/geohash/GeohashRecord.java | 20 +-
.../nifi/processors/graph/ExecuteGraphQuery.java | 1 -
.../processors/graph/ExecuteGraphQueryRecord.java | 14 +-
.../nifi-graph-test-clients/pom.xml | 2 +-
.../apache/commons/lang/UnhandledException.java | 1 -
.../nifi-neo4j-cypher-service/pom.xml | 2 +-
.../nifi/graph/ITNeo4JCypherExecutorNoSSL.java | 2 +-
.../apache/nifi/graph/TinkerpopClientService.java | 3 -
.../processors/groovyx/ExecuteGroovyScript.java | 58 +-
.../groovyx/flow/ProcessSessionWrap.java | 37 +-
.../groovyx/ExecuteGroovyScriptTest.java | 5 +-
.../hadoop/CreateHadoopSequenceFile.java | 2 +-
.../apache/nifi/processors/hadoop/DeleteHDFS.java | 8 +-
.../FlowFileStreamUnpackerSequenceFileWriter.java | 2 +-
.../nifi/processors/hadoop/GetHDFSFileInfo.java | 35 +-
.../processors/hadoop/inotify/GetHDFSEvents.java | 2 +-
.../processors/hadoop/util/SequenceFileWriter.java | 2 +-
.../nifi/processors/hadoop/MoveHDFSTest.java | 2 +-
.../apache/nifi/processors/hadoop/PutHDFSTest.java | 8 +-
.../hadoop/TestCreateHadoopSequenceFile.java | 3 -
.../nifi/processors/hadoop/TestDeleteHDFS.java | 8 +-
.../processors/hadoop/TestGetHDFSFileInfo.java | 1 -
.../nifi/processors/hadoop/TestListHDFS.java | 6 +-
.../processors/hadoop/util/MockFileSystem.java | 3 +-
.../hadoop/util/TestFileStatusIterator.java | 299 +-
.../cache/IMapBasedHazelcastCacheTest.java | 1 -
.../ExternalHazelcastCacheManagerTest.java | 1 -
.../nifi-iceberg-parquet-writer/pom.xml | 2 +-
.../nifi-iotdb-processors/pom.xml | 2 +-
.../org/apache/nifi/processors/AbstractIoTDB.java | 7 +
.../org/apache/nifi/processors/PutIoTDBRecord.java | 1 +
nifi-extension-bundles/nifi-iotdb-bundle/pom.xml | 2 +-
.../nifi-jms-bundle/nifi-jms-processors/pom.xml | 2 +-
.../nifi/jms/cf/JMSConnectionFactoryHandler.java | 70 +-
.../nifi/jms/cf/JMSConnectionFactoryProvider.java | 31 +
.../jms/cf/JndiJmsConnectionFactoryHandler.java | 1 -
.../org/apache/nifi/jms/processors/ConsumeJMS.java | 2 +-
.../apache/nifi/jms/processors/JMSConsumer.java | 4 -
.../apache/nifi/jms/processors/JMSPublisher.java | 1 -
.../org/apache/nifi/jms/processors/JMSWorker.java | 1 -
.../jms/cf/JMSConnectionFactoryProviderTest.java | 264 ++
.../processors/jolt/AbstractJoltTransform.java | 1 -
.../processors/jolt/TestJoltTransformJSON.java | 8 +-
.../web/standard/api/AbstractStandardResource.java | 1 -
.../standard/api/processor/ProcessorWebUtils.java | 2 -
.../transformjson/dto/JoltSpecificationDTO.java | 1 -
.../api/processor/TestProcessorResource.java | 2 -
.../transformjson/TestTransformJSONResource.java | 1 -
.../apache/nifi/jolt/util/TransformFactory.java | 1 -
.../nifi/processors/jslt/JSLTTransformJSON.java | 3 +-
.../kafka/processors/ConsumeKafkaRebalanceIT.java | 13 +-
.../apache/nifi/kafka/processors/ConsumeKafka.java | 1 -
.../apache/nifi/kafka/processors/PublishKafka.java | 2 +-
...apperRecordStreamKafkaMessageConverterTest.java | 2 -
.../nifi-kafka-service-aws/pom.xml | 2 +-
.../nifi-kafka-service-shared/pom.xml | 2 +-
.../service/consumer/Kafka3ConsumerService.java | 1 -
.../service/Kafka3ConnectionServiceBaseIT.java | 1 -
.../consumer/Kafka3ConsumerServiceTest.java | 18 +-
nifi-extension-bundles/nifi-kafka-bundle/pom.xml | 2 +-
.../processors/image/ExtractImageMetadata.java | 2 +-
.../processors/media/ExtractMediaMetadata.java | 6 +-
.../processors/image/ExtractImageMetadataTest.java | 2 -
.../apache/nifi/mongodb/MongoDBClientService.java | 1 -
.../processors/mongodb/AbstractMongoProcessor.java | 2 +-
.../apache/nifi/processors/mongodb/GetMongo.java | 1 -
.../nifi/processors/mongodb/GetMongoRecord.java | 1 -
.../mongodb/gridfs/AbstractGridFSProcessor.java | 2 +-
.../nifi/processors/mongodb/gridfs/PutGridFS.java | 2 +-
.../nifi/processors/mongodb/DeleteMongoIT.java | 1 -
.../processors/mongodb/MongoWriteTestBase.java | 12 +-
.../apache/nifi/processors/mongodb/PutMongoIT.java | 13 +-
.../nifi/processors/mongodb/PutMongoRecordIT.java | 1 -
.../nifi/mongodb/MongoDBControllerService.java | 1 -
.../apache/nifi/mongodb/MongoDBLookupService.java | 28 +-
nifi-extension-bundles/nifi-mongodb-bundle/pom.xml | 2 +-
.../mqtt/common/AbstractMQTTProcessor.java | 2 -
.../nifi/processors/mqtt/common/MqttConstants.java | 2 -
.../nifi/processors/mqtt/TestConsumeMQTT.java | 1 -
.../nifi/processors/network/ParseNetflowv5.java | 4 +-
.../opentelemetry/server/HttpRequestHandler.java | 1 -
.../nifi-opentelemetry-bundle/pom.xml | 2 +-
.../parquet/CalculateParquetOffsets.java | 2 +-
.../apache/nifi/parquet/TestParquetProcessor.java | 1 -
.../nifi/processors/parquet/FetchParquetTest.java | 2 -
.../nifi-protobuf-services/pom.xml | 4 +-
.../services/protobuf/ProtobufSchemaCompiler.java | 2 -
.../services/protobuf/StandardProtobufReader.java | 1 -
.../nifi/services/protobuf/ProtoTestUtil.java | 1 -
.../protobuf/StandardProtobufReaderTestBase.java | 3 -
.../nifi/services/protobuf/TestProtobufReader.java | 3 -
.../protobuf/TestStandardProtobufReader.java | 1 -
.../java/org/apache/nifi/py4j/PythonProcess.java | 2 -
.../org/apache/nifi/py4j/StandardPythonBridge.java | 1 -
.../nifi/py4j/StandardPythonProcessorBridge.java | 2 -
.../nifi/py4j/client/JavaObjectBindings.java | 2 -
.../apache/nifi/py4j/client/NiFiPythonGateway.java | 4 +-
.../py4j/client/PythonProxyInvocationHandler.java | 1 -
.../python/processor/FlowFileTransformProxy.java | 2 -
.../python/processor/PythonProcessorProxy.java | 5 -
.../python/processor/RecordTransformProxy.java | 4 -
.../nifi/py4j/client/TestNiFiPythonGateway.java | 1 -
.../PythonControllerInteractionIT.java | 9 -
.../nifi/redis/processor/PutRedisHashRecord.java | 4 +
.../redis/service/RedisConnectionPoolService.java | 9 +-
.../org/apache/nifi/redis/state/RedisStateMap.java | 1 -
.../nifi/redis/state/ITRedisStateProvider.java | 2 -
.../testcontainers/RedisSentinelContainer.java | 2 -
.../org/apache/nifi/redis/RedisConnectionPool.java | 8 +
.../org/apache/nifi/redis/util/RedisUtils.java | 1 -
nifi-extension-bundles/nifi-redis-bundle/pom.xml | 4 +-
.../services/AvroSchemaRegistry.java | 1 -
.../nifi-salesforce-processors/pom.xml | 2 +-
.../processors/salesforce/PutSalesforceObject.java | 38 +-
.../salesforce/util/TestRecordExtender.java | 227 +-
.../lookup/script/BaseScriptedLookupService.java | 16 +-
.../nifi/processors/script/ExecuteScript.java | 4 +-
.../processors/script/InvokeScriptedProcessor.java | 6 +-
.../processors/script/ScriptedPartitionRecord.java | 2 +-
.../processors/script/ScriptedRecordProcessor.java | 1 -
.../processors/script/ScriptedRouterProcessor.java | 2 +-
.../script/engine/ClojureScriptEngine.java | 7 +-
.../record/script/ScriptedRecordSetWriter.java | 3 -
.../record/sink/script/ScriptedRecordSink.java | 1 -
.../script/AbstractScriptedControllerService.java | 4 +-
.../nifi/script/ScriptingComponentHelper.java | 9 +-
.../nifi/script/ScriptingComponentUtils.java | 4 +-
.../nifi/processors/script/BaseScriptTest.java | 2 +-
.../processors/script/ExecuteScriptGroovyTest.java | 10 +-
.../nifi/processors/script/TestExecuteClojure.java | 10 +-
.../nifi/processors/script/TestExecuteGroovy.java | 27 +-
.../nifi/processors/script/TestInvokeGroovy.java | 24 +-
.../script/TestScriptedPartitionRecord.java | 1 -
.../script/TestScriptedTransformRecord.java | 3 -
.../apache/nifi/processors/shopify/GetShopify.java | 2 -
.../nifi/processors/shopify/GetShopifyTest.java | 457 +-
.../TestSiteToSiteProvenanceReportingTask.java | 5 -
.../apache/nifi/processors/slack/ConsumeSlack.java | 6 -
.../apache/nifi/processors/slack/ListenSlack.java | 11 +-
.../apache/nifi/processors/slack/PublishSlack.java | 19 +-
.../processors/slack/consume/ConsumeChannel.java | 100 +-
.../nifi/processors/slack/TestConsumeSlack.java | 10 +-
.../org/apache/nifi/processors/smb/GetSmbFile.java | 2 -
.../org/apache/nifi/processors/smb/PutSmbFile.java | 4 +-
.../apache/nifi/processors/smb/FetchSmbTest.java | 1 -
.../apache/nifi/processors/smb/GetSmbFileTest.java | 3 -
.../nifi/services/smb/SmbjClientService.java | 1 -
.../nifi/services/smb/SmbjClientServiceIT.java | 1 -
.../apache/nifi/snmp/dto/SNMPResponseStatus.java | 73 +-
.../exception/InvalidAuthProtocolException.java | 1 -
.../org/apache/nifi/snmp/processors/GetSNMP.java | 10 +-
.../nifi/snmp/processors/ListenTrapSNMP.java | 1 -
.../apache/nifi/snmp/processors/SendTrapSNMP.java | 3 +
.../processors/properties/V1TrapProperties.java | 1 -
.../testrunners/SNMPV1TestRunnerFactory.java | 1 -
.../apache/nifi/snmp/operations/SNMPRequestIT.java | 2 -
.../nifi/snmp/operations/SNMPTrapReceiverTest.java | 365 +-
.../snmp/processors/AbstractSNMPProcessorTest.java | 314 +-
.../apache/nifi/snmp/processors/TrapSNMPIT.java | 1 -
.../apache/nifi/snmp/utils/JsonUsmReaderTest.java | 126 +-
.../org/apache/nifi/snmp/utils/SNMPUtilsTest.java | 2 +-
.../snowflake/PutSnowflakeInternalStage.java | 1 +
.../nifi-snowflake-bundle/pom.xml | 2 +-
.../nifi/processors/twitter/ConsumeTwitter.java | 1 -
.../processors/twitter/TweetStreamService.java | 1 -
.../processors/twitter/TestConsumeTwitter.java | 1 -
.../apache/nifi/processors/splunk/GetSplunk.java | 8 +-
.../nifi/processors/splunk/PutSplunkHTTP.java | 1 +
.../nifi/processors/splunk/SplunkAPICall.java | 12 +-
.../nifi/processors/splunk/TestGetSplunk.java | 1 -
.../nifi/processors/splunk/TestPutSplunk.java | 1 -
.../datasources/ConnectionStatusDataSource.java | 3 +-
.../ConnectionStatusPredictionDataSource.java | 3 +-
.../sql/datasources/GroupStatusCache.java | 1 -
.../datasources/ProcessGroupStatusDataSource.java | 4 +-
.../sql/datasources/ProcessorStatusDataSource.java | 4 +-
.../sql/datasources/ProvenanceDataSource.java | 1 -
.../reporting/sql/TestQueryNiFiReportingTask.java | 1 -
.../nifi/parameter/DatabaseParameterProvider.java | 4 +-
.../processors/standard/AbstractExecuteSQL.java | 24 +-
.../standard/AbstractQueryDatabaseTable.java | 6 +-
.../standard/AbstractSyslogProcessor.java | 2 -
.../nifi/processors/standard/AttributesToCSV.java | 3 +-
.../nifi/processors/standard/AttributesToJSON.java | 2 -
.../nifi/processors/standard/CompressContent.java | 1 -
.../nifi/processors/standard/ControlRate.java | 8 +-
.../processors/standard/ConvertCharacterSet.java | 2 +-
.../apache/nifi/processors/standard/CountText.java | 1 -
.../standard/CryptographicHashContent.java | 4 +-
.../apache/nifi/processors/standard/DebugFlow.java | 50 +-
.../nifi/processors/standard/DeleteSFTP.java | 2 +-
.../nifi/processors/standard/DistributeLoad.java | 2 +-
.../nifi/processors/standard/EnforceOrder.java | 10 +-
.../nifi/processors/standard/ExecuteProcess.java | 3 -
.../nifi/processors/standard/ExecuteSQL.java | 2 +-
.../nifi/processors/standard/ExecuteSQLRecord.java | 3 +-
.../processors/standard/ExecuteStreamCommand.java | 20 +-
.../nifi/processors/standard/ExtractText.java | 1 -
.../standard/FetchDistributedMapCache.java | 3 +-
.../nifi/processors/standard/FilterAttribute.java | 1 -
.../nifi/processors/standard/GenerateFlowFile.java | 2 +-
.../processors/standard/GenerateTableFetch.java | 1 -
.../processors/standard/HandleHttpRequest.java | 2 -
.../nifi/processors/standard/InvokeHTTP.java | 2 +-
.../processors/standard/ListDatabaseTables.java | 5 +-
.../apache/nifi/processors/standard/ListFile.java | 3 -
.../nifi/processors/standard/ListenHTTP.java | 4 +-
.../nifi/processors/standard/ListenUDPRecord.java | 20 +-
.../nifi/processors/standard/LogAttribute.java | 16 +-
.../nifi/processors/standard/LookupRecord.java | 6 -
.../nifi/processors/standard/MergeContent.java | 4 +-
.../nifi/processors/standard/ModifyBytes.java | 2 +-
.../nifi/processors/standard/MonitorActivity.java | 8 +-
.../apache/nifi/processors/standard/Notify.java | 8 +-
.../nifi/processors/standard/PartitionRecord.java | 3 +-
.../processors/standard/PutDatabaseRecord.java | 11 +-
.../standard/PutDistributedMapCache.java | 12 +-
.../apache/nifi/processors/standard/PutEmail.java | 1 -
.../apache/nifi/processors/standard/PutFile.java | 2 +-
.../apache/nifi/processors/standard/PutRecord.java | 2 +-
.../apache/nifi/processors/standard/PutSQL.java | 17 +-
.../standard/QueryDatabaseTableRecord.java | 3 +-
.../nifi/processors/standard/QueryRecord.java | 2 -
.../processors/standard/RenameRecordField.java | 4 -
.../nifi/processors/standard/ReplaceText.java | 2 -
.../nifi/processors/standard/RouteOnAttribute.java | 5 +-
.../apache/nifi/processors/standard/RouteText.java | 5 +-
.../nifi/processors/standard/SampleRecord.java | 2 +-
.../apache/nifi/processors/standard/SplitJson.java | 10 +-
.../apache/nifi/processors/standard/TailFile.java | 4 +-
.../nifi/processors/standard/TransformXml.java | 34 +-
.../nifi/processors/standard/UnpackContent.java | 1 -
.../nifi/processors/standard/UpdateCounter.java | 2 +-
.../processors/standard/UpdateDatabaseTable.java | 6 +-
.../nifi/processors/standard/ValidateCsv.java | 8 +-
.../nifi/processors/standard/ValidateJson.java | 1 -
.../nifi/processors/standard/ValidateRecord.java | 3 +-
.../nifi/processors/standard/ValidateXml.java | 2 +-
.../processors/standard/WaitNotifyProtocol.java | 1 -
.../standard/calcite/RecordPathFunction.java | 2 -
.../standard/calcite/RecordPathFunctions.java | 1 -
.../impl/RemoveUnderscoreAndSpaceNormalizer.java | 1 -
.../db/impl/RemoveUnderscoreNormalizer.java | 1 -
.../enrichment/IndexCorrelatedJoinStrategy.java | 1 -
.../enrichment/InsertRecordFieldsJoinStrategy.java | 1 -
.../standard/enrichment/SqlJoinCache.java | 1 -
.../enrichment/SqlJoinCalciteParameters.java | 1 -
.../standard/ftp/filesystem/VirtualFtpFile.java | 4 +-
.../standard/merge/AttributeStrategyUtil.java | 1 -
.../nifi/processors/standard/merge/RecordBin.java | 2 -
.../standard/merge/RecordBinManager.java | 6 -
.../standard/servlets/ListenHTTPServlet.java | 3 -
.../nifi/processors/standard/util/FTPTransfer.java | 1 -
.../apache/nifi/queryrecord/RecordDataSource.java | 2 -
.../nifi/processors/standard/CountTextTest.java | 25 +-
.../nifi/processors/standard/FTPCharsetIT.java | 26 +-
.../processors/standard/PutDatabaseRecordIT.java | 16 +-
.../standard/QueryDatabaseTableRecordTest.java | 32 +-
.../standard/QueryDatabaseTableTest.java | 32 +-
.../processors/standard/TestAttributesToCSV.java | 183 +-
.../processors/standard/TestAttributesToJSON.java | 16 +-
.../processors/standard/TestCompressContent.java | 3 -
.../nifi/processors/standard/TestControlRate.java | 24 +-
.../processors/standard/TestConvertRecord.java | 108 +-
.../processors/standard/TestEvaluateXQuery.java | 122 +-
.../processors/standard/TestExecuteProcess.java | 1 -
.../nifi/processors/standard/TestExecuteSQL.java | 2 +-
.../processors/standard/TestExecuteSQLRecord.java | 8 +-
.../standard/TestExecuteStreamCommand.java | 1 -
.../nifi/processors/standard/TestExtractGrok.java | 1 -
.../nifi/processors/standard/TestExtractText.java | 2 +-
.../standard/TestExtractTextNamedGroups.java | 2 +-
.../apache/nifi/processors/standard/TestFTP.java | 4 +-
.../standard/TestFetchDistributedMapCache.java | 2 -
.../nifi/processors/standard/TestFetchFile.java | 1 -
.../processors/standard/TestFilterAttribute.java | 1 -
.../processors/standard/TestGenerateFlowFile.java | 1 -
.../standard/TestGenerateTableFetch.java | 38 +-
.../processors/standard/TestJoinEnrichment.java | 3 -
.../nifi/processors/standard/TestListFile.java | 3 +-
.../nifi/processors/standard/TestListenUDP.java | 1 -
.../nifi/processors/standard/TestLogAttribute.java | 36 +-
.../nifi/processors/standard/TestLookupRecord.java | 5 -
.../nifi/processors/standard/TestMergeContent.java | 1 -
.../nifi/processors/standard/TestMergeRecord.java | 3 -
.../processors/standard/TestMonitorActivity.java | 24 +-
.../nifi/processors/standard/TestNotify.java | 1 -
.../processors/standard/TestPackageFlowFile.java | 30 +-
.../processors/standard/TestPartitionRecord.java | 3 -
.../standard/TestPutDistributedMapCache.java | 1 -
.../nifi/processors/standard/TestPutEmail.java | 6 +-
.../nifi/processors/standard/TestPutFile.java | 1 -
.../nifi/processors/standard/TestPutSQL.java | 5 -
.../nifi/processors/standard/TestPutTCP.java | 3 +-
.../nifi/processors/standard/TestQueryRecord.java | 11 -
.../processors/standard/TestRenameRecordField.java | 6 +-
.../nifi/processors/standard/TestReplaceText.java | 47 +-
.../standard/TestReplaceTextWithMapping.java | 2 +-
.../processors/standard/TestRouteOnAttribute.java | 2 +-
.../nifi/processors/standard/TestRouteText.java | 6 -
.../nifi/processors/standard/TestSplitRecord.java | 1 -
.../nifi/processors/standard/TestSplitText.java | 2 -
.../nifi/processors/standard/TestTailFile.java | 8 -
.../nifi/processors/standard/TestTransformXml.java | 18 +-
.../nifi/processors/standard/TestUpdateRecord.java | 119 +-
.../processors/standard/TestValidateRecord.java | 2 -
.../apache/nifi/processors/standard/TestWait.java | 2 +-
.../TestRecordResultSetOutputStreamCallback.java | 2 +-
.../db/impl/TestMSSQL2008DatabaseAdapter.java | 16 +-
.../standard/db/impl/TestMSSQLDatabaseAdapter.java | 16 +-
.../db/impl/TestOracle12DatabaseAdapter.java | 13 +-
.../db/impl/TestOracleDatabaseAdapter.java | 12 +-
.../processors/standard/hash/HashServiceTest.java | 148 +-
.../controller/ControllerStatusReportingTask.java | 1 -
.../org/apache/nifi/controller/MonitorMemory.java | 10 +-
.../rules/AbstractFlowAnalaysisRuleTest.java | 1 -
.../nifi-standard-bundle/pom.xml | 2 +-
.../java/org/apache/nifi/dbcp/DBCPValidator.java | 2 +-
.../apache/nifi/dbcp/DBCPConnectionPoolLookup.java | 2 +-
.../cache/server/codec/CacheRequestDecoder.java | 2 +-
.../nifi/kerberos/AbstractKerberosUserService.java | 1 -
.../org/apache/nifi/lookup/RestLookupService.java | 2 -
.../CommonsConfigurationLookupService.java | 1 -
.../nifi/lookup/TestCSVRecordLookupService.java | 6 +-
.../lookup/configuration2/XXEValidatorTest.java | 1 -
.../oauth2/JWTBearerOAuth2AccessTokenProvider.java | 2 +-
.../oauth2/StandardOauth2AccessTokenProvider.java | 6 +-
.../org/apache/nifi/proxy/ProxyConfiguration.java | 13 +-
.../apache/nifi/proxy/TestProxyConfiguration.java | 1 -
.../nifi/schema/inference/SchemaInferenceUtil.java | 1 -
.../schema/inference/TestFieldTypeInference.java | 2 -
.../nifi-record-serialization-services/pom.xml | 4 +-
.../main/java/org/apache/nifi/avro/AvroReader.java | 2 +-
.../org/apache/nifi/avro/AvroRecordSetWriter.java | 1 -
.../org/apache/nifi/cef/CEFSchemaInference.java | 1 -
.../java/org/apache/nifi/csv/CSVRecordReader.java | 2 -
.../main/java/org/apache/nifi/grok/GrokReader.java | 2 -
.../org/apache/nifi/grok/GrokRecordReader.java | 3 -
.../java/org/apache/nifi/json/JsonTreeReader.java | 1 -
.../java/org/apache/nifi/lookup/ReaderLookup.java | 1 -
.../apache/nifi/lookup/RecordSetWriterLookup.java | 1 -
.../nifi/schema/inference/VolatileSchemaCache.java | 1 -
.../org/apache/nifi/syslog/Syslog5424Reader.java | 2 -
.../java/org/apache/nifi/syslog/SyslogReader.java | 1 -
.../windowsevent/WindowsEventLogRecordReader.java | 9 +-
.../java/org/apache/nifi/xml/WriteXMLResult.java | 5 +-
.../main/java/org/apache/nifi/xml/XMLReader.java | 1 -
.../java/org/apache/nifi/xml/XMLRecordReader.java | 21 +-
.../org/apache/nifi/xml/XMLRecordSetWriter.java | 10 +-
.../apache/nifi/xml/inference/XmlRecordSource.java | 6 +-
.../additionalDetails.md | 1 +
.../avro/TestWriteAvroResultWithoutSchema.java | 1 -
.../apache/nifi/csv/ITApacheCSVRecordReader.java | 14 +-
.../apache/nifi/csv/ITJacksonCSVRecordReader.java | 6 +-
.../org/apache/nifi/csv/TestCSVRecordReader.java | 23 +-
.../apache/nifi/csv/TestFastCSVRecordReader.java | 1 -
.../nifi/csv/TestJacksonCSVRecordReader.java | 2 -
.../org/apache/nifi/csv/TestWriteCSVResult.java | 2 -
.../apache/nifi/csv/TestWriteFastCSVResult.java | 3 -
.../nifi/json/TestJsonPathRowRecordReader.java | 6 -
.../apache/nifi/json/TestJsonSchemaInference.java | 6 +-
.../nifi/json/TestJsonTreeRowRecordReader.java | 5 -
.../org/apache/nifi/json/TestWriteJsonResult.java | 2 -
.../org/apache/nifi/lookup/TestReaderLookup.java | 2 +-
.../nifi/lookup/TestRecordSetWriterLookup.java | 4 +-
.../apache/nifi/syslog/TestSyslogRecordReader.java | 1 -
.../TestFreeFormTextRecordSetWriterProcessor.java | 1 -
.../apache/nifi/util/TestSchemaInferenceUtil.java | 1 -
.../org/apache/nifi/xml/TestWriteXMLResult.java | 2 -
.../apache/nifi/xml/TestWriteXMLResultUtils.java | 943 +++--
.../java/org/apache/nifi/xml/TestXMLReader.java | 33 +
.../org/apache/nifi/xml/TestXMLRecordReader.java | 3168 +++++++-------
.../apache/nifi/xml/TestXMLRecordSetWriter.java | 6 +-
.../nifi/xml/TestXMLRecordSetWriterProcessor.java | 4 -
.../nifi/yaml/TestYamlTreeRowRecordReader.java | 4 -
.../sink/lookup/RecordSinkServiceLookup.java | 2 +-
.../nifi/record/sink/TestEmailRecordSink.java | 357 +-
.../nifi/record/sink/TestHttpRecordSink.java | 2 +-
.../apache/nifi/ssl/StandardSSLContextService.java | 1 -
.../apache/nifi/ssl/StandardTlsConfiguration.java | 1 -
.../nifi-standard-shared-bom/pom.xml | 6 +-
.../analysis/AttributeRollingWindowIT.java | 6 -
.../processors/attributes/UpdateAttribute.java | 7 +-
.../update/attributes/TestUpdateAttribute.java | 1 -
.../AbstractWebSocketGatewayProcessor.java | 1 -
.../processors/websocket/TestConnectWebSocket.java | 3 -
.../nifi/websocket/WebSocketServerService.java | 1 -
.../nifi/websocket/jetty/JettyWebSocketClient.java | 2 -
.../nifi/websocket/jetty/JettyWebSocketServer.java | 3 -
.../event/log/ConsumeWindowsEventLogTest.java | 1 -
.../nifi/processors/workday/GetWorkdayReport.java | 4 +-
.../AbstractPolicyBasedAuthorizer.java | 1 -
.../java/org/apache/nifi/authorization/Group.java | 1 -
.../nifi/components/state/StateProvider.java | 2 -
.../org/apache/nifi/controller/Triggerable.java | 2 +-
.../nifi/controller/queue/FlowFileQueue.java | 10 +-
.../controller/repository/ContentRepository.java | 1 -
.../controller/repository/FlowFileRepository.java | 2 +-
.../controller/repository/claim/ResourceClaim.java | 1 -
.../repository/claim/ResourceClaimManager.java | 1 -
.../apache/nifi/provenance/IdentifierLookup.java | 1 -
.../nifi/provenance/ProvenanceRepository.java | 1 -
.../java/org/apache/nifi/web/ComponentDetails.java | 1 -
.../nifi/web/NiFiWebConfigurationContext.java | 1 -
.../nifi/authorization/TestAccessPolicy.java | 1 -
.../state/provider/StandardStateMap.java | 1 -
.../zookeeper/CuratorLeaderElectionManager.java | 19 +-
.../providers/zookeeper/StandardStateMap.java | 1 -
.../zookeeper/ZooKeeperStateProvider.java | 1 -
.../zookeeper/server/ZooKeeperQuorumX509Util.java | 5 +
.../zookeeper/server/ZooKeeperServerX509Util.java | 5 +
.../nifi-framework-zookeeper-bundle/pom.xml | 2 +-
.../provenance/EventIdFirstSchemaRecordWriter.java | 1 -
.../apache/nifi/provenance/IndexConfiguration.java | 1 -
.../nifi/provenance/RepositoryConfiguration.java | 1 -
.../provenance/WriteAheadProvenanceRepository.java | 1 -
.../provenance/expiration/FileRemovalAction.java | 5 +-
.../apache/nifi/provenance/index/EventIndex.java | 8 +-
.../index/lucene/ConvertEventToLuceneDocument.java | 1 -
.../provenance/index/lucene/EventIndexTask.java | 3 -
.../index/lucene/IndexDirectoryManager.java | 2 -
.../provenance/index/lucene/LuceneEventIndex.java | 2 -
.../index/lucene/MigrateDefunctIndex.java | 8 +-
.../nifi/provenance/index/lucene/QueryTask.java | 1 -
.../apache/nifi/provenance/lucene/DocsReader.java | 2 -
.../nifi/provenance/lucene/IndexingAction.java | 1 -
.../apache/nifi/provenance/lucene/LuceneUtil.java | 4 +-
.../provenance/lucene/StandardIndexManager.java | 1 -
.../schema/EventIdFirstHeaderSchema.java | 2 +-
.../provenance/schema/LookupTableEventRecord.java | 2 -
.../schema/LookupTableEventRecordFields.java | 1 -
.../serialization/CompressableRecordReader.java | 1 -
.../serialization/CompressableRecordWriter.java | 4 -
.../nifi/provenance/store/EventFileManager.java | 1 -
.../provenance/store/PartitionedEventStore.java | 3 -
.../nifi/provenance/store/RolloverState.java | 1 -
.../provenance/store/WriteAheadStorePartition.java | 10 +-
.../store/iterator/AggregateEventIterator.java | 1 -
.../provenance/store/iterator/EventIterator.java | 1 -
.../SelectiveRecordReaderEventIterator.java | 1 -
.../nifi/provenance/util/DirectoryUtils.java | 1 -
.../provenance/AbstractTestRecordReaderWriter.java | 3 -
.../provenance/TestSchemaRecordReaderWriter.java | 3 -
.../index/lucene/TestIndexDirectoryManager.java | 2 -
.../provenance/lucene/TestSimpleIndexManager.java | 3 +-
.../provenance/store/TestEventFileManager.java | 3 -
.../store/TestPartitionedWriteAheadEventStore.java | 10 +-
.../nifi/provenance/toc/TestStandardTocReader.java | 2 -
.../provenance/VolatileProvenanceRepository.java | 3 +-
.../TestVolatileProvenanceRepository.java | 6 +-
.../nifi-provenance-repository-bundle/pom.xml | 2 +-
.../org/apache/nifi/python/PythonController.java | 1 -
.../apache/nifi/python/PythonProcessConfig.java | 1 -
.../questdb/StorageStatusResultProcessor.java | 1 -
.../nifi-questdb-bundle/nifi-questdb/pom.xml | 2 +-
.../questdb/rollover/KeepAllRolloverStrategy.java | 2 +-
.../java/org/apache/nifi/questdb/util/Event.java | 1 -
.../admin/service/EntityStoreAuditService.java | 1 -
.../nifi/web/api/dto/AsynchronousRequestDTO.java | 1 -
.../apache/nifi/web/api/dto/BatchSettingsDTO.java | 5 +-
.../apache/nifi/web/api/dto/ConnectableDTO.java | 1 -
.../org/apache/nifi/web/api/dto/DifferenceDTO.java | 15 +-
.../apache/nifi/web/api/dto/DocumentedTypeDTO.java | 1 -
.../apache/nifi/web/api/dto/DropRequestDTO.java | 36 +-
.../web/api/dto/FlowAnalysisRuleViolationDTO.java | 1 -
.../java/org/apache/nifi/web/api/dto/PortDTO.java | 1 -
.../org/apache/nifi/web/api/dto/ProcessorDTO.java | 1 -
.../web/api/dto/ProcessorRunStatusDetailsDTO.java | 2 -
.../apache/nifi/web/api/dto/RelationshipDTO.java | 4 +-
.../web/api/dto/RemoteProcessGroupPortDTO.java | 6 +-
.../nifi/web/api/dto/SystemDiagnosticsDTO.java | 1 -
.../web/api/dto/SystemDiagnosticsSnapshotDTO.java | 3 -
.../dto/diagnostics/JVMDiagnosticsSnapshotDTO.java | 5 -
.../diagnostics/JVMFlowDiagnosticsSnapshotDTO.java | 1 -
.../JVMSystemDiagnosticsSnapshotDTO.java | 1 -
.../dto/diagnostics/ProcessorDiagnosticsDTO.java | 1 -
.../api/dto/diagnostics/RepositoryUsageDTO.java | 1 -
.../web/api/dto/provenance/ProvenanceEventDTO.java | 4 +-
.../dto/provenance/lineage/LineageRequestDTO.java | 8 +-
.../dto/provenance/lineage/ProvenanceNodeDTO.java | 6 +-
.../apache/nifi/web/api/dto/remote/PeerDTO.java | 1 -
.../api/dto/status/ConnectionStatisticsDTO.java | 1 -
.../web/api/dto/status/ConnectionStatusDTO.java | 1 -
.../ConnectionStatusPredictionsSnapshotDTO.java | 4 +-
.../dto/status/ConnectionStatusSnapshotDTO.java | 21 +-
.../web/api/dto/status/ControllerStatusDTO.java | 2 +-
.../nifi/web/api/dto/status/PortStatusDTO.java | 4 -
.../web/api/dto/status/PortStatusSnapshotDTO.java | 8 +-
.../dto/status/ProcessGroupStatusSnapshotDTO.java | 15 +-
.../api/dto/status/ProcessorStatusSnapshotDTO.java | 8 +-
.../RemoteProcessGroupStatusSnapshotDTO.java | 5 +-
.../apache/nifi/web/api/dto/util/TimeAdapter.java | 2 -
.../nifi/web/api/entity/PortRunStatusEntity.java | 2 +-
.../nifi/web/api/entity/ProcessorEntity.java | 1 -
.../web/api/entity/RemotePortRunStatusEntity.java | 2 +-
.../api/entity/ReportingTaskRunStatusEntity.java | 2 +-
.../authorization/FileUserGroupProviderTest.java | 1 -
.../repository/SchemaRepositoryRecordSerde.java | 2 -
.../WriteAheadRepositoryRecordSerde.java | 1 -
.../StandardManagedAuthorizerTest.java | 1 -
.../resource/ProvenanceDataAuthorizable.java | 1 -
.../authorization/resource/ResourceFactory.java | 1 -
.../resource/OperationAuthorizableTest.java | 42 +-
.../cluster/coordination/ClusterCoordinator.java | 2 +-
.../coordination/node/NodeConnectionState.java | 4 +-
.../coordination/node/NodeConnectionStatus.java | 1 -
.../protocol/AbstractNodeProtocolSender.java | 13 +-
.../nifi/cluster/protocol/ConnectionResponse.java | 1 -
.../nifi/cluster/protocol/NodeIdentifier.java | 2 -
.../nifi/cluster/protocol/StandardDataFlow.java | 1 -
.../jaxb/message/AdaptedNodeIdentifier.java | 1 -
.../jaxb/message/TestJaxbProtocolUtils.java | 1 -
.../heartbeat/AbstractHeartbeatMonitor.java | 1 -
.../http/endpoints/CurrentUserEndpointMerger.java | 1 -
.../endpoints/FlowAnalysisRuleEndpointMerger.java | 1 -
.../http/endpoints/ParameterContextMerger.java | 1 -
.../endpoints/ProvenanceQueryEndpointMerger.java | 2 -
.../http/replication/RequestReplicator.java | 1 -
.../replication/StandardAsyncClusterResponse.java | 1 -
.../replication/ThreadPoolRequestReplicator.java | 8 -
.../client/StandardHttpReplicationClient.java | 2 +-
.../coordination/node/NodeClusterCoordinator.java | 2 -
.../nifi/cluster/manager/BulletinMerger.java | 2 +-
.../apache/nifi/cluster/manager/NodeResponse.java | 2 -
.../manager/ProcessorDiagnosticsEntityMerger.java | 3 -
.../apache/nifi/cluster/manager/StatusMerger.java | 9 -
.../VersionControlInformationEntityMerger.java | 1 -
.../flow/TestPopularVoteFlowElection.java | 1 -
.../heartbeat/TestAbstractHeartbeatMonitor.java | 1 -
.../TestThreadPoolRequestReplicator.java | 2 -
.../client/TestStandardHttpReplicationClient.java | 49 +
.../node/TestNodeClusterCoordinator.java | 2 -
.../RemoteProcessGroupEntityMergerTest.java | 54 +-
.../org/apache/nifi/connectable/LocalPort.java | 1 -
.../nifi/controller/StandardProcessorNode.java | 16 +-
.../nifi/controller/flow/AbstractFlowManager.java | 1 -
.../flowanalysis/AbstractFlowAnalysisRuleNode.java | 1 -
.../reporting/AbstractReportingTaskNode.java | 1 -
.../repository/AbstractRepositoryContext.java | 1 -
.../repository/StandardProcessSession.java | 30 +-
.../controller/repository/metrics/EventSum.java | 1 -
.../repository/metrics/EventSumValue.java | 1 -
.../scheduling/ConnectableProcessContext.java | 1 -
.../service/StandardControllerServiceNode.java | 2 -
.../service/StandardControllerServiceProvider.java | 1 -
.../StandardControllerServiceReference.java | 1 -
.../controller/state/StandardStateManager.java | 1 -
.../StandardVersionedComponentSynchronizer.java | 4 -
.../VersionedComponentSynchronizer.java | 5 -
.../VersionedFlowSynchronizationContext.java | 2 -
.../org/apache/nifi/groups/StandardDataValve.java | 2 -
.../apache/nifi/groups/StandardProcessGroup.java | 9 +-
.../nifi/logging/repository/NopLogRepository.java | 1 -
.../logging/repository/StandardLogRepository.java | 2 -
.../StandardControllerServiceFactory.java | 1 -
.../StandardRelationshipConfiguration.java | 1 -
.../nifi/parameter/StandardParameterContext.java | 1 -
.../StandardParameterReferenceManager.java | 1 -
.../nifi/processor/StandardProcessContext.java | 1 -
.../flow/StandardVersionControlInformation.java | 2 -
.../flow/mapping/VersionedComponentFlowMapper.java | 3 -
.../nifi/remote/StandardRemoteProcessGroup.java | 2 -
.../apache/nifi/reporting/AbstractEventAccess.java | 1 -
.../java/org/apache/nifi/util/BundleUtils.java | 3 -
.../apache/nifi/util/FlowDifferenceFilters.java | 5 +-
.../java/org/apache/nifi/util/SnippetUtils.java | 1 -
.../repository/StandardProcessSessionTest.java | 40 +-
.../TestStandardLifecycleStateManager.java | 2 -
...StandardControllerServiceInvocationHandler.java | 3 -
...StandardVersionedComponentSynchronizerTest.java | 3 -
.../TestStandardControllerServiceFactory.java | 1 -
.../TestStandardPropertyConfiguration.java | 1 -
.../TestStandardRelationshipConfiguration.java | 28 +-
.../mapping/TestVersionedComponentFlowMapper.java | 4 -
.../java/org/apache/nifi/util/TestBundleUtils.java | 1 -
.../nifi/util/TestFlowDifferenceFilters.java | 1 -
.../org/apache/nifi/connectable/Connectable.java | 2 +-
.../nifi/controller/AbstractComponentNode.java | 2 -
.../org/apache/nifi/controller/ProcessorNode.java | 1 -
.../nifi/controller/PropertyConfiguration.java | 4 +-
.../nifi/controller/TerminationAwareLogger.java | 1 -
.../apache/nifi/controller/flow/FlowManager.java | 14 -
.../nifi/controller/queue/DropFlowFileRequest.java | 1 -
.../controller/service/ControllerServiceNode.java | 1 -
.../nifi/groups/AbstractComponentScheduler.java | 3 -
.../org/apache/nifi/groups/ComponentScheduler.java | 1 -
.../java/org/apache/nifi/groups/ProcessGroup.java | 1 -
.../groups/RemoteProcessGroupPortDescriptor.java | 4 +-
.../org/apache/nifi/logging/LogRepository.java | 1 -
.../nifi/registry/extension/ExtensionRegistry.java | 1 -
.../registry/flow/mapping/ComponentIdLookup.java | 2 -
.../registry/flow/mapping/FlowMappingOptions.java | 1 -
.../mapping/VersionedComponentStateLookup.java | 2 +-
.../java/org/apache/nifi/services/FlowService.java | 2 +-
.../nifi/controller/TestAbstractComponentNode.java | 1 -
.../apache/nifi/controller/TestStandardFunnel.java | 44 +-
.../StandaloneProcessGroupLifecycle.java | 3 +-
.../apache/nifi/controller/ExtensionBuilder.java | 3 -
.../nifi/controller/FileSystemSwapManager.java | 3 -
.../org/apache/nifi/controller/FlowController.java | 14 +-
.../nifi/controller/GarbageCollectionEvent.java | 1 -
.../nifi/controller/StandardFlowService.java | 3 +-
.../nifi/controller/StandardFlowSnippet.java | 4 -
.../nifi/controller/StandardReloadComponent.java | 2 -
.../cluster/ClusterProtocolHeartbeater.java | 2 -
.../nifi/controller/flow/StandardFlowManager.java | 1 -
.../flow/StandardStatelessGroupNodeFactory.java | 3 -
.../flowanalysis/StandardFlowAnalysisRuleNode.java | 1 -
.../controller/queue/AbstractFlowFileQueue.java | 5 -
.../controller/queue/StandardFlowFileQueue.java | 7 -
.../controller/queue/SwappablePriorityQueue.java | 10 +-
.../clustered/SocketLoadBalancedFlowFileQueue.java | 6 -
.../client/async/nio/LoadBalanceSession.java | 9 -
.../async/nio/NioAsyncLoadBalanceClient.java | 5 -
.../nio/NioAsyncLoadBalanceClientFactory.java | 1 -
.../nio/NioAsyncLoadBalanceClientRegistry.java | 1 -
.../clustered/client/async/nio/PeerChannel.java | 1 -
.../partition/NonLocalPartitionPartitioner.java | 1 -
.../queue/clustered/partition/QueuePartition.java | 2 +-
.../clustered/partition/RemoteQueuePartition.java | 2 -
.../clustered/partition/RoundRobinPartitioner.java | 1 -
.../partition/StandardRebalancingPartition.java | 2 -
.../server/ConnectionLoadBalanceServer.java | 2 -
.../server/StandardLoadBalanceProtocol.java | 5 +-
.../repository/BatchingSessionFactory.java | 7 +-
.../repository/FileSystemRepository.java | 7 -
.../repository/LiveSerializedRepositoryRecord.java | 1 -
.../repository/StandardQueueProvider.java | 1 -
.../StatelessBridgeFlowFileRepository.java | 1 -
.../repository/WriteAheadFlowFileRepository.java | 2 -
.../scheduling/StandardProcessScheduler.java | 2 -
.../serialization/AffectedComponentSet.java | 3 +-
.../serialization/ComponentSetFilter.java | 1 -
.../serialization/FlowSynchronizationUtils.java | 1 -
.../controller/serialization/FlowSynchronizer.java | 4 +-
.../serialization/ScheduledStateLookup.java | 1 -
.../serialization/VersionedDataflowMapper.java | 1 +
.../serialization/VersionedFlowSynchronizer.java | 3 -
.../local/WriteAheadLocalStateProvider.java | 2 -
.../CachingConnectionStatusAnalyticsEngine.java | 1 -
.../analytics/ConnectionStatusAnalytics.java | 14 +-
.../analytics/StatusAnalyticsModelMapFactory.java | 1 -
.../history/VolatileComponentStatusRepository.java | 3 -
.../controller/swap/SimpleSwapDeserializer.java | 1 -
.../nifi/controller/swap/StandardSwapSummary.java | 1 -
.../nifi/controller/tasks/InvocationResult.java | 1 -
.../nifi/controller/tasks/StatelessFlowTask.java | 8 -
.../nifi/groups/StandardStatelessGroupNode.java | 3 -
.../nifi/persistence/FlowConfigurationDAO.java | 4 +-
.../StandardProvenanceAuthorizableFactory.java | 3 -
.../apache/nifi/reporting/StandardEventAccess.java | 2 -
.../org/apache/nifi/util/ComponentMetrics.java | 2 -
.../connector/processors/CreateDummyFlowFile.java | 2 +-
.../apache/nifi/controller/MockFlowFileRecord.java | 1 -
.../nifi/controller/TestStandardFlowFileQueue.java | 6 +-
.../queue/clustered/LoadBalancedQueueIT.java | 20 +-
.../TestContentRepositoryFlowFileAccess.java | 1 -
.../TestSocketLoadBalancedFlowFileQueue.java | 4 -
.../clustered/TestSwappablePriorityQueue.java | 7 +-
.../client/async/nio/TestLoadBalanceSession.java | 3 +-
.../client/async/nio/TestPeerChannel.java | 1 -
.../server/TestStandardLoadBalanceProtocol.java | 5 +-
.../repository/BatchingSessionFactoryTest.java | 85 +
.../repository/StandardProcessSessionIT.java | 9 -
.../repository/TestFileSystemRepository.java | 4 -
.../TestWriteAheadFlowFileRepository.java | 4 +-
.../repository/io/TestContentClaimInputStream.java | 7 -
.../repository/io/TestLimitedInputStream.java | 1 -
.../scheduling/TestStandardProcessScheduler.java | 1 -
.../TestStandardControllerServiceProvider.java | 100 +-
.../state/providers/AbstractTestStateProvider.java | 2 -
.../analytics/TestStatusAnalyticsEngine.java | 1 -
.../analytics/models/TestOrdinaryLeastSquares.java | 1 -
.../nifi/controller/tasks/TestConnectableTask.java | 1 -
.../TestFlowConfigurationArchiveManager.java | 1 -
...ernalResourceProviderInitializationContext.java | 2 +-
.../ReplaceWithNewerResolutionStrategyTest.java | 1 -
.../java/org/apache/nifi/nar/NarLoaderHolder.java | 14 +-
.../apache/nifi/nar/TestLoadNativeLibFromNar.java | 12 +-
.../nar/TestLoadNativeLibViaSystemProperty.java | 14 +-
.../apache/nifi/FlowRegistryClientInitializer.java | 1 -
.../org/apache/nifi/nar/ExtensionDefinition.java | 1 -
.../apache/nifi/nar/ExtensionManagerHolder.java | 14 +-
.../nar/StandardExtensionDiscoveringManager.java | 5 -
.../src/test/resources/nifi.properties | 1 -
.../status/history/ComponentDetails.java | 1 -
.../status/history/ConnectionStatusDescriptor.java | 1 -
.../status/history/NodeStatusDescriptor.java | 1 -
.../history/ProcessGroupStatusDescriptor.java | 1 -
.../status/history/ProcessorStatusDescriptor.java | 3 -
.../RemoteProcessGroupStatusDescriptor.java | 1 -
.../status/history/StandardStatusSnapshot.java | 2 -
.../java/org/apache/nifi/nar/NarClassLoaders.java | 3 +-
.../org/apache/nifi/nar/NarClassLoadersHolder.java | 10 +-
.../java/org/apache/nifi/util/ReflectionUtils.java | 1 -
.../src/test/resources/nifi.properties | 1 -
.../repository/StandardRepositoryRecord.java | 1 -
.../repository/claim/StandardContentClaim.java | 3 +-
.../claim/StandardResourceClaimManager.java | 1 -
.../src/main/resources/conf/nifi.properties | 1 -
.../nifi/remote/PeerDescriptionModifier.java | 1 -
.../nifi/remote/SocketRemoteSiteListener.java | 1 -
.../org/apache/nifi/remote/StandardPublicPort.java | 4 +-
.../nifi/remote/StandardRemoteGroupPort.java | 1 -
.../http/StandardHttpFlowFileServerProtocol.java | 4 +-
.../socket/SocketFlowFileServerProtocol.java | 2 -
.../nifi/remote/TestPeerDescriptionModifier.java | 1 -
.../nifi/remote/TestStandardRemoteGroupPort.java | 13 +-
.../http/TestHttpFlowFileServerProtocol.java | 8 +-
.../org/apache/nifi/web/server/JettyServer.java | 1 -
.../org/apache/nifi/audit/ProcessorAuditor.java | 4 +-
.../nifi/audit/RemoteProcessGroupAuditor.java | 2 -
.../authorization/StandardAuthorizableLookup.java | 2 -
.../nifi/prometheusutil/NiFiMetricsRegistry.java | 2 +-
.../nifi/prometheusutil/PrometheusMetricsUtil.java | 2 -
.../nifi/registry/flow/FlowRegistryUtils.java | 1 -
.../org/apache/nifi/web/NiFiServiceFacade.java | 13 +-
.../org/apache/nifi/web/NiFiServiceFacadeLock.java | 1 -
.../apache/nifi/web/StandardNiFiServiceFacade.java | 42 +-
.../web/StandardNiFiWebConfigurationContext.java | 1 -
.../apache/nifi/web/api/ApplicationResource.java | 2 -
.../nifi/web/api/ControllerServiceResource.java | 3 -
.../apache/nifi/web/api/DataTransferResource.java | 12 +-
.../apache/nifi/web/api/FlowFileQueueResource.java | 4 +-
.../java/org/apache/nifi/web/api/FlowResource.java | 5 -
.../apache/nifi/web/api/OutputPortResource.java | 1 -
.../nifi/web/api/ParameterContextResource.java | 5 -
.../nifi/web/api/ParameterProviderResource.java | 1 -
.../apache/nifi/web/api/ProcessGroupResource.java | 15 +-
.../org/apache/nifi/web/api/ProcessorResource.java | 6 -
.../nifi/web/api/ProvenanceEventResource.java | 2 -
.../nifi/web/api/RemoteProcessGroupResource.java | 1 -
.../apache/nifi/web/api/ReportingTaskResource.java | 2 -
.../apache/nifi/web/api/SiteToSiteResource.java | 1 -
.../org/apache/nifi/web/api/VersionsResource.java | 7 -
.../web/api/concurrent/AsyncRequestManager.java | 2 -
.../api/config/WebApplicationExceptionMapper.java | 8 +-
.../org/apache/nifi/web/api/dto/DtoFactory.java | 53 +-
.../nifi/web/controller/ControllerFacade.java | 1 -
.../org/apache/nifi/web/dao/AccessPolicyDAO.java | 1 -
.../org/apache/nifi/web/dao/ProcessGroupDAO.java | 6 +-
.../apache/nifi/web/dao/impl/AbstractPortDAO.java | 1 -
.../nifi/web/dao/impl/StandardFlowRegistryDAO.java | 1 -
.../web/dao/impl/StandardParameterContextDAO.java | 1 -
.../dao/impl/StandardRemoteProcessGroupDAO.java | 1 -
.../web/dao/impl/StandardReportingTaskDAO.java | 1 -
.../util/ClusterReplicationComponentLifecycle.java | 6 -
.../nifi/web/util/LocalComponentLifecycle.java | 6 -
.../org/apache/nifi/web/util/SnippetUtils.java | 2 -
.../apache/nifi/audit/TestProcessGroupAuditor.java | 1 -
.../apache/nifi/audit/TestProcessorAuditor.java | 1 -
.../nifi/audit/TestRemoteProcessGroupAuditor.java | 3 -
.../nifi/web/StandardNiFiServiceFacadeTest.java | 3 -
.../org/apache/nifi/web/api/TestFlowResource.java | 1 -
.../apache/nifi/web/api/dto/DtoFactoryTest.java | 59 +
.../dao/impl/TestStandardParameterContextDAO.java | 1 -
.../test/resources/site-to-site/nifi.properties | 1 -
.../nifi/web/revision/StandardRevisionUpdate.java | 1 -
.../behavior/connectable-behavior.service.ts | 139 +-
.../service/canvas-utils.service.spec.ts | 356 +-
.../flow-designer/service/canvas-utils.service.ts | 168 +
.../manager/connection-manager.service.spec.ts | 82 +
.../service/manager/connection-manager.service.ts | 34 +-
.../pages/flow-designer/state/flow/flow.actions.ts | 6 +
.../pages/flow-designer/state/flow/flow.effects.ts | 22 +
.../flow-designer/state/flow/flow.selectors.ts | 15 +
.../app/pages/flow-designer/state/flow/index.ts | 6 +
.../flow-designer/ui/canvas/canvas.component.html | 6 +
.../flow-designer/ui/canvas/canvas.component.scss | 13 +
.../ui/canvas/canvas.component.spec.ts | 2 +
.../flow-designer/ui/canvas/canvas.component.ts | 14 +
.../pages/flow-designer/ui/canvas/canvas.module.ts | 4 +-
.../graph-controls/graph-controls.component.scss | 2 +-
.../navigation-control.component.html | 35 +-
.../edit-connection/edit-connection.component.ts | 19 +-
.../local-changes-dialog/local-changes-dialog.html | 1 +
.../local-changes-table/local-changes-table.html | 13 +-
.../local-changes-table.spec.ts | 162 +
.../local-changes-table/local-changes-table.ts | 77 +-
.../edit-processor/edit-processor.component.html | 2 +-
.../edit-processor.component.spec.ts | 1371 +++---
.../edit-processor/edit-processor.component.ts | 48 +-
.../app/ui/common/overlap-detection.utils.spec.ts | 250 ++
.../src/app/ui/common/overlap-detection.utils.ts | 131 +
...apping-connections-banner.component-theme.scss} | 29 +-
.../overlapping-connections-banner.component.html | 36 +
.../overlapping-connections-banner.component.scss} | 4 +-
...verlapping-connections-banner.component.spec.ts | 103 +
.../overlapping-connections-banner.component.ts} | 23 +-
.../src/main/frontend/apps/nifi/src/styles.scss | 4 +
nifi-frontend/src/main/frontend/package-lock.json | 4429 ++++++++++++--------
nifi-frontend/src/main/frontend/package.json | 22 +-
.../apache/nifi/extension/manifest/Extension.java | 6 +-
.../extension/manifest/MultiProcessorUseCase.java | 1 -
.../extension/manifest/ProcessorConfiguration.java | 1 -
.../apache/nifi/extension/manifest/UseCase.java | 1 -
.../nifi/provenance/MockProvenanceEvent.java | 3 -
.../java/org/apache/nifi/util/MockFlowFile.java | 1 -
.../org/apache/nifi/util/MockProcessContext.java | 5 +-
.../org/apache/nifi/util/MockProcessSession.java | 18 +-
.../nifi/util/MockPropertyConfiguration.java | 1 -
.../org/apache/nifi/util/MockPropertyValue.java | 4 +-
.../apache/nifi/util/MockValidationContext.java | 1 -
.../nifi/util/StandardProcessorTestRunner.java | 3 -
.../main/java/org/apache/nifi/util/TestRunner.java | 26 +-
.../apache/nifi/util/TestMockProcessSession.java | 2 +-
.../nifi/util/TestStandardProcessorTestRunner.java | 2 +-
.../nifi/registry/bootstrap/BootstrapCodec.java | 4 +-
.../nifi/registry/bootstrap/RunNiFiRegistry.java | 1 -
.../bundle/extract/nar/NarBundleExtractor.java | 2 +-
.../registry/client/NiFiRegistryClientConfig.java | 1 -
.../apache/nifi/registry/client/RequestConfig.java | 1 -
.../registry/client/impl/AbstractJerseyClient.java | 1 -
.../client/impl/BucketItemDeserializer.java | 1 -
.../registry/client/impl/JerseyBucketClient.java | 1 -
.../registry/client/impl/JerseyItemsClient.java | 2 -
.../apache/nifi/registry/bucket/BucketItem.java | 1 -
.../nifi/registry/extension/bundle/BundleType.java | 1 -
.../registry/extension/bundle/BundleVersion.java | 1 -
.../extension/bundle/BundleVersionMetadata.java | 1 -
.../flow/VersionedFlowSnapshotMetadata.java | 1 -
.../flow/TestVersionedRemoteProcessGroup.java | 4 -
.../nifi/registry/flow/diff/DifferenceType.java | 1 -
.../registry/flow/diff/StandardFlowComparator.java | 23 +-
.../nifi-registry-framework/pom.xml | 2 +-
.../nifi/registry/db/DatabaseMetadataService.java | 3 +-
.../nifi/registry/db/entity/BucketEntity.java | 1 -
.../nifi/registry/db/entity/BucketItemEntity.java | 1 -
.../registry/db/entity/BucketItemEntityType.java | 1 -
.../db/entity/BundleVersionDependencyEntity.java | 1 -
.../registry/db/entity/BundleVersionEntity.java | 1 -
.../nifi/registry/db/entity/ExtensionEntity.java | 2 -
.../nifi/registry/db/migration/BucketEntityV1.java | 1 -
.../nifi/registry/db/migration/FlowEntityV1.java | 1 -
.../FileSystemBundlePersistenceProvider.java | 1 -
.../extension/StandardBundleCoordinate.java | 1 -
.../StandardBundlePersistenceContext.java | 1 -
.../flow/git/GitFlowPersistenceProvider.java | 2 -
.../provider/hook/ScriptEventHookProvider.java | 1 -
.../AbstractPolicyBasedAuthorizer.java | 1 -
.../security/authorization/AuthorizerFactory.java | 2 -
.../authorization/CompositeUserAndGroups.java | 1 -
.../database/DatabaseAccessPolicyProvider.java | 1 -
.../registry/security/identity/IdentityMapper.java | 1 -
.../security/ldap/LdapIdentityProvider.java | 1 -
.../registry/service/AuthorizationService.java | 3 -
.../nifi/registry/service/MetadataService.java | 1 -
.../extension/StandardExtensionService.java | 1 -
.../flow/git/TestGitFlowPersistenceProvider.java | 1 -
.../nifi/registry/service/TestRegistryService.java | 1 -
.../properties/NiFiRegistryProperties.java | 1 -
.../nifi/registry/metadata/BucketMetadata.java | 1 -
.../nifi/registry/metadata/FlowMetadata.java | 1 -
.../registry/metadata/FlowSnapshotMetadata.java | 1 -
.../main/resources/conf/nifi-registry.properties | 1 -
.../revision/naive/NaiveRevisionManager.java | 1 -
.../revision/standard/StandardRevisionUpdate.java | 1 -
.../revision/jdbc/JdbcRevisionManager.java | 2 +-
.../registry/security/authorization/Group.java | 1 -
.../org/apache/nifi/registry/util/FileUtils.java | 1 -
.../registry/web/api/AccessPolicyResource.java | 3 -
.../nifi/registry/web/api/AccessResource.java | 2 -
.../apache/nifi/registry/web/api/ItemResource.java | 1 -
.../nifi/registry/web/api/TenantResource.java | 2 -
.../apache/nifi/registry/web/link/LinkService.java | 3 -
.../web/mapper/UntrustedProxyExceptionMapper.java | 2 +-
.../kerberos/KerberosIdentityProvider.java | 1 -
.../kerberos/KerberosSpnegoFactory.java | 1 -
.../oidc/StandardOidcIdentityProvider.java | 2 +-
.../authentication/x509/X509IdentityProvider.java | 1 -
.../web/service/StandardServiceFacade.java | 2 -
.../org/apache/nifi/registry/web/api/FlowsIT.java | 1 -
.../registry/web/api/IntegrationTestUtils.java | 1 -
.../nifi/registry/web/api/SecureKerberosIT.java | 1 -
.../oidc/StandardOidcIdentityProviderTest.java | 12 +-
.../application-ITSecureDatabase.properties | 3 -
.../resources/application-ITSecureFile.properties | 3 -
.../application-ITSecureKerberos.properties | 3 -
.../resources/application-ITSecureLdap.properties | 3 -
.../resources/application-ITSecureProxy.properties | 3 -
nifi-registry/pom.xml | 6 +-
.../PropertiesFileEngineConfigurationParser.java | 1 -
.../flow/NopProvenanceEventRepository.java | 2 -
.../nifi/stateless/flow/StatelessDataflow.java | 2 -
...ropertiesFileEngineConfigurationParserTest.java | 1 -
.../bootstrap/BootstrapConfiguration.java | 2 -
.../reporting/StatelessReportingTaskNode.java | 1 -
.../org/apache/nifi/extensions/DownloadQueue.java | 1 -
.../extensions/FileSystemExtensionRepository.java | 1 -
.../config/PropertiesFileFlowDefinitionParser.java | 3 -
.../engine/StandardExecutionProgress.java | 1 -
.../flow/StandardStatelessDataflowFactory.java | 1 -
.../nifi/stateless/flow/StandardStatelessFlow.java | 3 -
.../flow/StandardStatelessFlowCurrent.java | 2 -
.../StatelessFileSystemContentRepository.java | 2 -
.../repository/StatelessProvenanceRepository.java | 2 +-
.../processors/tests/system/MigrateProperties.java | 17 +-
.../nifi/stateless/VersionedFlowBuilder.java | 1 -
.../stateless/basics/AsyncCommitCallbackIT.java | 1 -
.../nifi/stateless/basics/InputOutputIT.java | 1 -
.../basics/RequiresAdditionalInputIT.java | 2 -
.../stateless/basics/RollbackOnExceptionIT.java | 1 -
.../stateless/parameters/ParameterContextIT.java | 3 -
...ntrollerServiceReferencingFlowAnalysisRule.java | 6 +-
.../flowanalysis/StatefulFlowAnalysisRule.java | 4 +-
.../tests/system/ConcatenateRangeOfFlowFiles.java | 1 -
.../processors/tests/system/CountFlowFiles.java | 1 -
.../DefaultedDynamicallyModifyClasspath.java | 3 -
.../nifi/processors/tests/system/Duplicate.java | 2 +-
.../tests/system/DynamicallyModifyClasspath.java | 4 -
.../nifi/processors/tests/system/LoopFlowFile.java | 4 +-
.../processors/tests/system/MigrateProperties.java | 13 +-
.../processors/tests/system/ReOrderFlowFiles.java | 2 +-
.../nifi/processors/tests/system/SetAttribute.java | 2 +-
.../nifi/processors/tests/system/SetState.java | 1 -
.../apache/nifi/processors/tests/system/Sleep.java | 1 -
.../processors/tests/system/TransferBatch.java | 1 -
.../processors/tests/system/UnzipFlowFile.java | 6 +-
.../processors/tests/system/UpdateContent.java | 2 +-
.../processors/tests/system/VerifyEvenThenOdd.java | 5 +-
.../tests/system/WriteFlowFileCountToFile.java | 4 +-
.../EnsureReportingTaskConfigurationCorrect.java | 1 -
.../nifi/reporting/MigrationReportingTask.java | 1 -
.../nifi/tests/system/AggregateNiFiInstance.java | 2 -
.../apache/nifi/tests/system/NiFiClientUtil.java | 4 -
.../nifi/tests/system/NiFiInstanceCache.java | 1 -
.../classloaders/ClassloaderIsolationKeyIT.java | 1 -
.../system/clustering/FlowSynchronizationIT.java | 32 +-
.../clustering/NodeRestartWithNewNodeIdIT.java | 1 -
.../nifi/tests/system/clustering/OffloadIT.java | 2 -
.../PrimaryNodeChangeNotificationIT.java | 1 -
.../system/clustering/SimpleNodeRestartIT.java | 1 -
.../ControllerServiceEnableDisableConflictIT.java | 1 -
.../flowanalysisrule/FlowAnalysisRuleIT.java | 1 -
.../tests/system/loadbalance/LoadBalanceIT.java | 5 +-
.../parameters/ClusteredParameterContextIT.java | 6 +-
.../system/parameters/ParameterContextIT.java | 10 +-
.../tests/system/pg/BatchFlowBetweenGroupsIT.java | 1 -
.../system/pg/SingleFlowFileConcurrencyIT.java | 2 -
.../processor/DynamicClassPathModificationIT.java | 2 -
.../nifi/tests/system/processor/RetryIT.java | 4 -
.../nifi/tests/system/processor/RunOnceIT.java | 16 +
.../system/provenance/ProvenanceRepositoryIT.java | 3 -
.../python/PythonNarDeletionDuringInitIT.java | 1 -
.../tests/system/registry/RegistryClientIT.java | 6 -
.../system/reportingtask/ReportingTaskIT.java | 1 -
.../tests/system/rpg/RemoteProcessGroupIT.java | 1 -
.../system/stateless/ClusteredStatelessFlowIT.java | 2 -
.../tests/system/stateless/StatelessBasicsIT.java | 4 -
.../VerifiableControllerServiceSystemIT.java | 2 -
.../VerifiableFlowAnalysisRuleSystemIT.java | 2 -
.../VerifiableParameterProviderSystemIT.java | 1 -
.../verification/VerifiableProcessorSystemIT.java | 1 -
.../VerifiableReportingTaskSystemIT.java | 2 -
.../resources/conf/clustered/node1/nifi.properties | 2 -
.../resources/conf/clustered/node2/nifi.properties | 2 -
.../test/resources/conf/default/nifi.properties | 2 -
.../test/resources/conf/pythonic/nifi.properties | 2 -
nifi-toolkit/nifi-toolkit-cli/pom.xml | 2 +-
.../toolkit/cli/impl/command/AbstractCommand.java | 1 -
.../command/registry/NiFiRegistryCommandGroup.java | 2 +-
.../registry/bucket/UpdateBucketPolicy.java | 2 -
.../command/registry/flow/TransferFlowVersion.java | 1 -
.../nifi/toolkit/cli/impl/result/writer/Table.java | 2 +-
pmd-ruleset.xml | 2 -
pom.xml | 57 +-
1322 files changed, 14064 insertions(+), 9734 deletions(-)
create mode 100644 checkstyle-suppressions.xml
copy
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/{SubstringAfterEvaluator.java
=> CompactDelimitedListEvaluator.java} (56%)
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/TrimDelimitedListEvaluator.java
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/UniqueEvaluator.java
create mode 100644
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/StandardAzureIdentityFederationTokenProvider.java
create mode 100644
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/util/AzureWorkloadIdentityCredentialUtils.java
create mode 100644
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/resources/docs/org.apache.nifi.services.azure.StandardAzureIdentityFederationTokenProvider/additionalDetails.md
copy
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/components/connector/services/impl/StandardCounterService.java
=>
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/services/azure/MockIdentityFederationTokenProvider.java
(60%)
create mode 100644
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/services/azure/TestStandardAzureIdentityFederationTokenProvider.java
create mode 100644
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/services/azure/util/TestAzureWorkloadIdentityCredentialUtils.java
copy
nifi-extension-bundles/nifi-azure-bundle/nifi-azure-services-api/src/main/java/org/apache/nifi/services/azure/{storage/AzureStorageCredentialsService_v12.java
=> AzureIdentityFederationTokenProvider.java} (58%)
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-processors/src/test/java/org/apache/nifi/processors/couchbase/AbstractCouchbaseProcessorTest.java
copy
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services-api/src/main/java/org/apache/nifi/services/couchbase/exception/{ExceptionCategory.java
=> CouchbaseCasMismatchException.java} (81%)
copy
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services-api/src/main/java/org/apache/nifi/services/couchbase/exception/{ExceptionCategory.java
=> CouchbaseDocExistsException.java} (81%)
copy
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services-api/src/main/java/org/apache/nifi/services/couchbase/exception/{ExceptionCategory.java
=> CouchbaseDocNotFoundException.java} (81%)
copy
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services-api/src/main/java/org/apache/nifi/services/couchbase/utils/{CouchbaseContext.java
=> CouchbaseLookupInResult.java} (88%)
copy nifi-extension-bundles/{nifi-box-bundle/nifi-box-processors =>
nifi-couchbase-bundle/nifi-couchbase-services}/pom.xml (74%)
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/main/java/org/apache/nifi/services/couchbase/AbstractCouchbaseService.java
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/main/java/org/apache/nifi/services/couchbase/CouchbaseKeyValueLookupService.java
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/main/java/org/apache/nifi/services/couchbase/CouchbaseMapCacheClient.java
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/main/java/org/apache/nifi/services/couchbase/CouchbaseRecordLookupService.java
copy nifi-extension-bundles/{nifi-pgp-bundle/nifi-pgp-service =>
nifi-couchbase-bundle/nifi-couchbase-services}/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService
(80%)
copy
nifi-extension-bundles/{nifi-evtx-bundle/nifi-evtx-processors/src/test/java/org/apache/nifi/processors/evtx/parser/bxml/BxmlNodeWithTokenAndStringTestBase.java
=>
nifi-couchbase-bundle/nifi-couchbase-services/src/test/java/org/apache/nifi/services/couchbase/AbstractCouchbaseServiceTest.java}
(50%)
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/test/java/org/apache/nifi/services/couchbase/CouchbaseKeyValueLookupServiceTest.java
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/test/java/org/apache/nifi/services/couchbase/CouchbaseMapCacheClientTest.java
create mode 100644
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-services/src/test/java/org/apache/nifi/services/couchbase/CouchbaseRecordLookupServiceTest.java
rename
nifi-extension-bundles/nifi-couchbase-bundle/nifi-couchbase-standard-services/src/test/java/org/apache/nifi/services/couchbase/{TestCouchbaseClient.java
=> CouchbaseClientTest.java} (50%)
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/repository/BatchingSessionFactoryTest.java
create mode 100644
nifi-frontend/src/main/frontend/apps/nifi/src/app/ui/common/overlap-detection.utils.spec.ts
create mode 100644
nifi-frontend/src/main/frontend/apps/nifi/src/app/ui/common/overlap-detection.utils.ts
copy
nifi-frontend/src/main/frontend/apps/{nifi-jolt-transform-ui/src/app/pages/jolt-transform-json-ui/feature/_jolt-transform-json-ui.component-theme.scss
=>
nifi/src/app/ui/common/overlapping-connections-banner/_overlapping-connections-banner.component-theme.scss}
(60%)
create mode 100644
nifi-frontend/src/main/frontend/apps/nifi/src/app/ui/common/overlapping-connections-banner/overlapping-connections-banner.component.html
copy
nifi-frontend/src/main/frontend/apps/nifi/src/app/{pages/documentation/ui/overview/overview.component.scss
=>
ui/common/overlapping-connections-banner/overlapping-connections-banner.component.scss}
(95%)
create mode 100644
nifi-frontend/src/main/frontend/apps/nifi/src/app/ui/common/overlapping-connections-banner/overlapping-connections-banner.component.spec.ts
copy
nifi-frontend/src/main/frontend/{libs/shared/src/components/codemirror/autocomplete/parameter-tip/parameter-tip.component.ts
=>
apps/nifi/src/app/ui/common/overlapping-connections-banner/overlapping-connections-banner.component.ts}
(58%)
