This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/nifi-registry/nifi-registry-core/nifi-registry-web-ui/src/main/decode-uri-component-0.2.2
in repository https://gitbox.apache.org/repos/asf/nifi.git
discard a2a709937d Bump decode-uri-component
add b744fac479 NIFI-10956: Fix inference issues with mixed arrays (#6763)
add 334c9db9c3 NIFI-10915 Add additionalDetails content to runtime
manifest - Update manifests assembly to include the additionaDetails.html files
- Update C2 ExtensionDefinition to add a new field for additional details
content - Update manifest generation to read the additional details and pass
through to C2 runtime manifest - Switch to boolean to indicate presence of
additional details, instead of including content
add b0ab364f61 NIFI-10967 Corrected TestWriteJsonResult mixed arrays
add ac8e3dae58 NIFI-10637 Deterministic TestGenerateTableFetch
testMultipleColumnTypeMissing
add 2fa82179a8 NIFI-10576 Added onFinishRecordSet implementation for
WriteParquetResult
add c11dff912a NIFI-10958 Adjusted Script Engine handling to avoid
exceptions
add e21f622643 NIFI-10877 Converted more nifi-framework-core tests from
JUnit 4 to 5
add ed6ba53724 NIFI-10832: Create PutSalesforceRecord processor
add 78be613a0f NIFI-10888: When inferring a schema using a Record Reader,
buffer up to 1 MB of FlowFile content for the schema inference so that when we
read the contents to obtain records we can use the buffered data. This helps in
cases of small FlowFiles by not having to seek back to the beginning of the
FlowFile every time.
add 1e23e5146f NIFI-10969: Created extension point for Signer Override in
AWS S3 processors
add ae5d23db47 NIFI-10987: Added default implementation of AWS SDK V2
credentials in AWSCredentialsProviderService
add 1c40738997 NIFI-10618: Add Asana connector
add a8974253ce NIFI-10989 Removed SHA-1 and MD5 from TestHashContent
add 5c3ca9d537 NIFI-10981 Ensure NarAutoLoader starts after provider
retrieves NARs,… (#6785)
add 1d5a1bff08 NIFI-10868 PutDropbox processor
add caee606706 NIFI-10884 log target filename
add 2a88980024 NIFI-4572: Include database and table names in
CaptureChangeMySQL events even when cache is not configured
add c85a6e866f NIFI-10921 Upgraded Apache POI from 5.2.2 to 5.2.3
add ce237888e6 NIFI-10978 Added LDAP_REFERRAL_STRATEGY to NiFi Docker
add 6a149c3f34 NIFI-10984 Allow NAR to be uploaded to NiFi Registry
without extension manifest (#6784)
add 2b0f7ac5c4 NIFI-10995 Update Jetty to 9.4.50.v20221201
add ba29c3b04e NIFI-11002 - docs: fix small error
add dde821cf71 NIFI-6498 Update TransformXml to send errors to Component
Log
add f38f14b363 NIFI-10585 Added GenerateRecord Processor
add b65431564d NIFI-10988 - Fix ConsumeGCPubSubLite processors delivering
incorrect messages
add b556322749 NIFI-11005 Added Illegal and Redundant Import Modules to
Checkstyle
add beb90ba8a6 NIFI-10855 Added Documentation on CSRF Protection
add bf24d575b3 NIFI-10971: improved edge case handling while fetching
objects using Azure Key Vault Client and added unit tests
add 4b24bcd2f8 NIFI-10677: Add Choice data type handling to Iceberg record
converter
add bb886af69d NIFI-11010 - Update Kinesis client to 1.14.9
add 7a4e3a4b6c NIFI-11011 - Update AWS SDK versions to 1.12.371 and
2.17.295
add eb9f75e28f NIFI-11009 Update Snowflake SDK to 1.0.2-beta.7
add 09463b0ae5 NIFI-11012 Updated Twitter SDK from 1.1.4 to 2.0.3
add 9915bded77 NIFI-11017 Upgraded Hazelcast from 4.2.5 to 4.2.6
add 4716c8d715 NIFI-10456 Added Client Authentication Strategy option to
OAuth2 Provider
add b74c5b423f NIFI-10979 Additional nifi-framework upgrades from JUnit 4
to 5
add 1404a151a1 NIFI-11015 Corrected Registry Trust Store Type handling
add 481cdaf3db NIFI-11018 Upgraded nifi-web-security to JUnit 5
add d229f3fd11 NIFI-10608 Process Group copies include non-processor
referenced controller services
add 9aecfc4e5b NIFI-11021 Upgraded Groovy from 3.0.9 to 3.0.14
add 660d0ed5f9 NIFI-11023 Address socket communication instability between
minifi process and bootstrap
add 06c8225bbd [NIFI-11006] Upgraded from Junit4 to Junit5
add c11092b2b4 NIFI-10998 Fixed SplitJson to always compile new JsonPath
when property changes
add d9420afb60 NIFI-10844 Allow _source only output for GetElasticsearch
and JsonQueryElasticsearch
add 53faecdcf6 NIFI-11027 Removed direct dependency on Joda Time
add b69721cac9 NIFI-10980 - correct ordering of property descriptor
allowable values (#6781)
add 3a60013876 NIFI-10754 Added getUri NIFI Expression Language function
add 9252dcbc76 NIFI-11019 Converted remaining nifi-scripting tests to
JUnit 5
add e966336e89 NIFI-11029 Added Standard XML parsing to
ExtractCCDAAttributes
add 4f77a17d19 NIFI-11031: Fix logic error in GenerateRecord for
nullPercentage
add ea93dec079 NIFI-10481 Support disabling ZooKeeper Ensemble Tracking
add e97977d61f NIFI-10997 Ensure auditing of process group / controller
service operations
add 6c517446a4 NIFI-10949 Updated MongoDB components using current driver
(#6759)
add 0d9dc6c540 NIFI-9167 Converted remaining nifi-framework tests to JUnit
5
add fe25424233 NIFI-10772 Clarify logs on shutdown where controller
service and/or processor were unable to properly start
add 0c0f7e87be NIFI-11004 Added documentation for OIDC groups claim
property
add 40ccb71f85 NIFI-10234 Added PutIoTDBRecord Processor
add a9baa21f87 NIFI-10996: Write out CSV header even if there are no
records
add d5c79fdcd1 NIFI-10887: Addressed performance concerned. Use
String.indexOf() instead of Pattern.matcher() when using Literal Replace. Use a
NonFlushableOutputStream when ProcessSession.write() is called. Implemented
hashCode() on AbstractConnection. Updated default Run Schedule on ReplaceText
from 0 ms to 25 ms. Added a Surround Replacement strategy that allows both
prepending and appending text. Updated unit tests to account for this.
add 692e74e90d NIFI-10241 Add comments tooltip for controller services,
reporting tasks
add fbb74b2c21 NIFI-11040 Update box-java-sdk to 3.8.2
add 74e0a2002e NIFI-11030 refactor nifi-stateless-processor-bundle to use
JUnit5
add 8807a9d377 NIFI-10895 Update properties command for MiNiFi C2
add de1d26d8bf NIFI-10799 Add OIDC to Docker images for NiFi and NiFi
Registry
add 1d7ee542b1 NIFI-2161 add option to skip attribute output for unmatched
JSON path expressions in EvaluateJsonPath
add e0ec9780a5 NIFI-10449 Fixed ScriptedLookupServices reloading
add d38f15997d NIFI-10870 Added debug logging for the Elasticsearch REST
Requests
add 765e5fc61e NIFI-11052 Upgraded Netty from 4.1.85 to 4.1.87
add 3a1e4dbe92 NiFI-10922 Update testcontainers version to 1.17.6
add b107ae1f8c NIFI-11046 Upgraded Dependency Check from 7.3.2 to 7.4.4
add b7071cbb04 NIFI-11049 Fixed flaky PutDropboxTest, attribute
description corrected
add 2abb8921e7 NIFI-10895 Handle minifi restarts more gracefully
add 6adbc1aeb0 NIFI-11036: Add Cluster Summary Metrics to Prometheus
endpoint
add 9552929c8c NIFI-11063 Upgraded express from 1.19.1 to 1.20.1
add 1003ddd983 Bump decode-uri-component
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 (a2a709937d)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/nifi-registry/nifi-registry-core/nifi-registry-web-ui/src/main/decode-uri-component-0.2.2
(1003ddd983)
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.
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-workflow.yml | 1 +
.gitignore | 1 +
.../org/apache/nifi/c2/client/C2ClientConfig.java | 24 +
.../apache/nifi/c2/client/http/C2HttpClient.java | 2 +
.../nifi/c2/client/http/C2HttpClientTest.java | 7 +-
.../nifi/c2/client/service/C2ClientService.java | 102 ++++-
.../service/operation/C2OperationHandler.java | 8 +
...ervice.java => C2OperationHandlerProvider.java} | 24 +-
.../client/service/operation/OperationQueue.java | 80 ++++
.../service/operation/RequestedOperationDAO.java} | 39 +-
.../UpdateConfigurationOperationHandler.java | 5 +
.../UpdatePropertiesOperationHandler.java | 92 ++++
.../c2/client/service/C2ClientServiceTest.java | 147 ++++++-
...st.java => C2OperationHandlerProviderTest.java} | 35 +-
.../UpdatePropertiesOperationHandlerTest.java | 130 ++++++
.../apache/nifi/c2/protocol/api/C2Operation.java | 29 ++
.../nifi/c2/protocol/api/C2OperationAck.java | 30 ++
.../nifi/c2/protocol/api/C2OperationState.java | 25 ++
.../apache/nifi/c2/protocol/api/OperandType.java | 1 +
.../apache/nifi/c2/protocol/api/OperationType.java | 3 +-
.../protocol/component/api/ExtensionComponent.java | 12 +
checkstyle.xml | 2 +
minifi/minifi-bootstrap/pom.xml | 5 +
.../apache/nifi/minifi/bootstrap/RunMiNiFi.java | 36 +-
.../bootstrap/command/CommandRunnerFactory.java | 10 +-
.../nifi/minifi/bootstrap/command/StartRunner.java | 145 ++++--
.../ConfigurationChangeCoordinator.java | 12 +-
.../differentiators/Differentiator.java | 4 +-
.../differentiators/WholeConfigDifferentiator.java | 10 +-
.../ingestors/FileChangeIngestor.java | 2 +-
.../ingestors/PullHttpChangeIngestor.java | 2 +-
.../ingestors/RestChangeIngestor.java | 2 +-
.../minifi/bootstrap/service/BootstrapCodec.java | 90 ++--
.../bootstrap/service/BootstrapFileProvider.java | 19 +-
.../bootstrap/service/MiNiFiCommandSender.java | 2 +
.../service/MiNiFiConfigurationChangeListener.java | 2 +-
.../minifi/bootstrap/service/MiNiFiListener.java | 15 +-
.../service/UpdateConfigurationService.java | 95 ++++
.../bootstrap/service/UpdatePropertiesService.java | 107 +++++
.../minifi/bootstrap/util/ConfigTransformer.java | 6 +
.../command/CommandRunnerFactoryTest.java | 35 +-
.../WholeConfigDifferentiatorTest.java | 10 +-
.../bootstrap/service/BootstrapCodecTest.java | 87 +++-
minifi/minifi-commons/minifi-commons-api/pom.xml | 32 ++
.../minifi/commons/api/MiNiFiCommandState.java | 11 +-
.../nifi/minifi/commons/api/MiNiFiConstants.java | 9 +-
minifi/minifi-commons/pom.xml | 1 +
minifi/minifi-docker/pom.xml | 1 +
.../main/markdown/minifi-java-agent-quick-start.md | 11 +-
.../c2/hierarchical/minifi-edge1/expected.json | 2 +-
.../c2/hierarchical/minifi-edge2/expected.json | 2 +-
.../c2/hierarchical/minifi-edge3/expected.json | 2 +-
.../minifi-framework/minifi-framework-core/pom.xml | 5 +
.../org/apache/nifi/minifi/MiNiFiProperties.java | 151 +++++++
.../apache/nifi/minifi/c2/C2NiFiProperties.java | 79 ----
.../apache/nifi/minifi/c2/C2NifiClientService.java | 254 +++++++++--
.../minifi/c2/FileBasedRequestedOperationDAO.java | 73 +++
.../c2/command/AgentPropertyValidationContext.java | 111 +++++
.../minifi/c2/command/PropertiesPersister.java | 143 ++++++
.../nifi/minifi/c2/command/UpdatableProperty.java | 75 ++++
.../command/UpdatePropertiesPropertyProvider.java | 78 ++++
.../c2/FileBasedRequestedOperationDAOTest.java | 114 +++++
.../minifi/c2/command/PropertiesPersisterTest.java | 152 +++++++
.../UpdatePropertiesPropertyProviderTest.java | 87 ++++
.../src/main/resources/conf/bootstrap.conf | 4 -
.../nifi/minifi/bootstrap/BootstrapListener.java | 3 +
.../apache/nifi/minifi/StandardMiNiFiServer.java | 20 +-
minifi/pom.xml | 5 -
.../apache/nifi/components/PropertyDescriptor.java | 19 +-
.../nifi/flow/ParameterProviderReference.java | 1 -
.../apache/nifi/components/EnumAllowableValue.java | 12 +
.../nifi/components/TestPropertyDescriptor.java | 22 +-
nifi-assembly/LICENSE | 25 ++
nifi-assembly/NOTICE | 142 ++++++
nifi-assembly/pom.xml | 23 +-
.../language/antlr/AttributeExpressionLexer.g | 2 +
.../language/antlr/AttributeExpressionParser.g | 5 +-
.../language/compile/ExpressionCompiler.java | 14 +
.../evaluation/functions/GetUriEvaluator.java | 75 ++++
.../literals/StringLiteralEvaluator.java | 64 +--
.../attribute/expression/language/TestQuery.java | 22 +
.../java/org/apache/nifi/util/NiFiProperties.java | 13 +
.../serialization/AbstractRecordSetWriter.java | 3 +-
.../serialization/record/util/DataTypeUtils.java | 22 +-
.../nifi/remote/ClientTransactionCompletion.java | 2 -
.../remote/cluster/NodeInformationAdapter.java | 2 -
.../apache/nifi/web/util/WebUtilsGroovyTest.groovy | 322 --------------
nifi-dependency-check-maven/suppressions.xml | 30 --
nifi-docker/dockerhub/sh/start.sh | 6 +
nifi-docker/dockerhub/sh/update_login_providers.sh | 3 +-
nifi-docker/dockerhub/sh/update_oidc_properties.sh | 27 ++
.../src/main/asciidoc/administration-guide.adoc | 42 +-
.../main/asciidoc/expression-language-guide.adoc | 41 ++
.../images/controller-services-info-buttons.png | Bin 10024 -> 9594 bytes
.../images/reporting-tasks-info-buttons.png | Bin 13352 -> 13815 bytes
nifi-docs/src/main/asciidoc/user-guide.adoc | 6 +-
...ovider.java => ExtensionManifestContainer.java} | 30 +-
.../manifest/ExtensionManifestProvider.java | 4 +-
.../runtime/manifest/RuntimeManifestBuilder.java | 5 +-
.../impl/DirectoryExtensionManifestProvider.java | 55 ++-
.../manifest/impl/RuntimeManifestGenerator.java | 35 +-
.../impl/StandardRuntimeManifestBuilder.java | 46 +-
.../nifi/runtime/manifest/TestRuntimeManifest.java | 3 +
nifi-manifest/nifi-runtime-manifest/pom.xml | 1 -
.../nifi/util/StandardProcessorTestRunner.java | 5 +-
.../nifi-asana-processors-nar}/pom.xml | 34 +-
.../src/main/resources/META-INF}/LICENSE | 0
.../src/main/resources/META-INF/NOTICE | 20 +
.../nifi-asana-processors}/pom.xml | 39 +-
.../nifi/processors/asana/AsanaObjectType.java | 115 +++++
.../nifi/processors/asana/GenericObjectSerDe.java | 57 +++
.../nifi/processors/asana/GetAsanaObject.java | 409 +++++++++++++++++
.../asana/utils/AbstractAsanaObjectFetcher.java | 98 ++---
.../nifi/processors/asana/utils/AsanaObject.java | 72 +++
.../processors/asana/utils/AsanaObjectFetcher.java | 53 +++
.../asana/utils/AsanaObjectFetcherException.java | 20 +-
.../processors/asana/utils/AsanaObjectState.java} | 10 +-
.../asana/utils/AsanaProjectEventFetcher.java | 80 ++++
.../asana/utils/AsanaProjectFetcher.java | 32 +-
.../asana/utils/AsanaProjectMembershipFetcher.java | 58 +++
.../utils/AsanaProjectStatusAttachmentFetcher.java | 66 +++
.../asana/utils/AsanaProjectStatusFetcher.java | 58 +++
.../processors/asana/utils/AsanaStoryFetcher.java | 57 +++
.../processors/asana/utils/AsanaTagFetcher.java | 23 +-
.../asana/utils/AsanaTaskAttachmentFetcher.java | 62 +++
.../processors/asana/utils/AsanaTaskFetcher.java | 105 +++++
.../processors/asana/utils/AsanaTeamFetcher.java | 23 +-
.../asana/utils/AsanaTeamMemberFetcher.java | 58 +++
.../processors/asana/utils/AsanaUserFetcher.java | 23 +-
.../asana/utils/GenericAsanaObjectFetcher.java | 176 ++++++++
.../services/org.apache.nifi.processor.Processor | 30 +-
.../additionalDetails.html | 100 +++++
.../asana/AbstractAsanaObjectFetcherTest.java | 89 ++++
.../nifi/processors/asana/AsanaObjectTest.java | 114 +++++
.../asana/AsanaProjectEventFetcherTest.java | 162 +++++++
.../processors/asana/AsanaProjectFetcherTest.java | 150 +++++++
.../asana/AsanaProjectMembershipFetcherTest.java | 190 ++++++++
.../AsanaProjectStatusAttachmentFetcherTest.java | 247 +++++++++++
.../asana/AsanaProjectStatusFetcherTest.java | 181 ++++++++
.../processors/asana/AsanaStoryFetcherTest.java | 441 +++++++++++++++++++
.../nifi/processors/asana/AsanaTagFetcherTest.java | 140 ++++++
.../asana/AsanaTaskAttachmentFetcherTest.java | 470 ++++++++++++++++++++
.../processors/asana/AsanaTaskFetcherTest.java | 437 ++++++++++++++++++
.../processors/asana/AsanaTeamFetcherTest.java | 142 ++++++
.../asana/AsanaTeamMemberFetcherTest.java | 184 ++++++++
.../processors/asana/AsanaUserFetcherTest.java | 142 ++++++
.../asana/GenericAsanaObjectFetcherTest.java | 213 +++++++++
.../processors/asana/GenericObjectSerDeTest.java | 82 ++++
.../asana/GetAsanaObjectConfigurationTest.java | 447 +++++++++++++++++++
.../asana/GetAsanaObjectLifecycleTest.java | 297 +++++++++++++
.../mocks/MockAbstractAsanaObjectFetcher.java | 55 +++
.../mocks/MockAsanaClientProviderService.java | 27 +-
.../asana/mocks/MockDistributedMapCacheClient.java | 78 ++++
.../asana/mocks/MockGenericAsanaObjectFetcher.java | 30 +-
.../processors/asana/mocks/MockGetAsanaObject.java | 28 +-
.../nifi-asana-services-api-nar}/pom.xml | 35 +-
.../src/main/resources/META-INF/LICENSE | 228 ++++++++++
.../src/main/resources/META-INF/NOTICE | 103 +++++
.../nifi-asana-services-api}/pom.xml | 30 +-
.../apache/nifi/controller/asana/AsanaClient.java | 194 ++++++++
.../controller/asana/AsanaClientException.java} | 11 +-
.../asana/AsanaClientProviderService.java | 18 +-
.../controller/asana/AsanaEventsCollection.java | 33 +-
.../nifi-asana-services-nar}/pom.xml | 34 +-
.../src/main/resources/META-INF}/LICENSE | 0
.../src/main/resources/META-INF/NOTICE | 5 +
.../nifi-asana-services}/pom.xml | 27 +-
.../nifi/controller/asana/StandardAsanaClient.java | 295 +++++++++++++
.../asana/StandardAsanaClientProviderService.java | 101 +++++
.../org.apache.nifi.controller.ControllerService} | 30 +-
.../additionalDetails.html | 91 ++++
.../StandardAsanaClientProviderServiceTest.java | 177 ++++++++
.../pom.xml | 57 ++-
.../nifi/processors/aws/AbstractAWSProcessor.java | 9 +-
.../processors/aws/AwsPropertyDescriptors.java | 52 +++
.../factory/CredentialPropertyDescriptors.java | 57 ++-
.../processors/aws/s3/AbstractS3Processor.java | 51 ++-
.../processors/aws/signer/AwsCustomSignerUtil.java | 53 +++
.../nifi/processors/aws/signer/AwsSignerType.java | 74 ++++
.../strategies/AssumeRoleCredentialsStrategy.java | 95 ++--
.../AWSCredentialsProviderControllerService.java | 10 +-
.../nifi/processors/aws/s3/DeleteS3Object.java | 30 +-
.../nifi/processors/aws/s3/FetchS3Object.java | 28 +-
.../org/apache/nifi/processors/aws/s3/ListS3.java | 62 +--
.../apache/nifi/processors/aws/s3/PutS3Object.java | 48 +-
.../apache/nifi/processors/aws/s3/TagS3Object.java | 28 +-
.../provider/factory/MockAWSProcessor.java | 10 +-
.../factory/TestCredentialsProviderFactory.java | 96 ++--
...WSCredentialsProviderControllerServiceTest.java | 22 +-
.../apache/nifi/processors/aws/s3/ITListS3.java | 27 +-
.../nifi/processors/aws/s3/ITPutS3Object.java | 11 +-
.../nifi/processors/aws/s3/TestDeleteS3Object.java | 4 +-
.../nifi/processors/aws/s3/TestFetchS3Object.java | 4 +-
.../nifi/processors/aws/s3/TestPutS3Object.java | 42 +-
.../nifi/processors/aws/s3/TestTagS3Object.java | 4 +-
.../service/AWSCredentialsProviderService.java | 10 +
nifi-nar-bundles/nifi-aws-bundle/pom.xml | 2 +-
.../AzureKeyVaultSecretsParameterProvider.java | 13 +-
.../TestAzureKeyVaultSecretsParameterProvider.java | 54 +++
.../azure/storage/PutAzureDataLakeStorage.java | 25 +-
.../nifi-box-bundle/nifi-box-services-api/pom.xml | 4 +-
.../nifi-ccda-bundle/nifi-ccda-processors/pom.xml | 5 +
.../processors/ccda/ExtractCCDAAttributes.java | 10 +-
.../processors/ccda/TestExtractCCDAAttributes.java | 32 +-
.../cdc/mysql/processors/CaptureChangeMySQL.java | 8 +-
.../mysql/processors/CaptureChangeMySQLTest.groovy | 4 +
.../nifi/processors/dropbox/DropboxAttributes.java | 40 ++
.../nifi/processors/dropbox/DropboxFileInfo.java | 14 +-
.../dropbox/DropboxFlowFileAttribute.java | 12 +-
.../nifi/processors/dropbox/DropboxTrait.java | 42 +-
.../nifi/processors/dropbox/FetchDropbox.java | 83 +++-
.../nifi/processors/dropbox/ListDropbox.java | 48 +-
.../apache/nifi/processors/dropbox/PutDropbox.java | 358 +++++++++++++++
.../services/org.apache.nifi.processor.Processor | 1 +
.../processors/dropbox/AbstractDropboxTest.java | 128 ++++++
.../nifi/processors/dropbox/FetchDropboxTest.java | 88 ++--
.../nifi/processors/dropbox/ListDropboxTest.java | 97 +---
.../nifi/processors/dropbox/PutDropboxIT.java | 153 +++++++
.../nifi/processors/dropbox/PutDropboxTest.java | 327 ++++++++++++++
.../ElasticSearchClientServiceImpl.java | 31 +-
.../integration/ElasticSearchClientService_IT.java | 101 +++--
.../src/test/resources/setup-6.script | 3 +-
.../src/test/resources/setup-7.script | 3 +-
.../src/test/resources/setup-8.script | 3 +-
.../AbstractJsonQueryElasticsearch.java | 128 ++++--
.../AbstractPaginatedJsonQueryElasticsearch.java | 64 +--
.../elasticsearch/SearchElasticsearch.java | 5 +-
.../api/AggregationResultsFormat.java | 96 ++--
.../elasticsearch/api/PaginationType.java | 56 +++
.../elasticsearch/api/ResultOutputStrategy.java | 59 +++
.../elasticsearch/api/SearchResultsFormat.java | 96 ++--
.../AbstractJsonQueryElasticsearchTest.groovy | 118 ++++-
...tractPaginatedJsonQueryElasticsearchTest.groovy | 44 +-
.../PaginatedJsonQueryElasticsearchTest.groovy | 12 +-
.../elasticsearch/SearchElasticsearchTest.groovy | 32 +-
.../org/apache/nifi/elasticsearch/MapBuilder.java | 4 +-
nifi-nar-bundles/nifi-elasticsearch-bundle/pom.xml | 4 +-
.../nifi-email-processors/pom.xml | 2 +-
.../prometheus/util/ClusterMetricsRegistry.java | 52 +++
.../prometheus/util/PrometheusMetricsUtil.java | 11 +
.../java/org/apache/nifi/json/OutputGrouping.java | 0
.../java/org/apache/nifi/json/WriteJsonResult.java | 2 +-
.../java/org/apache/nifi}/NullSuppression.java | 2 +-
.../nifi/documentation/html/XmlValidator.java | 18 +-
.../CompositeUserGroupProviderTestBase.java | 16 +-
.../ControllerConfigurationEndpointMerger.java | 1 -
.../cluster/integration/ClusterConnectionIT.java | 2 +-
.../org/apache/nifi/cluster/integration/Node.java | 9 +-
.../nifi/controller/StandardProcessorNode.java | 12 +-
.../repository/StandardProcessSession.java | 9 +-
.../repository/io/ContentClaimInputStream.java | 56 ++-
.../service/StandardConfigurationContext.java | 13 +-
.../service/StandardControllerServiceNode.java | 8 +-
.../repository/TestStandardProvenanceReporter.java | 62 ---
...StandardVersionedComponentSynchronizerTest.java | 22 +-
.../controller/cluster/ZooKeeperClientConfig.java | 12 +-
.../election/CuratorLeaderElectionManager.java | 1 +
.../controller/queue/AbstractFlowFileQueue.java | 5 +
.../manifest/StandardRuntimeManifestService.java | 65 ++-
.../EncryptedFileSystemRepositoryTest.groovy | 24 +-
.../serialization/FlowFromDOMFactoryTest.groovy | 9 +-
.../fingerprint/FingerprintFactoryGroovyIT.groovy | 21 +-
.../FingerprintFactoryGroovyTest.groovy | 27 +-
...cryptedSequentialAccessWriteAheadLogTest.groovy | 56 +--
.../apache/nifi/cluster/HeartbeatPayloadTest.java | 12 +-
.../nifi/cluster/ZooKeeperClientConfigTest.java | 42 +-
.../components/LongRunningTaskMonitorTest.java | 6 +-
.../nifi/controller/StandardFlowServiceTest.java | 110 ++---
.../nifi/controller/StandardProcessorNodeIT.java | 243 +++++-----
.../TestEncryptedFileSystemSwapManager.java | 11 +-
.../nifi/controller/TestFileSystemSwapManager.java | 26 +-
.../apache/nifi/controller/TestFlowController.java | 115 +++--
.../nifi/controller/TestStandardFlowFileQueue.java | 56 +--
.../election/TestCuratorACLProviderFactory.java | 12 +-
.../queue/clustered/LoadBalancedQueueIT.java | 71 +--
.../TestContentRepositoryFlowFileAccess.java | 20 +-
.../queue/clustered/TestNaiveLimitThreshold.java | 6 +-
.../TestSocketLoadBalancedFlowFileQueue.java | 45 +-
.../clustered/TestSwappablePriorityQueue.java | 54 +--
.../client/async/nio/TestLoadBalanceSession.java | 57 ++-
.../server/TestStandardLoadBalanceProtocol.java | 49 +--
.../reporting/TestStandardReportingContext.java | 12 +-
.../SchemaRepositoryRecordSerdeTest.java | 14 +-
.../repository/StandardProcessSessionIT.java | 483 +++++++-------------
.../repository/TestFileSystemRepository.java | 90 ++--
.../TestWriteAheadFlowFileRepository.java | 60 ++-
.../claim/TestContentClaimWriteCache.java | 20 +-
.../repository/io/TestContentClaimInputStream.java | 12 +-
.../io/TestFlowFileAccessInputStream.java | 42 +-
.../repository/io/TestLimitedInputStream.java | 13 +-
.../nifi/controller/repository/util/DiskUtils.java | 26 +-
.../scheduling/ProcessorLifecycleIT.java | 20 +-
.../scheduling/TestStandardProcessScheduler.java | 176 ++++----
.../serialization/StandardFlowSerializerTest.java | 14 +-
.../StandardControllerServiceProviderIT.java | 16 +-
.../StandardControllerServiceProviderTest.java | 22 +-
.../TestStandardControllerServiceProvider.java | 104 ++---
.../nifi/controller/state/TestStateMapSerDe.java | 10 +-
.../zookeeper/TestZooKeeperStateProvider.java | 4 +-
.../state/server/ITZooKeeperStateServerTLS.java | 100 ++---
.../TestZooKeeperStateServerConfigurations.java | 60 +--
...TestCachingConnectionStatusAnalyticsEngine.java | 8 +-
.../analytics/TestConnectionStatusAnalytics.java | 166 +++----
.../analytics/TestStatusAnalyticsEngine.java | 39 +-
.../analytics/models/TestOrdinaryLeastSquares.java | 8 +-
.../analytics/models/TestSimpleRegression.java | 5 +-
...EmbeddedQuestDbStatusHistoryRepositoryTest.java | 8 +-
.../AbstractStatusHistoryRepositoryTest.java | 190 ++++----
.../EmbeddedQuestDbRolloverHandlerTest.java | 306 -------------
...DbStatusHistoryRepositoryForComponentsTest.java | 19 +-
...dQuestDbStatusHistoryRepositoryForNodeTest.java | 11 +-
.../JsonNodeStatusHistoryDumpFactoryTest.java | 11 +-
.../status/history/StatusHistoryUtilTest.java | 17 +-
.../status/history/TestMetricRollingBuffer.java | 17 +-
...ComponentStatusRepositoryForComponentsTest.java | 2 +-
...latileComponentStatusRepositoryForNodeTest.java | 103 ++---
.../BufferedWriterForStatusStorageTest.java | 13 +-
.../swap/TestSchemaSwapSerializerDeserializer.java | 36 +-
.../swap/TestSimpleSwapSerializerDeserializer.java | 12 +-
.../nifi/controller/tasks/TestConnectableTask.java | 27 +-
.../events/TestNodeBulletinProcessingStrategy.java | 4 +-
.../nifi/fingerprint/FingerprintFactoryTest.java | 17 +-
.../nifi/integration/FrameworkIntegrationTest.java | 38 +-
.../cs/ControllerServiceReferenceIT.java | 2 +-
.../flowfilerepo/OOMEFlowFileRepoUpdateIT.java | 4 +-
.../integration/lifecycle/ContentCleanupIT.java | 10 +-
.../nifi/integration/parameters/ParametersIT.java | 22 +-
.../processgroup/StandardProcessGroupIT.java | 17 +-
.../processor/ProcessorParameterTokenIT.java | 13 +-
.../nifi/integration/swap/ClusteredSwapFileIT.java | 251 -----------
.../nifi/integration/versioned/ImportFlowIT.java | 2 +-
.../election/ITSecureClientZooKeeperFactory.java | 18 +-
.../nifi/persistence/TemplateSerializerTest.java | 4 +-
.../flow/mapping/NiFiRegistryFlowMapperTest.java | 37 +-
.../nifi/util/TestFileBasedVariableRegistry.java | 6 +-
.../java/org/apache/nifi/nar/NarAutoLoader.java | 12 +-
...pertyBasedNarProviderInitializationContext.java | 28 +-
.../nifi/nar/NarThreadContextClassLoaderTest.java | 36 +-
.../java/org/apache/nifi/nar/NarUnpackerTest.java | 15 +-
.../apache/nifi/nar/TestInstanceClassLoader.java | 10 +-
.../AbstractNativeLibHandlingClassLoaderTest.java | 102 +----
.../apache/nifi/nar/LoadNativeLibAspectTest.java | 14 +-
.../org/apache/nifi/nar/NarBundleUtilTest.java | 13 +-
.../repository/TestStandardRepositoryRecord.java | 8 +-
.../claim/TestStandardResourceClaimManager.java | 96 +---
.../nifi-framework/nifi-resources/pom.xml | 1 +
.../src/main/resources/conf/nifi.properties | 1 +
.../authorization/ShellUserGroupProviderIT.java | 387 ----------------
.../remote/SocketRemoteSiteListenerTest.groovy | 24 +-
.../remote/StandardPublicPortGroovyTest.groovy | 114 -----
.../nifi/remote/TestHttpRemoteSiteListener.java | 56 +--
.../nifi/remote/TestPeerDescriptionModifier.java | 96 ++--
.../nifi/remote/TestSocketRemoteSiteListener.java | 11 +-
.../apache/nifi/remote/TestStandardPublicPort.java | 18 +-
.../nifi/remote/TestStandardRemoteGroupPort.java | 10 +-
.../remote/TestStandardSiteToSiteProtocol.java | 116 -----
.../http/TestHttpFlowFileServerProtocol.java | 106 ++---
.../socket/TestSocketFlowFileServerProtocol.java | 8 +-
.../prioritizer/NewestFirstPrioritizerTest.java | 20 +-
.../prioritizer/OldestFirstPrioritizerTest.java | 25 +-
.../PriorityAttributePrioritizerTest.java | 34 +-
.../org/apache/nifi/web/server/JettyServer.java | 22 +-
.../nifi/web/server/HostHeaderHandlerTest.groovy | 21 +-
.../web/server/util/TrustStoreScannerTest.java | 10 +-
.../org/apache/nifi/audit/ProcessGroupAuditor.java | 17 +-
.../apache/nifi/web/StandardNiFiServiceFacade.java | 27 +-
.../org/apache/nifi/web/api/dto/DtoFactory.java | 1 -
.../nifi/web/api/request/FlowMetricsRegistry.java | 5 +-
.../org/apache/nifi/web/util/SnippetUtils.java | 10 +
.../nifi/web/api/ApplicationResourceTest.groovy | 21 +-
.../nifi/web/api/ProcessGroupResourceTest.groovy | 26 +-
...JsonContentConversionExceptionMapperTest.groovy | 24 +-
.../apache/nifi/audit/TestProcessGroupAuditor.java | 143 ++++++
.../nifi/audit/TestRemoteProcessGroupAuditor.java | 14 +-
.../StandardAuthorizableLookupTest.java | 4 +-
...iFiWebApiTest.java => NiFiWebApiFlowUtils.java} | 7 +-
.../accesscontrol/AccessControlHelper.java | 6 +-
.../accesscontrol/ITConnectionAccessControl.java | 20 +-
.../accesscontrol/ITCountersAccessControl.java | 12 +-
.../accesscontrol/ITFlowAccessControl.java | 12 +-
.../accesscontrol/ITFunnelAccessControl.java | 20 +-
.../accesscontrol/ITInputPortAccessControl.java | 20 +-
.../accesscontrol/ITLabelAccessControl.java | 20 +-
.../accesscontrol/ITOutputPortAccessControl.java | 20 +-
.../accesscontrol/ITProcessGroupAccessControl.java | 20 +-
.../accesscontrol/ITProcessorAccessControl.java | 24 +-
.../anonymous/ITAllowDirectAnonymousAccess.java | 19 +-
.../anonymous/ITAllowProxiedAnonymousAccess.java | 19 +-
.../anonymous/ITPreventDirectAnonymousAccess.java | 15 +-
.../anonymous/ITPreventProxiedAnonymousAccess.java | 15 +-
.../nifi/web/StandardNiFiServiceFacadeTest.java | 81 ++--
.../nifi/web/api/OIDCAccessResourceTest.java | 2 +-
.../nifi/web/api/TestDataTransferResource.java | 10 +-
.../org/apache/nifi/web/api/TestFlowResource.java | 27 +-
.../nifi/web/api/TestProcessGroupResource.java | 10 +-
.../nifi/web/api/TestSiteToSiteResource.java | 42 +-
.../apache/nifi/web/api/TestVersionsResource.java | 10 +-
.../apache/nifi/web/api/dto/DtoFactoryTest.java | 112 +++++
.../web/api/filter/TestRedirectResourceFilter.java | 44 +-
.../AbstractControllerSearchIntegrationTest.java | 10 +-
.../nifi/web/controller/ControllerFacadeTest.java | 15 +-
.../ControllerSearchServiceFilterTest.java | 2 +-
.../ControllerSearchServiceIntegrationTest.java | 22 +-
.../ControllerSearchServiceRegressionTest.java | 2 +-
.../controller/ControllerSearchServiceTest.java | 59 +--
.../nifi/web/controller/SearchResultMatcher.java | 2 +-
.../impl/TestStandardRemoteProcessGroupDAO.java | 13 +-
.../search/AttributeBasedComponentMatcherTest.java | 36 +-
.../AbstractAttributeMatcherTest.java | 25 +-
.../attributematchers/AttributeMatcherTest.java | 40 +-
.../attributematchers/BackPressureMatcherTest.java | 19 +-
.../search/attributematchers/BasicMatcherTest.java | 13 +-
.../attributematchers/ConnectionMatcherTest.java | 16 +-
.../ConnectionRelationshipMatcherTest.java | 2 +-
.../attributematchers/ConnectivityMatcherTest.java | 6 +-
.../ControllerServiceNodeMatcherTest.java | 18 +-
.../attributematchers/ExecutionMatcherTest.java | 3 +-
.../attributematchers/ExpirationMatcherTest.java | 19 +-
.../attributematchers/ExtendedMatcherTest.java | 18 +-
.../search/attributematchers/LabelMatcherTest.java | 14 +-
.../ParameterContextMatcherTest.java | 16 +-
.../attributematchers/ParameterMatcherTest.java | 9 +-
.../PortScheduledStateMatcherTest.java | 9 +-
.../attributematchers/PrioritiesMatcherTest.java | 6 +-
.../attributematchers/ProcessGroupMatcherTest.java | 7 +-
.../ProcessorMetadataMatcherTest.java | 3 +-
.../attributematchers/PropertyMatcherTest.java | 9 +-
.../attributematchers/PublicPortMatcherTest.java | 15 +-
.../attributematchers/RelationshipMatcherTest.java | 2 +-
.../RemoteProcessGroupMatcherTest.java | 19 +-
.../ScheduledStateMatcherTest.java | 4 +-
.../attributematchers/SchedulingMatcherTest.java | 2 +-
.../attributematchers/SearchableMatcherTest.java | 12 +-
.../attributematchers/TargetUriMatcherTest.java | 10 +-
.../TransmissionStatusMatcherTest.java | 2 +-
.../VariableRegistryMatcherTest.java | 6 +-
.../search/query/RegexSearchQueryParserTest.java | 53 +--
.../ComponentSearchResultEnricherTest.java | 75 ++--
.../org/apache/nifi/web/util/SnippetUtilsTest.java | 17 +-
.../nifi/web/filter/CatchAllFilterTest.groovy | 23 +-
.../web/security/ProxiedEntitiesUtilsTest.groovy | 75 ++--
.../web/security/oidc/OidcServiceGroovyTest.groovy | 30 +-
.../StandardOidcIdentityProviderGroovyTest.groovy | 150 +++----
.../requests/ContentLengthFilterTest.groovy | 62 +--
.../security/NiFiAuthenticationProviderTest.java | 12 +-
.../web/security/TestProxiedEntitiesUtils.java | 8 +-
.../NiFiAnonymousAuthenticationProviderTest.java | 21 +-
.../StandardJwtAuthenticationConverterTest.java | 16 +-
.../jwt/jws/StandardJwsSignerProviderTest.java | 16 +-
.../jwt/key/command/KeyGenerationCommandTest.java | 14 +-
.../StandardVerificationKeyServiceTest.java | 26 +-
.../resolver/StandardBearerTokenResolverTest.java | 16 +-
.../jwt/revocation/JwtRevocationValidatorTest.java | 16 +-
.../revocation/StandardJwtLogoutListenerTest.java | 18 +-
.../StandardJwtRevocationServiceTest.java | 22 +-
.../knox/KnoxAuthenticationFilterTest.java | 22 +-
.../nifi/web/security/knox/KnoxServiceTest.java | 53 +--
.../security/logout/TestLogoutRequestManager.java | 12 +-
.../nifi/web/security/oidc/OidcServiceTest.java | 46 +-
.../oidc/StandardOidcIdentityProviderTest.java | 10 +-
.../x509/X509AuthenticationProviderTest.java | 72 ++-
.../x509/ocsp/OcspCertificateValidatorTest.java | 74 ++--
.../webapp/js/nf/canvas/nf-controller-services.js | 38 +-
.../src/main/webapp/js/nf/canvas/nf-settings.js | 42 +-
.../nifi-web-ui/src/main/webapp/js/nf/nf-common.js | 15 +
.../gcp/pubsub/lite/ConsumeGCPubSubLite.java | 2 +-
.../nifi-hazelcast-services/pom.xml | 2 +-
.../iceberg/converter/ArrayElementGetter.java | 17 +-
.../iceberg/converter/RecordFieldGetter.java | 18 +-
.../iceberg/TestIcebergRecordConverter.java | 67 ++-
.../nifi-iotdb-nar}/pom.xml | 39 +-
.../nifi-iotdb-processors/pom.xml | 108 +++++
.../org/apache/nifi/processors/AbstractIoTDB.java | 359 +++++++++++++++
.../org/apache/nifi/processors/PutIoTDBRecord.java | 248 +++++++++++
.../nifi/processors/model/DatabaseField.java | 113 +++++
.../nifi/processors/model/DatabaseSchema.java | 82 ++++
.../nifi/processors/model/ValidationResult.java | 23 +-
.../services/org.apache.nifi.processor.Processor | 2 +-
.../apache/nifi/processors/AbstractIoTDBTest.java | 243 ++++++++++
.../apache/nifi/processors/PutIoTDBRecordIT.java | 212 +++++++++
.../apache/nifi/processors/PutIoTDBRecordTest.java | 59 +++
.../{nifi-aws-bundle => nifi-iotdb-bundle}/pom.xml | 29 +-
nifi-nar-bundles/nifi-media-bundle/pom.xml | 2 +-
.../nifi-mongodb-client-service-api/pom.xml | 10 +-
.../nifi-mongodb-processors/pom.xml | 4 +-
.../processors/mongodb/AbstractMongoProcessor.java | 32 +-
.../processors/mongodb/GetMongoRecordIT.groovy | 182 --------
.../mongodb/AbstractMongoProcessorTest.java | 11 +-
.../apache/nifi/processors/mongodb/GetMongoIT.java | 37 +-
.../processors/mongodb/MongoWriteTestBase.java | 6 +-
.../nifi/processors/mongodb/PutMongoRecordIT.java | 39 --
.../processors/mongodb/RunMongoAggregationIT.java | 6 +-
.../mongodb/gridfs/GridFSITTestBase.java | 7 +-
.../nifi-mongodb-services/pom.xml | 4 +-
.../nifi/mongodb/MongoDBControllerService.java | 28 +-
.../java/org/apache/nifi/mongodb/Validation.java | 47 --
.../nifi/mongodb/MongoDBControllerServiceIT.java | 4 +-
nifi-nar-bundles/nifi-mongodb-bundle/pom.xml | 7 +-
.../nifi/parquet/ParquetRecordSetWriter.java | 2 +-
.../nifi/parquet/record/WriteParquetResult.java | 19 +-
.../nifi/parquet/TestParquetRecordSetWriter.java | 26 +-
.../nifi-poi-bundle/nifi-poi-processors/pom.xml | 2 +-
.../src/main/resources/META-INF/LICENSE | 239 ++++++++++
.../src/main/resources/META-INF/NOTICE | 125 ++++++
.../processors/salesforce/PutSalesforceObject.java | 207 +++++++++
.../salesforce/QuerySalesforceObject.java | 42 +-
.../util/CommonSalesforceProperties.java | 66 +++
.../processors/salesforce/util/RecordExtender.java | 87 ++++
.../salesforce/util/SalesforceRestService.java | 21 +-
.../services/org.apache.nifi.processor.Processor | 1 +
.../additionalDetails.html | 71 +++
.../salesforce/PutSalesforceObjectIT.java | 86 ++++
.../salesforce/QuerySalesforceObjectIT.java | 7 +-
.../SalesforceToRecordSchemaConverterTest.java | 1 -
.../salesforce/util/TestRecordExtender.java | 119 +++++
.../src/test/resources/json/put_records.json | 37 ++
.../lookup/script/BaseScriptedLookupService.java | 97 +++-
.../nifi/script/ScriptingComponentHelper.java | 20 +-
.../lookup/script/TestScriptedLookupService.groovy | 25 +-
.../nifi/processors/script/TestInvokeJython.java | 13 +-
.../script/TestScriptedFilterRecord.java | 9 +-
.../script/TestScriptedPartitionRecord.java | 22 +-
.../script/TestScriptedRouterProcessor.java | 11 +-
.../script/TestScriptedValidateRecord.java | 13 +-
.../engine/script/ScriptedRulesEngineTest.java | 2 +-
.../handlers/script/ScriptedActionHandlerTest.java | 6 +-
.../groovy/test_simple_lookup_inline.groovy | 4 +-
nifi-nar-bundles/nifi-snowflake-bundle/pom.xml | 2 +-
.../nifi-twitter-processors/pom.xml | 2 +-
.../processors/twitter/TweetStreamService.java | 28 +-
.../nifi/processors/splunk/TestPutSplunkHTTP.java | 4 -
.../nifi-standard-content-viewer/pom.xml | 5 -
.../nifi/web/StandardContentViewerController.java | 16 +-
.../nifi-standard-processors/pom.xml | 8 +
.../nifi/processors/standard/EvaluateJsonPath.java | 102 +++--
.../nifi/processors/standard/GenerateRecord.java | 415 ++++++++++++++++++
.../nifi/processors/standard/ReplaceText.java | 92 +++-
.../apache/nifi/processors/standard/SplitJson.java | 6 +-
.../nifi/processors/standard/TransformXml.java | 38 +-
.../standard/faker/FakerMethodHolder.java | 38 +-
.../nifi/processors/standard/faker/FakerUtils.java | 188 ++++++++
.../nifi/processors/standard/util/FTPTransfer.java | 1 -
.../services/org.apache.nifi.processor.Processor | 1 +
.../processors/standard/TestEvaluateJsonPath.java | 109 +++--
.../processors/standard/TestGenerateRecord.java | 273 ++++++++++++
.../standard/TestGenerateTableFetch.java | 4 +-
.../nifi/processors/standard/TestHashContent.java | 13 -
.../nifi/processors/standard/TestReplaceText.java | 35 ++
.../nifi/processors/standard/TestSplitJson.java | 34 ++
.../nifi/processors/standard/TestTransformXml.java | 55 +++
.../TestGenerateRecord/nested_no_nullable.avsc | 52 +++
.../TestGenerateRecord/nested_nullable.avsc | 52 +++
.../test/resources/TestTransformXml/employee.html | 35 ++
.../test/resources/TestTransformXml/employee.xml | 41 +-
.../employeeMessageNonTerminate.xsl | 50 +++
.../TestTransformXml/employeeMessageTerminate.xsl | 50 +++
.../TestTransformXml/nonMatchingEndTag.xsl | 35 +-
nifi-nar-bundles/nifi-standard-bundle/pom.xml | 5 -
.../nifi/oauth2/ClientAuthenticationStrategy.java | 94 ++--
.../oauth2/StandardOauth2AccessTokenProvider.java | 59 ++-
.../StandardOauth2AccessTokenProviderTest.java | 90 +++-
.../nifi-record-serialization-services/pom.xml | 2 +
.../java/org/apache/nifi/csv/WriteCSVResult.java | 2 +
.../org/apache/nifi/json/JsonRecordSetWriter.java | 2 +-
.../org/apache/nifi/json/JsonSchemaInference.java | 5 +
.../inference/HierarchicalSchemaInference.java | 94 +++-
.../inference/InferSchemaAccessStrategy.java | 2 +-
.../java/org/apache/nifi/xml/WriteXMLResult.java | 2 +-
.../org/apache/nifi/xml/XMLRecordSetWriter.java | 2 +-
.../nifi/xml/inference/XmlSchemaInference.java | 5 +
.../org/apache/nifi/csv/TestWriteCSVResult.java | 22 +
.../apache/nifi/json/TestJsonSchemaInference.java | 77 +++-
.../org/apache/nifi/json/TestWriteJsonResult.java | 48 +-
.../org/apache/nifi/xml/TestWriteXMLResult.java | 6 +-
.../choice-of-array-empty-or-array-record.json | 59 +++
.../src/test/resources/json/empty-arrays.json | 13 +
.../org/apache/nifi/record/sink/TestProcessor.java | 1 -
.../processors/stateless/TestExecuteStateless.java | 10 +-
.../retrieval/TestCachingDataflowProvider.java | 12 +-
nifi-nar-bundles/pom.xml | 2 +
.../bundle/extract/nar/NarBundleExtractor.java | 4 +-
.../bundle/extract/nar/TestNarBundleExtractor.java | 10 +-
.../nifi-registry-docker/dockerhub/sh/start.sh | 8 +-
.../dockerhub/sh/update_oidc_properties.sh | 27 ++
.../ApplicationServerConnectorFactory.java | 2 +-
.../ApplicationServerConnectorFactoryTest.java | 4 +-
.../src/main/package-lock.json | 488 +++++++++++++++------
.../dockermaven/sh/start.sh | 9 +-
.../dockermaven/sh/update_oidc_properties.sh | 27 ++
.../nar/provider/LocalDirectoryNarProvider.java | 67 +++
...che.nifi.flow.resource.ExternalResourceProvider | 3 +-
.../nifi-nar-provider-assembly}/pom.xml | 96 ++--
.../src/main/assembly/dependencies.xml} | 34 +-
.../nifi-nar-provider-processors-nar}/pom.xml | 32 +-
.../nifi-nar-provider-processors}/pom.xml | 42 +-
.../nifi/nar/provider/GetClassLoaderInfo.java | 94 ++++
.../services/org.apache.nifi.processor.Processor | 2 +-
.../nifi-nar-provider-service-api-nar}/pom.xml | 32 +-
.../nifi-nar-provider-service-api}/pom.xml | 25 +-
.../nifi/nar/provider/ClassLoaderInfoService.java | 17 +-
.../nifi-nar-provider-service-nar}/pom.xml | 32 +-
.../nifi-nar-provider-service}/pom.xml | 41 +-
.../provider/StandardClassLoaderInfoService.java | 61 +++
.../org.apache.nifi.controller.ControllerService | 2 +-
.../pom.xml | 25 +-
nifi-system-tests/nifi-system-test-suite/pom.xml | 26 +-
.../src/test/assembly/dependencies.xml | 1 +
.../SpawnedStandaloneNiFiInstanceFactory.java | 6 +
.../system/nar/NarProviderAndAutoLoaderIT.java | 82 ++++
.../src/test/resources/conf/default/bootstrap.conf | 2 +-
nifi-system-tests/pom.xml | 1 +
pom.xml | 14 +-
612 files changed, 22256 insertions(+), 7888 deletions(-)
rename
c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/{C2OperationService.java
=> C2OperationHandlerProvider.java} (72%)
create mode 100644
c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/OperationQueue.java
copy
c2/{c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/RequestedOperationDAO.java}
(57%)
create mode 100644
c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/UpdatePropertiesOperationHandler.java
rename
c2/c2-client-bundle/c2-client-service/src/test/java/org/apache/nifi/c2/client/service/operation/{C2OperationServiceTest.java
=> C2OperationHandlerProviderTest.java} (73%)
create mode 100644
c2/c2-client-bundle/c2-client-service/src/test/java/org/apache/nifi/c2/client/service/operation/UpdatePropertiesOperationHandlerTest.java
create mode 100644
minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/UpdateConfigurationService.java
create mode 100644
minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/service/UpdatePropertiesService.java
create mode 100644 minifi/minifi-commons/minifi-commons-api/pom.xml
copy
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/record/NullSuppression.java
=>
minifi/minifi-commons/minifi-commons-api/src/main/java/org/apache/nifi/minifi/commons/api/MiNiFiCommandState.java
(78%)
copy
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/record/NullSuppression.java
=>
minifi/minifi-commons/minifi-commons-api/src/main/java/org/apache/nifi/minifi/commons/api/MiNiFiConstants.java
(79%)
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/MiNiFiProperties.java
delete mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/C2NiFiProperties.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/FileBasedRequestedOperationDAO.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/command/AgentPropertyValidationContext.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/command/PropertiesPersister.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/command/UpdatableProperty.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/command/UpdatePropertiesPropertyProvider.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/c2/FileBasedRequestedOperationDAOTest.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/c2/command/PropertiesPersisterTest.java
create mode 100644
minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-framework-core/src/test/java/org/apache/nifi/minifi/c2/command/UpdatePropertiesPropertyProviderTest.java
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/GetUriEvaluator.java
delete mode 100644
nifi-commons/nifi-web-utils/src/test/groovy/org/apache/nifi/web/util/WebUtilsGroovyTest.groovy
create mode 100644 nifi-docker/dockerhub/sh/update_oidc_properties.sh
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/{ExtensionManifestProvider.java
=> ExtensionManifestContainer.java} (50%)
copy nifi-nar-bundles/{nifi-aws-bundle =>
nifi-asana-bundle/nifi-asana-processors-nar}/pom.xml (64%)
copy
{minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-resources
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors-nar/src/main/resources/META-INF}/LICENSE
(100%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors-nar/src/main/resources/META-INF/NOTICE
copy nifi-nar-bundles/{nifi-hazelcast-bundle/nifi-hazelcast-services =>
nifi-asana-bundle/nifi-asana-processors}/pom.xml (73%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/AsanaObjectType.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/GenericObjectSerDe.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/GetAsanaObject.java
copy nifi-api/src/test/java/org/apache/nifi/components/EnumAllowableValue.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AbstractAsanaObjectFetcher.java
(56%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaObject.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaObjectFetcher.java
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaObjectFetcherException.java
(69%)
copy
nifi-nar-bundles/{nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/OutputGrouping.java
=>
nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaObjectState.java}
(87%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaProjectEventFetcher.java
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaProjectFetcher.java
(57%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaProjectMembershipFetcher.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaProjectStatusAttachmentFetcher.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaProjectStatusFetcher.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaStoryFetcher.java
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaTagFetcher.java
(63%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaTaskAttachmentFetcher.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaTaskFetcher.java
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaTeamFetcher.java
(63%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaTeamMemberFetcher.java
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/AsanaUserFetcher.java
(63%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/java/org/apache/nifi/processors/asana/utils/GenericAsanaObjectFetcher.java
copy nifi-nar-bundles/{nifi-salesforce-bundle/nifi-salesforce-processors =>
nifi-asana-bundle/nifi-asana-processors}/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
(92%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/main/resources/docs/org.apache.nifi.processors.asana.GetAsanaObject/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AbstractAsanaObjectFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaObjectTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaProjectEventFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaProjectFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaProjectMembershipFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaProjectStatusAttachmentFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaProjectStatusFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaStoryFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaTagFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaTaskAttachmentFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaTaskFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaTeamFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaTeamMemberFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/AsanaUserFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/GenericAsanaObjectFetcherTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/GenericObjectSerDeTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/GetAsanaObjectConfigurationTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/GetAsanaObjectLifecycleTest.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/mocks/MockAbstractAsanaObjectFetcher.java
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/mocks/MockAsanaClientProviderService.java
(61%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/mocks/MockDistributedMapCacheClient.java
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/mocks/MockGenericAsanaObjectFetcher.java
(60%)
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-processors/src/test/java/org/apache/nifi/processors/asana/mocks/MockGetAsanaObject.java
(58%)
copy nifi-nar-bundles/{nifi-aws-bundle =>
nifi-asana-bundle/nifi-asana-services-api-nar}/pom.xml (64%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-api-nar/src/main/resources/META-INF/LICENSE
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-api-nar/src/main/resources/META-INF/NOTICE
copy nifi-nar-bundles/{nifi-aws-bundle =>
nifi-asana-bundle/nifi-asana-services-api}/pom.xml (63%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-api/src/main/java/org/apache/nifi/controller/asana/AsanaClient.java
copy
nifi-nar-bundles/{nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/record/NullSuppression.java
=>
nifi-asana-bundle/nifi-asana-services-api/src/main/java/org/apache/nifi/controller/asana/AsanaClientException.java}
(81%)
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-api/src/main/java/org/apache/nifi/controller/asana/AsanaClientProviderService.java
(61%)
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-api/src/main/java/org/apache/nifi/controller/asana/AsanaEventsCollection.java
(58%)
copy nifi-nar-bundles/{nifi-aws-bundle =>
nifi-asana-bundle/nifi-asana-services-nar}/pom.xml (64%)
copy
{minifi/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-resources
=>
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-nar/src/main/resources/META-INF}/LICENSE
(100%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services-nar/src/main/resources/META-INF/NOTICE
copy nifi-nar-bundles/{nifi-mongodb-bundle/nifi-mongodb-client-service-api =>
nifi-asana-bundle/nifi-asana-services}/pom.xml (76%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services/src/main/java/org/apache/nifi/controller/asana/StandardAsanaClient.java
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services/src/main/java/org/apache/nifi/controller/asana/StandardAsanaClientProviderService.java
copy
nifi-nar-bundles/{nifi-salesforce-bundle/nifi-salesforce-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
=>
nifi-asana-bundle/nifi-asana-services/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService}
(90%)
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services/src/main/resources/docs/org.apache.nifi.controller.asana.AsanaClientService/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-asana-bundle/nifi-asana-services/src/test/java/org/apache/nifi/controller/asana/StandardAsanaClientProviderServiceTest.java
copy nifi-nar-bundles/{nifi-media-bundle => nifi-asana-bundle}/pom.xml (52%)
create mode 100644
nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/AwsPropertyDescriptors.java
create mode 100644
nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/signer/AwsCustomSignerUtil.java
create mode 100644
nifi-nar-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/signer/AwsSignerType.java
create mode 100644
nifi-nar-bundles/nifi-dropbox-bundle/nifi-dropbox-processors/src/main/java/org/apache/nifi/processors/dropbox/DropboxAttributes.java
create mode 100644
nifi-nar-bundles/nifi-dropbox-bundle/nifi-dropbox-processors/src/main/java/org/apache/nifi/processors/dropbox/PutDropbox.java
create mode 100644
nifi-nar-bundles/nifi-dropbox-bundle/nifi-dropbox-processors/src/test/java/org/apache/nifi/processors/dropbox/AbstractDropboxTest.java
create mode 100644
nifi-nar-bundles/nifi-dropbox-bundle/nifi-dropbox-processors/src/test/java/org/apache/nifi/processors/dropbox/PutDropboxIT.java
create mode 100644
nifi-nar-bundles/nifi-dropbox-bundle/nifi-dropbox-processors/src/test/java/org/apache/nifi/processors/dropbox/PutDropboxTest.java
copy nifi-api/src/test/java/org/apache/nifi/components/EnumAllowableValue.java
=>
nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/AggregationResultsFormat.java
(57%)
create mode 100644
nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/PaginationType.java
create mode 100644
nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/ResultOutputStrategy.java
copy nifi-api/src/test/java/org/apache/nifi/components/EnumAllowableValue.java
=>
nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/SearchResultsFormat.java
(57%)
create mode 100644
nifi-nar-bundles/nifi-extension-utils/nifi-prometheus-utils/src/main/java/org/apache/nifi/prometheus/util/ClusterMetricsRegistry.java
rename
nifi-nar-bundles/{nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services
=>
nifi-extension-utils/nifi-record-utils/nifi-json-record-utils}/src/main/java/org/apache/nifi/json/OutputGrouping.java
(100%)
rename
nifi-nar-bundles/{nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services
=>
nifi-extension-utils/nifi-record-utils/nifi-json-record-utils}/src/main/java/org/apache/nifi/json/WriteJsonResult.java
(99%)
rename
nifi-nar-bundles/{nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/record
=>
nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/src/main/java/org/apache/nifi}/NullSuppression.java
(96%)
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/test/java/org/apache/nifi/controller/repository/TestStandardProvenanceReporter.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/status/history/EmbeddedQuestDbRolloverHandlerTest.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/integration/swap/ClusteredSwapFileIT.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-shell-authorizer/src/test/java/org/apache/nifi/authorization/ShellUserGroupProviderIT.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/test/groovy/org/apache/nifi/remote/StandardPublicPortGroovyTest.groovy
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/test/java/org/apache/nifi/remote/TestStandardSiteToSiteProtocol.java
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/audit/TestProcessGroupAuditor.java
rename
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/integration/{NiFiWebApiTest.java
=> NiFiWebApiFlowUtils.java} (99%)
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/test/java/org/apache/nifi/web/api/dto/DtoFactoryTest.java
copy nifi-nar-bundles/{nifi-aws-bundle =>
nifi-iotdb-bundle/nifi-iotdb-nar}/pom.xml (52%)
create mode 100644
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/pom.xml
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/main/java/org/apache/nifi/processors/AbstractIoTDB.java
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/main/java/org/apache/nifi/processors/PutIoTDBRecord.java
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/main/java/org/apache/nifi/processors/model/DatabaseField.java
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/main/java/org/apache/nifi/processors/model/DatabaseSchema.java
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/main/java/org/apache/nifi/processors/model/ValidationResult.java
(66%)
mode change 100644 => 100755
copy nifi-nar-bundles/{nifi-salesforce-bundle/nifi-salesforce-processors =>
nifi-iotdb-bundle/nifi-iotdb-processors}/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
(92%)
mode change 100644 => 100755
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/test/java/org/apache/nifi/processors/AbstractIoTDBTest.java
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/test/java/org/apache/nifi/processors/PutIoTDBRecordIT.java
create mode 100755
nifi-nar-bundles/nifi-iotdb-bundle/nifi-iotdb-processors/src/test/java/org/apache/nifi/processors/PutIoTDBRecordTest.java
copy nifi-nar-bundles/{nifi-aws-bundle => nifi-iotdb-bundle}/pom.xml (70%)
delete mode 100644
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/test/groovy/org/apache/nifi/processors/mongodb/GetMongoRecordIT.groovy
delete mode 100644
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-services/src/main/java/org/apache/nifi/mongodb/Validation.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-nar/src/main/resources/META-INF/LICENSE
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-nar/src/main/resources/META-INF/NOTICE
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/PutSalesforceObject.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/util/CommonSalesforceProperties.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/util/RecordExtender.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/resources/docs/org.apache.nifi.processors.salesforce.PutSalesforceObject/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/test/java/org/apache/nifi/processors/salesforce/PutSalesforceObjectIT.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/test/java/org/apache/nifi/processors/salesforce/util/TestRecordExtender.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/test/resources/json/put_records.json
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateRecord.java
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/OperandType.java
=>
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/faker/FakerMethodHolder.java
(51%)
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/faker/FakerUtils.java
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestGenerateRecord.java
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestGenerateRecord/nested_no_nullable.avsc
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestGenerateRecord/nested_nullable.avsc
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestTransformXml/employee.html
copy nifi-system-tests/pom.xml =>
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestTransformXml/employee.xml
(50%)
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestTransformXml/employeeMessageNonTerminate.xsl
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestTransformXml/employeeMessageTerminate.xsl
copy nifi-system-tests/pom.xml =>
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestTransformXml/nonMatchingEndTag.xsl
(52%)
copy nifi-api/src/test/java/org/apache/nifi/components/EnumAllowableValue.java
=>
nifi-nar-bundles/nifi-standard-services/nifi-oauth2-provider-bundle/nifi-oauth2-provider-service/src/main/java/org/apache/nifi/oauth2/ClientAuthenticationStrategy.java
(55%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/resources/json/choice-of-array-empty-or-array-record.json
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/resources/json/empty-arrays.json
create mode 100644
nifi-registry/nifi-registry-core/nifi-registry-docker/dockerhub/sh/update_oidc_properties.sh
create mode 100644
nifi-registry/nifi-registry-docker-maven/dockermaven/sh/update_oidc_properties.sh
create mode 100644
nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/nar/provider/LocalDirectoryNarProvider.java
copy
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
=>
nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/resources/META-INF/services/org.apache.nifi.flow.resource.ExternalResourceProvider
(92%)
copy {nifi-nar-bundles/nifi-poi-bundle/nifi-poi-processors =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-assembly}/pom.xml
(51%)
copy nifi-system-tests/{pom.xml =>
nifi-system-test-nar-provider-bundles/nifi-nar-provider-assembly/src/main/assembly/dependencies.xml}
(50%)
copy {nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-client-service-api =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-processors-nar}/pom.xml
(65%)
copy {nifi-nar-bundles/nifi-hazelcast-bundle/nifi-hazelcast-services =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-processors}/pom.xml
(70%)
create mode 100644
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-processors/src/main/java/org/apache/nifi/nar/provider/GetClassLoaderInfo.java
copy {nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-processors}/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
(92%)
copy {nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-client-service-api =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service-api-nar}/pom.xml
(65%)
copy {nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-client-service-api =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service-api}/pom.xml
(63%)
copy
nifi-manifest/nifi-runtime-manifest-core/src/main/java/org/apache/nifi/runtime/manifest/ExtensionManifestProvider.java
=>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service-api/src/main/java/org/apache/nifi/nar/provider/ClassLoaderInfoService.java
(67%)
copy {nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-client-service-api =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service-nar}/pom.xml
(65%)
copy {nifi-nar-bundles/nifi-hazelcast-bundle/nifi-hazelcast-services =>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service}/pom.xml
(71%)
create mode 100644
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service/src/main/java/org/apache/nifi/nar/provider/StandardClassLoaderInfoService.java
copy
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
=>
nifi-system-tests/nifi-system-test-nar-provider-bundles/nifi-nar-provider-service/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService
(92%)
copy nifi-system-tests/{ => nifi-system-test-nar-provider-bundles}/pom.xml
(56%)
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/nar/NarProviderAndAutoLoaderIT.java
