This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
from fb7dc98326 NIFI-5941 set default LogAttribute and LogMessage level to
TRACE in logback.xml to cover all usage scenarios
add 5e8f7c53b1 NIFI-15420 Added Checkstyle rule for import ordering
(#10725)
No new revisions were added by this update.
Summary of changes:
.../org/apache/nifi/c2/client/api/C2Client.java | 7 +-
.../org/apache/nifi/c2/client/C2ClientConfig.java | 9 +-
.../nifi/c2/serializer/C2JacksonSerializer.java | 9 +-
.../apache/nifi/c2/serializer/C2Serializer.java | 1 +
.../apache/nifi/c2/client/http/C2HttpClient.java | 25 +-
.../nifi/c2/client/http/C2RequestCompression.java | 5 +-
.../nifi/c2/client/http/OkHttpClientProvider.java | 13 +-
.../c2/client/http/url/C2UrlProviderFactory.java | 4 +-
.../c2/client/http/url/LegacyC2UrlProvider.java | 3 +-
.../client/http/url/ProxyAwareC2UrlProvider.java | 11 +-
.../c2/client/http/C2RequestCompressionTest.java | 21 +-
.../client/http/url/C2UrlProviderFactoryTest.java | 10 +-
.../client/http/url/LegacyC2UrlProviderTest.java | 11 +-
.../client/http/url/ProxyAwareC2ProviderTest.java | 13 +-
.../nifi/c2/client/service/C2HeartbeatFactory.java | 49 +-
.../nifi/c2/client/service/C2HeartbeatManager.java | 14 +-
.../nifi/c2/client/service/C2OperationManager.java | 25 +-
.../nifi/c2/client/service/FlowIdHolder.java | 9 +-
.../c2/client/service/ManifestHashProvider.java | 10 +-
.../client/service/model/RuntimeInfoWrapper.java | 5 +-
.../service/operation/C2OperationHandler.java | 13 +-
.../operation/C2OperationHandlerProvider.java | 11 +-
.../operation/C2OperationRestartHandler.java | 3 +-
.../DescribeManifestOperationHandler.java | 19 +-
.../client/service/operation/OperationQueue.java | 5 +-
.../operation/SupportedOperationsProvider.java | 7 +-
.../operation/SyncResourceOperationHandler.java | 19 +-
.../service/operation/SyncResourceStrategy.java | 7 +-
.../operation/TransferDebugOperationHandler.java | 51 +-
.../operation/UpdateAssetOperationHandler.java | 27 +-
.../UpdateConfigurationOperationHandler.java | 29 +-
.../UpdatePropertiesOperationHandler.java | 21 +-
.../nifi/minifi/validator/ValidationException.java | 3 +-
.../c2/client/service/C2HeartbeatFactoryTest.java | 37 +-
.../c2/client/service/C2HeartbeatManagerTest.java | 28 +-
.../c2/client/service/C2OperationManagerTest.java | 43 +-
.../client/service/ManifestHashProviderTest.java | 13 +-
.../operation/C2OperationHandlerProviderTest.java | 23 +-
.../DescribeManifestOperationHandlerTest.java | 8 +-
.../EmptyOperandPropertiesProviderTest.java | 5 +-
.../operation/StartFlowOperationHandlerTest.java | 3 +-
.../operation/StopFlowOperationHandlerTest.java | 3 +-
.../operation/SupportedOperationsProviderTest.java | 16 +-
.../SyncResourceOperationHandlerTest.java | 43 +-
.../TransferDebugOperationHandlerTest.java | 65 +-
.../operation/UpdateAssetOperationHandlerTest.java | 39 +-
.../UpdateConfigurationOperationHandlerTest.java | 31 +-
.../UpdatePropertiesOperationHandlerTest.java | 21 +-
.../apache/nifi/c2/protocol/api/AgentManifest.java | 6 +-
.../nifi/c2/protocol/api/C2OperationAck.java | 1 +
.../apache/nifi/c2/protocol/api/FailureCause.java | 3 +-
.../apache/nifi/c2/protocol/api/OperationType.java | 10 +-
.../nifi/c2/protocol/api/ProcessorBulletin.java | 1 +
.../apache/nifi/c2/protocol/api/ResourceInfo.java | 1 +
.../apache/nifi/c2/protocol/api/ResourceItem.java | 1 +
.../nifi/c2/protocol/api/ResourcesGlobalHash.java | 1 +
.../component/api/ProcessorConfiguration.java | 1 -
checkstyle.xml | 6 +
.../apache/nifi/minifi/bootstrap/RunMiNiFi.java | 23 +-
.../nifi/minifi/bootstrap/SensitiveProperty.java | 6 +-
.../apache/nifi/minifi/bootstrap/ShutdownHook.java | 1 -
.../nifi/minifi/bootstrap/WindowsService.java | 3 +-
.../bootstrap/command/CommandRunnerFactory.java | 7 +-
.../bootstrap/command/CompositeCommandRunner.java | 4 +-
.../nifi/minifi/bootstrap/command/DumpRunner.java | 15 +-
.../nifi/minifi/bootstrap/command/EnvRunner.java | 9 +-
.../minifi/bootstrap/command/FlowStatusRunner.java | 4 +-
.../nifi/minifi/bootstrap/command/StartRunner.java | 49 +-
.../minifi/bootstrap/command/StatusRunner.java | 8 +-
.../nifi/minifi/bootstrap/command/StopRunner.java | 21 +-
.../ConfigurationChangeCoordinator.java | 21 +-
.../differentiators/Differentiator.java | 3 +-
.../differentiators/WholeConfigDifferentiator.java | 9 +-
.../ingestors/AbstractPullChangeIngestor.java | 9 +-
.../ingestors/FileChangeIngestor.java | 41 +-
.../ingestors/PullHttpChangeIngestor.java | 58 +-
.../ingestors/RestChangeIngestor.java | 34 +-
.../ingestors/interfaces/ChangeIngestor.java | 3 +-
.../minifi/bootstrap/service/BootstrapCodec.java | 13 +-
.../bootstrap/service/BootstrapFileProvider.java | 19 +-
.../bootstrap/service/CurrentPortProvider.java | 6 +-
.../service/GracefulShutdownParameterProvider.java | 3 +-
.../bootstrap/service/MiNiFiCommandSender.java | 7 +-
.../service/MiNiFiConfigurationChangeListener.java | 33 +-
.../service/MiNiFiExecCommandProvider.java | 13 +-
.../minifi/bootstrap/service/MiNiFiListener.java | 11 +-
.../service/MiNiFiPropertiesGenerator.java | 49 +-
.../bootstrap/service/MiNiFiStatusProvider.java | 4 +-
.../bootstrap/service/MiNiFiStdLogHandler.java | 11 +-
.../service/PeriodicStatusReporterManager.java | 17 +-
.../minifi/bootstrap/service/ReloadService.java | 11 +-
.../bootstrap/service/UpdatePropertiesService.java | 15 +-
.../bootstrap/status/PeriodicStatusReporter.java | 5 +-
.../bootstrap/status/reporters/StatusLogger.java | 11 +-
.../minifi/bootstrap/util/OrderedProperties.java | 3 +-
.../minifi/bootstrap/util/UnixProcessUtils.java | 7 +-
.../nifi/minifi/bootstrap/ShutdownHookTest.java | 8 +-
.../command/CommandRunnerFactoryTest.java | 29 +-
.../command/CompositeCommandRunnerTest.java | 15 +-
.../minifi/bootstrap/command/DumpRunnerTest.java | 25 +-
.../minifi/bootstrap/command/EnvRunnerTest.java | 21 +-
.../bootstrap/command/FlowStatusRunnerTest.java | 15 +-
.../minifi/bootstrap/command/StatusRunnerTest.java | 12 +-
.../minifi/bootstrap/command/StopRunnerTest.java | 31 +-
.../WholeConfigDifferentiatorTest.java | 19 +-
.../ingestors/FileChangeIngestorTest.java | 37 +-
.../ingestors/RestChangeIngestorCommonTest.java | 7 +-
.../ingestors/RestChangeIngestorTest.java | 23 +-
.../bootstrap/service/BootstrapCodecTest.java | 31 +-
.../bootstrap/service/CurrentPortProviderTest.java | 14 +-
.../GracefulShutdownParameterProviderTest.java | 21 +-
.../service/MiNiFiPropertiesGeneratorTest.java | 43 +-
.../status/reporters/StatusLoggerTest.java | 27 +-
.../nifi/minifi/commons/api/MiNiFiProperties.java | 14 +-
.../commons/service/StandardFlowEnrichService.java | 49 +-
.../service/StandardFlowPropertyEncryptor.java | 29 +-
.../commons/service/StandardFlowSerDeService.java | 9 +-
.../nifi/minifi/commons/util/FlowUpdateUtils.java | 19 +-
.../service/StandardFlowEnrichServiceTest.java | 35 +-
.../service/StandardFlowPropertyEncryptorTest.java | 33 +-
.../minifi/commons/utils/PropertyUtilTest.java | 11 +-
.../standalone/test/StandaloneJsonTest.java | 12 +-
.../java/org/apache/nifi/minifi/MiNiFiServer.java | 1 -
.../c2/BootstrapC2OperationRestartHandler.java | 29 +-
.../apache/nifi/minifi/c2/C2NifiClientService.java | 112 +-
.../nifi/minifi/c2/FileBasedOperationQueueDAO.java | 9 +-
.../c2/command/AgentPropertyValidationContext.java | 7 +-
.../c2/command/DefaultFlowStateStrategy.java | 1 +
.../c2/command/DefaultProcessorStateStrategy.java | 4 +-
.../DefaultUpdateConfigurationStrategy.java | 47 +-
.../minifi/c2/command/PropertiesPersister.java | 15 +-
.../c2/command/TransferDebugCommandHelper.java | 13 +-
.../c2/command/UpdateAssetCommandHelper.java | 5 +-
.../command/UpdatePropertiesPropertyProvider.java | 11 +-
.../syncresource/DefaultSyncResourceStrategy.java | 35 +-
.../syncresource/FileResourceRepository.java | 25 +-
.../command/syncresource/ResourceRepository.java | 5 +-
.../syncresource/SyncResourcePropertyProvider.java | 1 +
.../nifi/minifi/validator/FlowValidator.java | 25 +-
.../c2/BootstrapC2OperationRestartHandlerTest.java | 27 +-
.../minifi/c2/FileBasedOperationQueueDAOTest.java | 33 +-
.../DefaultUpdateConfigurationStrategyTest.java | 53 +-
.../minifi/c2/command/PropertiesPersisterTest.java | 29 +-
.../c2/command/TransferDebugCommandHelperTest.java | 7 +-
.../c2/command/UpdateAssetCommandHelperTest.java | 19 +-
.../UpdatePropertiesPropertyProviderTest.java | 21 +-
.../DefaultSyncResourceStrategyTest.java | 56 +-
.../syncresource/FileResourceRepositoryTest.java | 37 +-
.../nifi/minifi/nar/NarAutoUnloadService.java | 1 +
.../apache/nifi/minifi/nar/NarAutoUnloader.java | 4 +-
.../nifi/minifi/nar/NarAutoUnloaderTask.java | 9 +-
.../minifi/nar/NarAutoUnloaderTaskFactory.java | 11 +-
.../nifi/minifi/nar/NarAutoUnloadServiceTest.java | 9 +-
.../minifi/properties/BootstrapProperties.java | 5 +-
.../minifi/properties/MiNiFiPropertiesLoader.java | 6 +-
.../properties/MultiSourceMinifiProperties.java | 5 +-
.../nifi/minifi/properties/PropertiesLoader.java | 5 +-
.../main/java/org/apache/nifi/minifi/MiNiFi.java | 29 +-
.../nifi/minifi/bootstrap/BootstrapListener.java | 21 +-
.../minifi/util/BootstrapClassLoaderUtils.java | 5 +-
.../apache/nifi/minifi/StandardMiNiFiServer.java | 22 +-
.../minifi/toolkit/configuration/ConfigMain.java | 8 +-
.../json/ComponentPropertyProvider.java | 19 +-
...ConfigSchemaToVersionedDataFlowTransformer.java | 77 +-
.../json/TransformNifiCommandFactory.java | 11 +-
.../json/TransformYamlCommandFactory.java | 27 +-
.../minifi/toolkit/schema/ReportingSchema.java | 2 +-
.../toolkit/schema/SecurityPropertiesSchema.java | 6 +-
.../minifi/toolkit/schema/common/BaseSchema.java | 3 +-
.../toolkit/schema/serialization/SchemaLoader.java | 2 +-
.../minifi/toolkit/schema/v2/ConfigSchemaV2.java | 32 +-
.../toolkit/schema/v2/CorePropertiesSchemaV2.java | 9 +-
.../command/StandardBootstrapCommandProvider.java | 2 +-
.../StandardConfigurationProvider.java | 4 +-
.../SecurityApplicationPropertyHandler.java | 2 +-
.../nifi/provenance/AsyncLineageSubmission.java | 6 +-
.../nifi/provenance/AsyncQuerySubmission.java | 6 +-
.../nifi/provenance/SearchableFieldParser.java | 4 +-
.../nifi/provenance/StandardQueryResult.java | 10 +-
.../apache/nifi/provenance/lineage/EventNode.java | 4 +-
.../expression/language/InvalidPreparedQuery.java | 1 -
.../attribute/expression/language/ValueLookup.java | 2 +-
.../language/compile/ExpressionCompiler.java | 14 +-
.../evaluation/functions/HashEvaluator.java | 8 +-
.../evaluation/functions/HostnameEvaluator.java | 1 -
.../functions/JsonPathBaseEvaluator.java | 19 +-
.../functions/JsonPathDeleteEvaluator.java | 7 +-
.../evaluation/functions/JsonPathEvaluator.java | 5 +-
.../evaluation/functions/JsonPathSetEvaluator.java | 1 -
.../functions/JsonPathUpdateEvaluator.java | 1 -
.../evaluation/functions/PadLeftEvaluator.java | 1 -
.../evaluation/functions/PaddingEvaluator.java | 2 +-
.../evaluation/functions/Uuid3Evaluator.java | 2 +-
.../literals/DecimalLiteralEvaluator.java | 1 -
.../encryptor/command/FlowEncryptorCommand.java | 11 +-
.../nifi/flow/encryptor/JsonFlowEncryptorTest.java | 15 +-
.../org/apache/nifi/util/FlowFilePackagerV1.java | 8 +-
.../org/apache/nifi/util/FlowFileUnpackagerV1.java | 5 +-
.../hashicorp/config/HashiCorpVaultProperty.java | 1 -
.../java/org/apache/nifi/hl7/hapi/EmptyField.java | 6 +-
.../java/org/apache/nifi/hl7/hapi/HapiField.java | 13 +-
.../java/org/apache/nifi/hl7/hapi/HapiMessage.java | 17 +-
.../java/org/apache/nifi/hl7/hapi/HapiSegment.java | 13 +-
.../org/apache/nifi/hl7/hapi/SingleValueField.java | 6 +-
.../java/org/apache/nifi/hl7/io/HL7Reader.java | 4 +-
.../java/org/apache/nifi/hl7/query/HL7Query.java | 22 +-
.../comparison/AbstractComparisonEvaluator.java | 6 +-
.../comparison/AbstractNumericComparison.java | 4 +-
.../evaluator/comparison/IsNullEvaluator.java | 6 +-
.../query/evaluator/comparison/NotEvaluator.java | 4 +-
.../evaluator/comparison/NotNullEvaluator.java | 6 +-
.../evaluator/literal/IntegerLiteralEvaluator.java | 4 +-
.../evaluator/literal/StringLiteralEvaluator.java | 4 +-
.../hl7/query/evaluator/logic/AndEvaluator.java | 4 +-
.../hl7/query/evaluator/logic/OrEvaluator.java | 4 +-
.../message/DeclaredReferenceEvaluator.java | 4 +-
.../hl7/query/evaluator/message/DotEvaluator.java | 10 +-
.../query/evaluator/message/FieldEvaluator.java | 10 +-
.../query/evaluator/message/MessageEvaluator.java | 4 +-
.../query/evaluator/message/SegmentEvaluator.java | 8 +-
.../apache/nifi/hl7/query/result/MissedResult.java | 6 +-
.../nifi/hl7/query/result/StandardQueryResult.java | 8 +-
.../nifi/hl7/query/result/StandardResultHit.java | 4 +-
.../connector/StandardServerConnectorFactory.java | 2 +-
.../StandardServerConnectorFactoryTest.java | 3 +-
...TestExpressionLanguageAwareParameterParser.java | 1 -
.../nifi/encrypt/CipherPropertyEncryptor.java | 6 +-
.../nifi/encrypt/KeyedCipherPropertyEncryptor.java | 6 +-
.../nifi/encrypt/PropertyEncryptorBuilder.java | 2 +-
.../encrypt/StandardPropertySecretKeyProvider.java | 2 +-
.../encrypt/KeyedCipherPropertyEncryptorTest.java | 4 +-
.../nifi/record/path/RecordFieldRemover.java | 9 +-
.../org/apache/nifi/record/path/RecordPath.java | 6 +-
.../nifi/record/path/filter/ContainsRegex.java | 6 +-
.../nifi/record/path/filter/MatchesRegex.java | 6 +-
.../record/path/filter/StringComparisonFilter.java | 4 +-
.../apache/nifi/record/path/functions/Concat.java | 4 +-
.../nifi/record/path/functions/FieldName.java | 4 +-
.../apache/nifi/record/path/functions/Replace.java | 4 +-
.../nifi/record/path/functions/ReplaceNull.java | 6 +-
.../nifi/record/path/functions/ReplaceRegex.java | 8 +-
.../nifi/record/path/functions/Substring.java | 8 +-
.../nifi/record/path/functions/SubstringAfter.java | 4 +-
.../record/path/functions/SubstringAfterLast.java | 4 +-
.../record/path/functions/SubstringBefore.java | 4 +-
.../record/path/functions/SubstringBeforeLast.java | 4 +-
.../nifi/record/path/paths/ArrayIndexPath.java | 4 +-
.../nifi/record/path/paths/CurrentFieldPath.java | 4 +-
.../record/path/paths/DescendantFieldPath.java | 11 +-
.../nifi/record/path/paths/LiteralValuePath.java | 4 +-
.../record/path/paths/MultiArrayIndexPath.java | 8 +-
.../nifi/record/path/paths/MultiMapKeyPath.java | 8 +-
.../apache/nifi/record/path/paths/ParentPath.java | 3 +-
.../nifi/record/path/paths/PredicatePath.java | 4 +-
.../nifi/record/path/paths/RecordPathSegment.java | 6 +-
.../apache/nifi/record/path/paths/RootPath.java | 4 +-
.../nifi/record/path/paths/SingularMapKeyPath.java | 6 +-
.../nifi/record/path/paths/WildcardChildPath.java | 6 +-
.../record/path/paths/WildcardDescendantPath.java | 11 +-
.../nifi/record/path/paths/WildcardIndexPath.java | 8 +-
.../path/util/FieldValueLogicalPathBuilder.java | 8 +-
.../nifi/record/path/util/FieldValueWalker.java | 4 +-
.../org/apache/nifi/record/path/util/Filters.java | 9 +-
.../nifi/record/path/util/RecordPathUtils.java | 4 +-
.../serialization/AbstractRecordSetWriter.java | 6 +-
.../apache/nifi/serialization/RecordSetWriter.java | 4 +-
.../apache/nifi/serialization/RecordWriter.java | 4 +-
.../nifi/serialization/record/RawRecordWriter.java | 4 +-
.../apache/nifi/serialization/record/Record.java | 4 +-
.../nifi/serialization/record/TestMapRecord.java | 2 +-
.../nifi/repository/schema/MapRecordField.java | 4 +-
.../nifi/repository/schema/UnionRecordField.java | 4 +-
.../cert/builder/StandardCertificateBuilder.java | 2 +-
.../builder/StandardCertificateBuilderTest.java | 2 +-
.../nifi/security/cert/PeerIdentityProvider.java | 2 +-
.../cert/StandardPeerIdentityProvider.java | 2 +-
.../security/cert/StandardPrincipalFormatter.java | 2 +-
.../cert/StandardPeerIdentityProviderTest.java | 2 +-
.../cert/StandardPrincipalFormatterTest.java | 2 +-
.../org/apache/nifi/security/krb/KerberosUser.java | 2 +-
.../nifi/security/krb/AbstractKerberosUser.java | 14 +-
.../nifi/security/krb/KeytabConfiguration.java | 4 +-
.../nifi/security/krb/PasswordConfiguration.java | 4 +-
.../security/krb/TicketCacheConfiguration.java | 4 +-
.../krb/UsernamePasswordCallbackHandler.java | 2 +-
.../apache/nifi/security/krb/KerberosUserIT.java | 8 +-
.../security/ssl/StandardKeyManagerBuilder.java | 6 +-
.../ssl/StandardKeyManagerFactoryBuilder.java | 2 +-
.../security/ssl/StandardSslContextBuilder.java | 10 +-
.../security/ssl/StandardTrustManagerBuilder.java | 6 +-
.../ssl/StandardTrustManagerFactoryBuilder.java | 2 +-
.../ssl/StandardX509ExtendedKeyManager.java | 4 +-
.../ssl/StandardX509ExtendedTrustManager.java | 4 +-
.../ssl/StandardSslContextBuilderTest.java | 4 +-
.../ssl/StandardX509ExtendedKeyManagerTest.java | 3 +-
.../ssl/StandardX509ExtendedTrustManagerTest.java | 4 +-
.../org/apache/nifi/security/util/TlsPlatform.java | 9 +-
.../writer/StandardLoginCredentialsWriter.java | 18 +-
.../src/main/java/org/apache/nifi/remote/Peer.java | 4 +-
.../nifi/remote/RemoteResourceInitiator.java | 8 +-
.../java/org/apache/nifi/remote/Transaction.java | 4 +-
.../apache/nifi/remote/TransactionCompletion.java | 4 +-
.../apache/nifi/remote/client/PeerSelector.java | 23 +-
.../nifi/remote/client/PeerStatusProvider.java | 5 +-
.../nifi/remote/client/SiteInfoProvider.java | 15 +-
.../nifi/remote/client/SiteToSiteClient.java | 27 +-
.../nifi/remote/client/SiteToSiteClientConfig.java | 11 +-
.../apache/nifi/remote/client/http/HttpClient.java | 23 +-
.../client/socket/EndpointConnectionPool.java | 53 +-
.../socket/StandardSocketPeerIdentityProvider.java | 8 +-
.../remote/cluster/ClusterNodeInformation.java | 12 +-
.../apache/nifi/remote/codec/FlowFileCodec.java | 10 +-
.../org/apache/nifi/remote/protocol/Response.java | 4 +-
.../protocol/socket/SocketClientProtocol.java | 19 +-
.../apache/nifi/remote/util/PeerStatusCache.java | 3 +-
.../nifi/remote/util/SiteToSiteRestApiClient.java | 52 +-
.../nifi/remote/util/StandardDataPacket.java | 6 +-
.../nifi/remote/client/TestSiteInfoProvider.java | 2 +-
.../StandardSocketPeerIdentityProviderTest.java | 11 +-
.../nifi/remote/io/InterruptableInputStream.java | 4 +-
.../nifi/remote/io/InterruptableOutputStream.java | 4 +-
.../nifi/stream/io/util/AbstractDemarcator.java | 4 +-
.../org/apache/nifi/util/ComponentIdGenerator.java | 6 +-
.../main/java/org/apache/nifi/util/DomUtils.java | 6 +-
.../util/concurrency/DebugEnabledTimedLock.java | 6 +-
.../apache/nifi/util/concurrency/TimedLock.java | 6 +-
.../java/org/apache/nifi/util/search/Search.java | 4 +-
.../nifi/util/search/ahocorasick/AhoCorasick.java | 6 +-
.../apache/nifi/util/search/ahocorasick/Node.java | 4 +-
.../nifi/util/search/ahocorasick/SearchState.java | 4 +-
.../stream/io/ByteCountingOutputStreamTest.java | 1 -
.../nifi/stream/io/util/StreamDemarcatorTest.java | 1 -
.../stream/io/util/TextLineDemarcatorTest.java | 2 +-
.../nifi/util/timebuffer/TestRingBuffer.java | 1 -
.../util/validator/TestStandardValidators.java | 5 +-
.../nifi/web/client/StandardWebClientService.java | 1 -
.../web/client/ssl/StandardSSLContextProvider.java | 10 +-
.../ssl/StandardSSLSocketFactoryProvider.java | 2 +-
.../org/apache/nifi/web/client/ssl/TlsContext.java | 2 +-
.../web/client/StandardWebClientServiceTest.java | 3 +-
.../nifi/web/servlet/shared/RequestUriBuilder.java | 1 +
.../web/servlet/shared/RequestUriBuilderTest.java | 2 +-
.../apache/nifi/wali/TestBlockingQueuePool.java | 1 -
.../parsers/StandardDocumentProvider.java | 6 +-
.../processing/sax/StandardInputSourceParser.java | 4 +-
.../stream/StandardXMLEventReaderProvider.java | 2 +-
.../stream/StandardXMLStreamReaderProvider.java | 2 +-
.../transform/StandardTransformProvider.java | 2 +-
.../validation/StandardSchemaValidator.java | 5 +-
.../parsers/StandardDocumentProviderTest.java | 5 +-
.../stream/StandardXMLEventReaderProviderTest.java | 4 +-
.../StandardXMLStreamReaderProviderTest.java | 4 +-
.../transform/StandardTransformProviderTest.java | 4 +-
.../validation/StandardSchemaValidatorTest.java | 5 +-
.../processors/airtable/QueryAirtableTable.java | 37 +-
.../parse/AirtableRecordSetFlowFileWriter.java | 7 +-
.../airtable/parse/AirtableRetrievePageResult.java | 3 +-
.../parse/AirtableRetrieveTableResult.java | 3 +-
.../airtable/parse/AirtableTableRetriever.java | 11 +-
.../airtable/service/AirtableRestService.java | 13 +-
.../apache/nifi/amqp/processors/AMQPConsumer.java | 15 +-
.../apache/nifi/amqp/processors/AMQPPublisher.java | 11 +-
.../apache/nifi/amqp/processors/AMQPResource.java | 4 +-
.../apache/nifi/amqp/processors/AMQPWorker.java | 9 +-
.../amqp/processors/AbstractAMQPProcessor.java | 21 +-
.../nifi/amqp/processors/AMQPConsumerTest.java | 27 +-
.../nifi/amqp/processors/AMQPPublisherTest.java | 25 +-
.../amqp/processors/AbstractAMQPProcessorTest.java | 1 -
.../apache/nifi/amqp/processors/TestChannel.java | 28 +-
.../nifi/amqp/processors/TestConnection.java | 10 +-
.../java/org/apache/nifi/jasn1/JASN1Reader.java | 10 +-
.../nifi/jasn1/convert/JASN1ConverterImpl.java | 2 +-
.../org/apache/nifi/jasn1/JASN1ReaderTest.java | 15 +-
.../nifi/jasn1/TestRecordSchemaProvider.java | 1 -
.../nifi/processors/avro/ExtractAvroMetadata.java | 20 +-
.../org/apache/nifi/processors/avro/SplitAvro.java | 39 +-
.../apache/nifi/processors/avro/AvroTestUtil.java | 5 +-
.../nifi/processors/aws/AbstractAwsProcessor.java | 8 +-
.../provider/PropertiesCredentialsProvider.java | 1 -
.../aws/kinesis/ReaderRecordProcessorTest.java | 4 +-
.../aws/AwsSecretsManagerParameterProvider.java | 8 +-
.../provider/factory/CredentialsStrategy.java | 1 -
.../AbstractBooleanCredentialsStrategy.java | 1 -
.../strategies/AbstractCredentialsStrategy.java | 6 +-
.../AccessKeyPairCredentialsStrategy.java | 1 -
.../strategies/AnonymousCredentialsStrategy.java | 1 -
.../strategies/AssumeRoleCredentialsStrategy.java | 2 +-
.../ExplicitDefaultCredentialsStrategy.java | 1 -
.../strategies/FileCredentialsStrategy.java | 1 -
.../ImplicitDefaultCredentialsStrategy.java | 1 -
.../NamedProfileCredentialsStrategy.java | 1 -
.../strategies/WebIdentityCredentialsStrategy.java | 3 +-
.../processors/aws/ml/textract/TextractType.java | 6 +-
.../apache/nifi/processors/aws/s3/PutS3Object.java | 3 +-
.../s3/encryption/StandardS3EncryptionService.java | 1 -
.../org/apache/nifi/processors/aws/sqs/GetSQS.java | 1 -
.../aws/cloudwatch/MockPutCloudWatchMetric.java | 1 -
.../provider/service/MockAWSProcessor.java | 1 -
.../nifi/processors/aws/lambda/TestPutLambda.java | 1 -
.../nifi/processors/aws/s3/ITDeleteS3Object.java | 1 -
.../nifi/processors/aws/s3/ITFetchS3Object.java | 1 -
.../apache/nifi/processors/aws/s3/ITListS3.java | 1 -
.../nifi/processors/aws/s3/ITTagS3Object.java | 1 -
.../nifi/processors/aws/s3/TestDeleteS3Object.java | 1 -
.../nifi/processors/aws/s3/TestFetchS3Object.java | 1 -
.../apache/nifi/processors/aws/s3/TestListS3.java | 1 -
.../nifi/processors/aws/s3/TestPutS3Object.java | 1 -
.../nifi/processors/aws/s3/TestTagS3Object.java | 1 -
.../s3/encryption/TestS3EncryptionStrategies.java | 3 +-
.../TestStandardS3EncryptionService.java | 1 -
.../apache/nifi/processors/aws/sns/TestPutSNS.java | 1 -
.../nifi/processors/aws/sqs/TestDeleteSQS.java | 1 -
.../apache/nifi/processors/aws/sqs/TestGetSQS.java | 1 -
.../apache/nifi/processors/aws/sqs/TestPutSQS.java | 1 -
.../schemaregistry/AmazonGlueSchemaRegistry.java | 8 +-
.../azure/ClientSideEncryptionSupport.java | 2 +-
.../azure/eventhub/GetAzureEventHub.java | 2 +-
.../azure/eventhub/GetAzureEventHubTest.java | 2 +-
.../explorer/StandardKustoIngestServiceTest.java | 30 +-
.../AbstractAzureLogAnalyticsReportingTask.java | 4 +-
.../AzureLogAnalyticsProvenanceReportingTask.java | 958 ++++++++--------
.../nifi/reporting/azure/loganalytics/Metric.java | 1 +
.../api/AzureLogAnalyticsMetricsFactory.java | 10 +-
...stAzureLogAnalyticsProvenanceReportingTask.java | 4 +-
.../cosmos/AzureCosmosDBConnectionService.java | 1 -
.../apache/nifi/processors/box/BoxFileInfo.java | 8 +-
.../nifi/processors/box/BoxFlowFileAttribute.java | 3 +-
.../apache/nifi/processors/box/FetchBoxFile.java | 30 +-
.../apache/nifi/processors/box/ListBoxFile.java | 33 +-
.../org/apache/nifi/processors/box/PutBoxFile.java | 1 -
.../nifi/processors/box/FetchBoxFileTest.java | 21 +-
.../nifi/processors/box/FileListingTestTrait.java | 11 +-
.../processors/box/ListBoxFileListingTest.java | 17 +-
.../nifi/processors/box/ListBoxFileTest.java | 24 +-
.../apache/nifi/processors/box/PutBoxFileTest.java | 31 +-
.../DeveloperBoxClientService.java | 1 -
.../JsonConfigBasedBoxClientService.java | 20 +-
.../apache/nifi/cdc/event/BaseRowEventInfo.java | 1 -
.../org/apache/nifi/cdc/event/io/EventWriter.java | 2 +-
.../apache/nifi/cdc/mysql/event/DDLEventInfo.java | 1 -
.../mysql/event/io/AbstractBinlogEventWriter.java | 2 +-
.../event/io/CommitTransactionEventWriter.java | 1 -
.../nifi/cdc/mysql/event/io/DDLEventWriter.java | 3 +-
.../nifi/cdc/mysql/event/io/DeleteRowsWriter.java | 4 +-
.../nifi/cdc/mysql/event/io/InsertRowsWriter.java | 5 +-
.../nifi/cdc/mysql/event/io/UpdateRowsWriter.java | 5 +-
.../cdc/mysql/processors/CaptureChangeMySQL.java | 3 +-
.../processors/ssl/BinaryLogSSLSocketFactory.java | 2 +-
.../cdc/mysql/event/io/TestInsertRowsWriter.java | 1 -
.../mysql/processors/CaptureChangeMySQLTest.java | 2 +-
.../ssl/BinaryLogSSLSocketFactoryTest.java | 6 +-
.../nifi/processors/cipher/VerifyContentMAC.java | 44 +-
.../ConfluentProtobufMessageNameResolverTest.java | 1 -
.../schemaregistry/ConfluentSchemaRegistry.java | 28 +-
.../client/RestSchemaRegistryClient.java | 12 +-
.../client/SchemaRegistryClient.java | 4 +-
.../client/RestSchemaRegistryClientTest.java | 7 +-
.../schemaregistry/client/SchemaResponse.java | 1 -
.../couchbase/AbstractCouchbaseProcessor.java | 4 +-
.../StandardCouchbaseConnectionService.java | 1 -
.../services/couchbase/TestCouchbaseClient.java | 1 -
.../nifi/processors/dropbox/DropboxFileInfo.java | 25 +-
.../nifi/processors/dropbox/DropboxTrait.java | 13 +-
.../nifi/processors/dropbox/FetchDropbox.java | 43 +-
.../nifi/processors/dropbox/ListDropbox.java | 49 +-
.../apache/nifi/processors/dropbox/PutDropbox.java | 62 +-
.../processors/dropbox/AbstractDropboxTest.java | 17 +-
.../nifi/processors/dropbox/FetchDropboxTest.java | 19 +-
.../nifi/processors/dropbox/ListDropboxTest.java | 25 +-
.../nifi/processors/dropbox/PutDropboxTest.java | 37 +-
.../dropbox/StandardDropboxCredentialService.java | 3 +-
.../ElasticSearchClientServiceImpl.java | 2 +-
.../elasticsearch/PutElasticsearchRecord.java | 2 +-
.../processors/email/AbstractEmailProcessor.java | 6 +-
.../apache/nifi/processors/email/ConsumeIMAP.java | 6 +-
.../apache/nifi/processors/email/ConsumePOP3.java | 4 +-
.../processors/email/ExtractEmailAttachments.java | 20 +-
.../nifi/processors/email/ExtractEmailHeaders.java | 26 +-
.../nifi/processors/email/TestConsumeEmail.java | 10 +-
.../apache/nifi/processors/GeoEnrichTestUtils.java | 1 +
.../nifi/processors/evtx/XmlBxmlNodeVisitor.java | 4 +-
.../processors/evtx/XmlBxmlNodeVisitorFactory.java | 2 +-
.../nifi/processors/evtx/XmlRootNodeHandler.java | 3 +-
.../nifi/processors/evtx/parser/BinaryReader.java | 1 +
.../parser/bxml/value/WStringArrayTypeNode.java | 7 +-
.../apache/nifi/processors/evtx/ParseEvtxTest.java | 2 +-
.../processors/evtx/XmlBxmlNodeVisitorTest.java | 4 +-
.../processors/evtx/XmlRootNodeHandlerTest.java | 2 +-
.../resolution/ConflictResolutionStrategy.java | 3 +-
.../org/apache/nifi/util/db/TestJdbcCommon.java | 35 +-
.../nifi/dbcp/AbstractDBCPConnectionPool.java | 17 +-
.../nifi/dbcp/ProviderAwareBasicDataSource.java | 2 +-
.../nifi/dbcp/utils/DefaultDataSourceValues.java | 3 +-
.../nifi/dbcp/AbstractDBCPConnectionPoolTest.java | 4 +-
.../util/put/AbstractPutEventProcessor.java | 2 +-
.../ByteArrayMessageNettyEventServerFactory.java | 2 +-
.../netty/ByteArrayNettyEventSenderFactory.java | 1 +
.../transport/netty/NettyEventSenderFactory.java | 2 +-
.../transport/netty/NettyEventServerFactory.java | 4 +-
.../netty/StringNettyEventSenderFactory.java | 2 +-
.../ssl/ClientSslStandardChannelInitializer.java | 4 +-
.../ssl/ServerSslHandlerChannelInitializer.java | 6 +-
.../netty/codec/SocketByteArrayMessageDecoder.java | 6 +-
.../netty/NettyEventSenderFactoryTest.java | 2 +-
.../netty/StringNettyEventSenderFactoryTest.java | 4 +-
.../processor/util/file/transfer/FileInfo.java | 14 +-
.../processor/util/file/transfer/FileTransfer.java | 12 +-
.../java/org/apache/nifi/hadoop/SecurityUtil.java | 4 +-
.../processors/hadoop/AbstractHadoopProcessor.java | 2 +-
.../nifi/processors/hadoop/CompressionType.java | 6 +-
.../nifi/processor/util/list/EntityListing.java | 6 +-
.../util/pattern/TestRollbackOnFailure.java | 2 +-
.../java/org/apache/nifi/avro/AvroTypeUtil.java | 55 +-
.../schema/access/InferenceSchemaStrategy.java | 2 +-
.../org/apache/nifi/avro/TestAvroTypeUtil.java | 44 +-
.../apache/nifi/json/JsonTreeRowRecordReader.java | 1 -
.../serialization/record/MockSchemaRegistry.java | 2 +-
.../main/java/org/apache/nifi/csv/CSVUtils.java | 3 +-
.../schema/access/InheritSchemaFromRecord.java | 4 +-
.../nifi/schema/access/NopSchemaAccessWriter.java | 4 +-
.../nifi/schema/access/SchemaAccessWriter.java | 4 +-
.../nifi/schema/access/SchemaNameAsAttribute.java | 6 +-
.../validation/StandardSchemaValidationResult.java | 6 +-
.../schema/validation/StandardValidationError.java | 6 +-
.../java/org/apache/nifi/csv/CSVUtilsTest.java | 7 +-
.../reporting/util/metrics/MetricsService.java | 9 +-
.../reporting/util/metrics/api/MetricsBuilder.java | 6 +-
.../StrictSyslog5424ParserDashPolicyTest.java | 1 -
.../StrictSyslog5424ParserNullPolicyTest.java | 1 -
.../StrictSyslog5424ParserOmitPolicyTest.java | 1 -
.../flow/NifiRegistryFlowRegistryClient.java | 2 +-
.../nifi/processors/gcp/AbstractGCPProcessor.java | 7 +-
.../ApplicationDefaultCredentialsStrategy.java | 1 -
.../JsonFileServiceAccountCredentialsStrategy.java | 1 -
...sonStringServiceAccountCredentialsStrategy.java | 1 -
.../processors/gcp/drive/FetchGoogleDrive.java | 18 +-
.../processors/gcp/drive/GoogleDriveTrait.java | 4 +-
.../gcp/pubsub/AbstractGCPubSubProcessor.java | 338 +++---
.../processors/gcp/pubsub/PublishGCPubSub.java | 4 +-
.../processors/gcp/storage/DeleteGCSObject.java | 1 -
.../processors/gcp/storage/FetchGCSObject.java | 29 +-
.../nifi/processors/gcp/storage/PutGCSObject.java | 1 -
.../gcp/vision/AbstractGcpVisionProcessor.java | 10 +-
...bstractGetGcpVisionAnnotateOperationStatus.java | 13 +-
.../vision/AbstractStartGcpVisionOperation.java | 15 +-
.../StartGcpVisionAnnotateFilesOperation.java | 8 +-
.../StartGcpVisionAnnotateImagesOperation.java | 8 +-
.../processors/gcp/bigquery/PutBigQueryIT.java | 36 +-
.../processors/gcp/bigquery/PutBigQueryTest.java | 11 +-
.../factory/MockCredentialsFactoryProcessor.java | 1 -
.../service/GCPCredentialsServiceTest.java | 1 -
.../service/MockCredentialsServiceProcessor.java | 1 -
.../gcp/drive/AbstractGoogleDriveTest.java | 22 +-
.../processors/gcp/drive/FetchGoogleDriveIT.java | 21 +-
.../processors/gcp/drive/FetchGoogleDriveTest.java | 22 +-
.../gcp/drive/ListGoogleDriveTestRunnerTest.java | 56 +-
.../processors/gcp/drive/PutGoogleDriveIT.java | 16 +-
.../processors/gcp/drive/PutGoogleDriveTest.java | 33 +-
.../processors/gcp/storage/AbstractGCSTest.java | 1 -
.../gcp/storage/DeleteGCSObjectTest.java | 5 +-
.../processors/gcp/storage/FetchGCSObjectTest.java | 15 +-
...tGcpVisionAnnotateFilesOperationStatusTest.java | 17 +-
...GcpVisionAnnotateImagesOperationStatusTest.java | 17 +-
.../StartGcpVisionAnnotateFilesOperationTest.java | 25 +-
.../StartGcpVisionAnnotateImagesOperationTest.java | 23 +-
.../nifi/processors/geohash/GeohashRecord.java | 15 +-
.../nifi/processors/graph/ExecuteGraphQuery.java | 2 +-
.../graph/ExecuteGraphQueryRecordTest.java | 8 +-
.../processors/graph/util/InMemoryGraphClient.java | 6 +-
.../graph/InMemoryJanusGraphClientService.java | 4 +-
.../nifi/graph/ITNeo4JCypherClientServiceSSL.java | 3 +-
.../apache/nifi/graph/TinkerpopClientService.java | 1 -
.../processors/groovyx/ExecuteGroovyScript.java | 21 +-
.../nifi/processors/groovyx/GroovyMethods.java | 6 +-
.../processors/groovyx/flow/GroovySessionFile.java | 10 +-
.../groovyx/flow/ProcessSessionWrap.java | 25 +-
.../nifi/processors/groovyx/flow/SessionFile.java | 14 +-
.../apache/nifi/processors/groovyx/sql/OSql.java | 10 +-
.../apache/nifi/processors/groovyx/util/Files.java | 1 +
.../nifi/processors/groovyx/util/Throwables.java | 4 +-
.../groovyx/ExecuteGroovyScriptTest.java | 1 +
.../hadoop/HDFSExternalResourceProvider.java | 2 +-
.../FlowFileStreamUnpackerSequenceFileWriter.java | 15 +-
.../nifi/processors/hadoop/GetHDFSFileInfo.java | 24 +-
.../hadoop/TarUnpackerSequenceFileWriter.java | 7 +-
.../hadoop/ZipUnpackerSequenceFileWriter.java | 11 +-
.../nifi/processors/hadoop/util/HDFSListing.java | 4 +-
.../hadoop/util/OutputStreamWritable.java | 5 +-
.../nifi/processors/hadoop/MoveHDFSTest.java | 2 +-
.../apache/nifi/processors/hadoop/PutHDFSTest.java | 12 +-
.../processors/hadoop/TestGetHDFSFileInfo.java | 19 +-
.../hadoop/inotify/util/EventTestUtils.java | 1 -
.../StandardHashiCorpVaultClientService.java | 1 -
.../cacheclient/HazelcastMapCacheClientTest.java | 1 -
.../EmbeddedHazelcastCacheManagerTest.java | 7 +-
.../nifi/processors/hl7/ExtractHL7Attributes.java | 20 +-
.../org/apache/nifi/processors/hl7/RouteHL7.java | 23 +-
.../iceberg/parquet/ParquetIcebergWriter.java | 12 +-
.../parquet/io/ParquetIcebergRowWriter.java | 2 +-
.../iceberg/parquet/ParquetIcebergWriterTest.java | 2 +-
.../nifi/processors/iceberg/PutIcebergRecord.java | 12 +-
.../processors/iceberg/PutIcebergRecordTest.java | 10 +-
.../iceberg/catalog/RESTIcebergCatalog.java | 6 +-
.../org/apache/nifi/processors/AbstractIoTDB.java | 44 +-
.../org/apache/nifi/processors/PutIoTDBRecord.java | 28 +-
.../apache/nifi/processors/QueryIoTDBRecord.java | 18 +-
.../nifi/processors/model/DatabaseField.java | 8 +-
.../nifi/processors/model/DatabaseSchema.java | 12 +-
.../apache/nifi/processors/AbstractIoTDBTest.java | 9 +-
.../apache/nifi/processors/PutIoTDBRecordTest.java | 3 +-
.../cf/AbstractJMSConnectionFactoryProvider.java | 10 +-
.../jms/cf/CachedJMSConnectionFactoryHandler.java | 3 +-
.../nifi/jms/cf/JMSConnectionFactoryHandler.java | 19 +-
.../nifi/jms/cf/JMSConnectionFactoryProvider.java | 3 +-
.../jms/cf/JndiJmsConnectionFactoryHandler.java | 8 +-
.../jms/cf/JndiJmsConnectionFactoryProvider.java | 3 +-
.../nifi/jms/processors/AbstractJMSProcessor.java | 4 +-
.../org/apache/nifi/jms/processors/ConsumeJMS.java | 2 +-
.../apache/nifi/jms/processors/JMSConsumer.java | 18 +-
.../apache/nifi/jms/processors/JMSPublisher.java | 12 +-
.../org/apache/nifi/jms/processors/JMSWorker.java | 4 +-
.../processors/MessageBodyToBytesConverter.java | 19 +-
.../org/apache/nifi/jms/processors/PublishJMS.java | 4 +-
.../jms/cf/JMSConnectionFactoryHandlerForTest.java | 2 +-
.../jms/cf/JMSConnectionFactoryProviderTest.java | 2 +-
.../org/apache/nifi/jms/processors/CommonTest.java | 1 -
.../jms/processors/ConnectionFactoryConfigIT.java | 5 +-
.../apache/nifi/jms/processors/ConsumeJMSIT.java | 24 +-
.../nifi/jms/processors/ConsumeJMSManualTest.java | 15 +-
.../jms/processors/JMSPublisherConsumerIT.java | 18 +-
.../apache/nifi/jms/processors/PublishJMSIT.java | 14 +-
.../ConnectionFactoryInvocationHandler.java | 11 +-
.../helpers/ConnectionInvocationHandler.java | 11 +-
.../helpers/MessageProducerInvocationHandler.java | 9 +-
.../helpers/SessionInvocationHandler.java | 11 +-
.../web/standard/api/AbstractStandardResource.java | 2 -
.../standard/api/processor/ProcessorResource.java | 14 +-
.../standard/api/processor/ProcessorWebUtils.java | 8 +-
.../api/transformjson/TransformJSONResource.java | 10 +-
.../api/processor/TestProcessorResource.java | 14 +-
.../api/processor/TestProcessorWebUtils.java | 8 +-
.../transformjson/TestTransformJSONResource.java | 11 +-
.../org/apache/nifi/jolt/util/TransformUtils.java | 1 -
.../ConsumeKafkaInjectOffsetRecordIT.java | 2 +-
.../processors/ConsumeKafkaRecordWithNullIT.java | 6 +-
.../processors/PublishKafkaExpressionKeyIT.java | 4 +-
.../processors/PublishKafkaOneLargePayloadIT.java | 4 +-
.../processors/PublishKafkaTooLargePayloadIT.java | 6 +-
.../publish/PublishKafkaMultipleFFIT.java | 2 +-
.../additional/PublishKafkaContentX1IT.java | 2 +-
.../additional/PublishKafkaWrapperX1IT.java | 2 +-
.../additional/PublishKafkaWrapperX2IT.java | 2 +-
.../additional/PublishKafkaWrapperX3IT.java | 2 +-
.../additional/PublishKafkaWrapperX4IT.java | 2 +-
.../service/aws/AmazonMSKConnectionService.java | 3 +-
.../aws/AmazonMSKCredentialsCallbackHandler.java | 6 +-
.../AmazonMSKCredentialsCallbackHandlerTest.java | 6 +-
.../security/OAuthBearerLoginCallbackHandler.java | 7 +-
.../service/Kafka3ConnectionServiceBaseIT.java | 3 +-
.../shared/login/KerberosLoginConfigProvider.java | 2 +-
.../kafka/shared/login/LoginConfigBuilder.java | 2 +-
.../login/AwsMskIamLoginConfigProviderTest.java | 4 +-
.../processors/image/ExtractImageMetadata.java | 19 +-
.../apache/nifi/processors/image/ResizeImage.java | 33 +-
.../processors/media/ExtractMediaMetadata.java | 19 +-
.../processors/image/ExtractImageMetadataTest.java | 1 -
.../nifi/processors/image/TestResizeImage.java | 2 +-
.../processors/mongodb/AbstractMongoProcessor.java | 2 +-
.../nifi/processors/mongodb/PutMongoRecordIT.java | 1 -
.../nifi/mongodb/MongoDBControllerService.java | 3 +-
.../apache/nifi/processors/mqtt/ConsumeMQTT.java | 1 -
.../mqtt/adapters/HiveMqV5ClientAdapter.java | 4 +-
.../mqtt/adapters/PahoMqttClientAdapter.java | 2 +-
.../apache/nifi/processors/network/pcap/PCAP.java | 1 -
.../nifi/processors/network/pcap/SplitPCAP.java | 14 +-
.../nifi/processors/network/pcap/TestPCAP.java | 4 +-
.../processors/network/pcap/TestSplitPCAP.java | 12 +-
.../processors/network/parser/Netflowv5Parser.java | 5 +-
.../nifi/processors/opentelemetry/ListenOTLP.java | 2 +-
.../server/HttpProtocolNegotiationHandler.java | 2 +-
.../opentelemetry/server/HttpRequestHandler.java | 2 +-
.../opentelemetry/server/HttpServerFactory.java | 4 +-
.../processors/opentelemetry/ListenOTLPTest.java | 15 +-
.../viewer/ParquetServletContextListener.java | 2 +-
.../controller/ParquetContentViewerController.java | 3 +-
.../org/apache/nifi/parquet/ParquetReader.java | 24 +-
.../nifi/parquet/ParquetRecordSetWriter.java | 27 +-
.../nifi/parquet/filter/OffsetRecordFilter.java | 3 +-
.../nifi/parquet/record/ParquetRecordReader.java | 11 +-
.../apache/nifi/parquet/utils/ParquetUtils.java | 9 +-
.../parquet/CalculateParquetOffsets.java | 15 +-
.../parquet/CalculateParquetRowGroupOffsets.java | 13 +-
.../processors/parquet/ConvertAvroToParquet.java | 1 -
.../nifi/processors/parquet/FetchParquet.java | 5 +-
.../apache/nifi/processors/parquet/PutParquet.java | 5 +-
.../org/apache/nifi/parquet/ParquetTestUtils.java | 18 +-
.../apache/nifi/parquet/TestParquetProcessor.java | 17 +-
.../org/apache/nifi/parquet/TestParquetReader.java | 31 +-
.../parquet/CalculateParquetOffsetsTest.java | 24 +-
.../CalculateParquetRowGroupOffsetsTest.java | 23 +-
.../nifi/processors/parquet/FetchParquetTest.java | 35 +-
.../parquet/TestConvertAvroToParquet.java | 23 +-
.../nifi/processors/pgp/DecryptContentPGP.java | 3 +-
.../nifi/processors/pgp/EncryptContentPGP.java | 1 -
.../apache/nifi/processors/pgp/SignContentPGP.java | 2 +-
.../nifi/processors/pgp/VerifyContentPGP.java | 2 +-
.../nifi/processors/pgp/DecryptContentPGPTest.java | 2 +-
.../nifi/processors/pgp/EncryptContentPGPTest.java | 6 +-
.../nifi/processors/pgp/SignContentPGPTest.java | 2 +-
.../nifi/processors/pgp/VerifyContentPGPTest.java | 4 +-
.../standard/StandardPGPPrivateKeyService.java | 1 -
.../standard/StandardPGPPublicKeyService.java | 1 -
.../standard/StandardPGPPrivateKeyServiceTest.java | 4 +-
.../standard/StandardPGPPublicKeyServiceTest.java | 1 -
.../nifi/excel/TestExcelSchemaInference.java | 24 +-
.../excel/TestExcelStartingRowSchemaInference.java | 2 +-
.../protobuf/converter/ProtobufDataConverter.java | 2 +-
.../converter/TestProtobufDataConverter.java | 2 +-
.../apache/nifi/py4j/client/NiFiPythonGateway.java | 1 -
.../nifi/py4j/logback/LevelChangeListener.java | 2 +-
.../apache/nifi/py4j/server/NiFiGatewayServer.java | 2 +-
.../nifi/py4j/logback/LevelChangeListenerTest.java | 5 +-
.../PythonControllerInteractionIT.java | 1 -
.../redis/service/RedisConnectionPoolService.java | 2 +-
.../org/apache/nifi/redis/state/RedisStateMap.java | 3 +-
.../nifi/redis/state/RedisStateProvider.java | 2 +-
.../redis/processor/TestPutRedisHashRecord.java | 1 -
.../service/TestRedisConnectionPoolService.java | 2 +-
.../nifi/redis/state/ITRedisStateProvider.java | 3 +-
.../nifi/redis/state/TestRedisStateProvider.java | 2 +-
.../org/apache/nifi/redis/util/RedisUtils.java | 3 +-
.../services/StandardJsonSchemaRegistry.java | 6 +-
.../services/TestStandardJsonSchemaRegistry.java | 2 +-
.../lookup/script/BaseScriptedLookupService.java | 8 +-
.../nifi/processors/script/ExecuteScript.java | 8 +-
.../processors/script/InvokeScriptedProcessor.java | 8 +-
.../nifi/processors/script/ScriptRunner.java | 1 -
.../processors/script/ScriptedPartitionRecord.java | 4 +-
.../processors/script/ScriptedRecordProcessor.java | 14 +-
.../processors/script/ScriptedRouterProcessor.java | 4 +-
.../processors/script/ScriptedTransformRecord.java | 4 +-
.../script/engine/ClojureScriptEngine.java | 6 +-
.../script/engine/ClojureScriptEngineFactory.java | 4 +-
.../apache/nifi/record/script/ScriptedReader.java | 8 +-
.../record/script/ScriptedRecordSetWriter.java | 8 +-
.../record/sink/script/ScriptedRecordSink.java | 8 +-
.../reporting/script/ScriptedReportingTask.java | 10 +-
.../apache/nifi/script/ScriptRunnerFactory.java | 6 +-
.../nifi/script/ScriptingComponentHelper.java | 8 +-
.../nifi/script/ScriptingComponentUtils.java | 4 +-
...FilteredPropertiesValidationContextAdapter.java | 144 +--
.../script/TestSimpleScriptedLookupService.java | 1 +
.../nifi/processors/script/TestInvokeGroovy.java | 1 -
.../record/script/ScriptedRecordSetWriterTest.java | 8 +-
.../script/ScriptedReportingTaskTest.java | 2 +-
.../processors/shopify/model/ResourceType.java | 259 ++---
.../shopify/util/TestIncrementalTimers.java | 1 -
.../reporting/AbstractSiteToSiteReportingTask.java | 6 +-
.../reporting/SiteToSiteBulletinReportingTask.java | 12 +-
.../reporting/SiteToSiteMetricsReportingTask.java | 31 +-
.../SiteToSiteProvenanceReportingTask.java | 33 +-
.../reporting/SiteToSiteStatusReportingTask.java | 31 +-
.../apache/nifi/reporting/s2s/SiteToSiteUtils.java | 7 +-
.../sink/SiteToSiteReportingRecordSink.java | 9 +-
.../TestSiteToSiteBulletinReportingTask.java | 8 +-
.../TestSiteToSiteMetricsReportingTask.java | 10 +-
.../TestSiteToSiteProvenanceReportingTask.java | 8 +-
.../TestSiteToSiteStatusReportingTask.java | 12 +-
.../apache/nifi/processors/slack/ListenSlack.java | 1 -
.../apache/nifi/processors/slack/PublishSlack.java | 2 +-
.../processors/slack/consume/ConsumeChannel.java | 21 +-
.../slack/consume/ConsumeSlackClient.java | 1 -
.../processors/slack/consume/SlackTimestamp.java | 1 -
.../services/smb/SmbClientProviderService.java | 5 +-
.../nifi/services/smb/SmbListableEntity.java | 11 +-
.../org/apache/nifi/processors/smb/ListSmb.java | 73 +-
.../org/apache/nifi/processors/smb/PutSmbFile.java | 1 -
.../org/apache/nifi/processors/smb/FetchSmbIT.java | 22 +-
.../apache/nifi/processors/smb/FetchSmbTest.java | 13 +-
.../apache/nifi/processors/smb/GetSmbFileTest.java | 13 +-
.../org/apache/nifi/processors/smb/ListSmbIT.java | 34 +-
.../apache/nifi/processors/smb/ListSmbTest.java | 39 +-
.../apache/nifi/processors/smb/PutSmbFileTest.java | 19 +-
.../nifi/processors/smb/SambaTestContainers.java | 18 +-
.../nifi/services/smb/SmbjClientService.java | 6 +-
.../nifi/services/smb/SmbjClientServiceIT.java | 46 +-
.../processors/properties/V1TrapProperties.java | 1 -
.../nifi/processors/twitter/ConsumeTwitter.java | 4 +-
.../apache/nifi/processors/splunk/PutSplunk.java | 22 +-
.../splunk/QuerySplunkIndexingStatus.java | 3 +-
.../nifi/processors/splunk/TestPutSplunk.java | 1 -
.../nifi/processors/splunk/TestPutSplunkHTTP.java | 2 +-
.../nifi/reporting/sql/MetricsQueryService.java | 1 -
.../reporting/sql/TestQueryNiFiReportingTask.java | 1 -
.../StandardContentViewerController.java | 4 +-
.../nifi/parameter/DatabaseParameterProvider.java | 2 +-
.../parameter/OnePasswordParameterProvider.java | 5 +-
.../parameter/TestDatabaseParameterProvider.java | 5 +-
.../TestEnvironmentVariableParameterProvider.java | 3 +-
.../TestOnePasswordParameterProvider.java | 5 +-
.../standard/AbstractDatabaseFetchProcessor.java | 2 +-
.../processors/standard/AbstractExecuteSQL.java | 1 -
.../standard/AbstractQueryDatabaseTable.java | 2 +-
.../nifi/processors/standard/EvaluateXPath.java | 14 +-
.../nifi/processors/standard/EvaluateXQuery.java | 4 +-
.../nifi/processors/standard/ExecuteSQLRecord.java | 1 -
.../processors/standard/GenerateTableFetch.java | 2 +-
.../processors/standard/HandleHttpRequest.java | 2 +-
.../nifi/processors/standard/IdentifyMimeType.java | 1 -
.../nifi/processors/standard/InvokeHTTP.java | 9 +-
.../nifi/processors/standard/ListenHTTP.java | 8 +-
.../nifi/processors/standard/ListenSyslog.java | 2 +-
.../apache/nifi/processors/standard/ListenTCP.java | 2 +-
.../nifi/processors/standard/LookupRecord.java | 1 -
.../nifi/processors/standard/MergeContent.java | 1 -
.../nifi/processors/standard/MergeRecord.java | 1 -
.../nifi/processors/standard/PackageFlowFile.java | 1 -
.../nifi/processors/standard/ParseSyslog.java | 1 -
.../processors/standard/QueryDatabaseTable.java | 1 -
.../standard/QueryDatabaseTableRecord.java | 1 -
.../processors/standard/RemoveRecordField.java | 1 -
.../nifi/processors/standard/TransformXml.java | 26 +-
.../processors/standard/UpdateDatabaseTable.java | 2 +-
.../nifi/processors/standard/ValidateJson.java | 8 +-
.../nifi/processors/standard/ValidateRecord.java | 1 -
.../nifi/processors/standard/ValidateXml.java | 14 +-
.../nifi/processors/standard/db/TableSchema.java | 1 -
.../processors/standard/ftp/NifiFtpServer.java | 6 +-
.../standard/ftp/StandardFTPClientProvider.java | 19 +-
.../http/CertificateAttributesProvider.java | 1 +
...leHttpRequestCertificateAttributesProvider.java | 2 +-
.../standard/merge/AttributeStrategy.java | 4 +-
.../merge/KeepCommonAttributeStrategy.java | 6 +-
.../merge/KeepUniqueAttributeStrategy.java | 6 +-
.../servlets/ContentAcknowledgmentServlet.java | 11 +-
.../standard/servlets/HealthCheckServlet.java | 1 +
.../standard/socket/ProxySocketFactory.java | 2 +-
.../socket/StandardSocketFactoryProvider.java | 2 +-
.../nifi/processors/standard/sql/SqlWriter.java | 1 -
.../nifi/processors/standard/util/FTPTransfer.java | 34 +-
.../util/FlowFileAttributesSerializer.java | 10 +-
.../standard/util/ProxyAuthenticator.java | 3 +-
.../standard/util/ValidatingBase32InputStream.java | 3 +-
.../standard/util/ValidatingBase64InputStream.java | 4 +-
.../nifi/processors/standard/InvokeHTTPTest.java | 9 +-
.../processors/standard/TestAttributesToCSV.java | 4 +-
.../processors/standard/TestAttributesToJSON.java | 1 -
.../standard/TestConvertCharacterSet.java | 10 +-
.../processors/standard/TestEvaluateXPath.java | 13 +-
.../processors/standard/TestEvaluateXQuery.java | 15 +-
.../processors/standard/TestExecuteProcess.java | 10 +-
.../nifi/processors/standard/TestExtractGrok.java | 1 -
.../nifi/processors/standard/TestExtractText.java | 7 +-
.../nifi/processors/standard/TestFetchFTP.java | 2 +-
.../processors/standard/TestGenerateFlowFile.java | 1 -
.../standard/TestHandleHttpResponse.java | 10 +-
.../nifi/processors/standard/TestListFile.java | 2 +-
.../nifi/processors/standard/TestListSFTP.java | 18 +-
.../nifi/processors/standard/TestListenHTTP.java | 16 +-
.../nifi/processors/standard/TestListenTCP.java | 4 +-
.../nifi/processors/standard/TestListenUDP.java | 2 +-
.../nifi/processors/standard/TestPutRecord.java | 1 -
.../nifi/processors/standard/TestPutSFTP.java | 2 +-
.../nifi/processors/standard/TestPutTCP.java | 4 +-
.../processors/standard/TestRemoveRecordField.java | 1 -
.../nifi/processors/standard/TestSplitXml.java | 4 +-
.../processors/standard/TestValidateRecord.java | 2 +-
.../standard/TestWaitNotifyProtocol.java | 2 +-
.../db/impl/TestOracle12DatabaseAdapter.java | 12 +-
.../standard/ftp/TestVirtualFileSystem.java | 1 -
...tpRequestCertificateAttributesProviderTest.java | 4 +-
.../socket/StandardSocketFactoryProviderTest.java | 2 +-
.../nifi/processors/standard/util/JsonUtil.java | 1 -
.../util/TestFlowFileAttributesSerializer.java | 6 +-
.../rules/RequireServerSSLContextService.java | 1 -
.../rules/RestrictBackpressureSettingsTest.java | 12 +-
.../java/org/apache/nifi/dbcp/DBCPService.java | 8 +-
.../org/apache/nifi/dbcp/DBCPConnectionPool.java | 15 +-
.../java/org/apache/nifi/dbcp/DBCPServiceTest.java | 25 +-
.../apache/nifi/dbcp/HikariCPConnectionPool.java | 3 +-
.../distributed/cache/client/Deserializer.java | 4 +-
.../cache/client/DistributedSetCacheClient.java | 4 +-
.../nifi/distributed/cache/client/Serializer.java | 4 +-
.../nifi/distributed/cache/client/CacheClient.java | 2 +-
.../client/CacheClientChannelInitializer.java | 4 +-
.../client/CacheClientChannelPoolFactory.java | 2 +-
.../cache/protocol/ProtocolHandshake.java | 6 +-
.../distributed/cache/server/EventCacheServer.java | 2 +-
.../distributed/cache/server/SetCacheServer.java | 5 +-
.../cache/server/map/MapCacheRecord.java | 4 +-
.../cache/server/map/MapCacheServer.java | 9 +-
.../cache/server/map/PersistentMapCache.java | 17 +-
.../cache/server/map/SimpleMapCache.java | 9 +-
.../cache/server/map/StandardMapCacheServer.java | 4 +-
.../cache/server/set/PersistentSetCache.java | 12 +-
.../cache/server/set/SetCacheRecord.java | 4 +-
.../cache/server/set/SimpleSetCache.java | 9 +-
.../cache/server/set/StandardSetCacheServer.java | 2 +-
.../cache/server/map/MapCacheServiceTlsTest.java | 4 +-
.../server/map/StandardMapCacheServerTest.java | 2 +-
.../map/TestDistributedMapServerAndClient.java | 4 +-
.../cache/server/set/SetCacheServiceTest.java | 2 +-
.../set/TestDistributedSetServerAndClient.java | 2 +-
.../service/StandardFileResourceService.java | 2 +-
.../apache/nifi/dbcp/HadoopDBCPConnectionPool.java | 2 +-
.../java/org/apache/nifi/http/HttpContextMap.java | 5 +-
.../apache/nifi/http/StandardHttpContextMap.java | 19 +-
.../key/service/StandardPrivateKeyServiceTest.java | 1 -
.../java/org/apache/nifi/lookup/LookupService.java | 4 +-
.../apache/nifi/lookup/CSVRecordLookupService.java | 26 +-
.../lookup/DistributedMapCacheLookupService.java | 24 +-
.../org/apache/nifi/lookup/RestLookupService.java | 4 +-
.../nifi/lookup/SimpleCsvFileLookupService.java | 22 +-
.../apache/nifi/lookup/XMLFileLookupService.java | 1 -
.../configuration2/SafeXMLConfiguration.java | 15 +-
.../nifi/lookup/configuration2/XXEValidator.java | 11 +-
.../nifi/lookup/maxmind/AnonymousIpSchema.java | 4 +-
.../org/apache/nifi/lookup/maxmind/CitySchema.java | 6 +-
.../nifi/lookup/maxmind/ContainerSchema.java | 4 +-
.../nifi/lookup/maxmind/IPLookupService.java | 1 -
.../org/apache/nifi/lookup/maxmind/IspSchema.java | 4 +-
.../nifi/lookup/TestCSVRecordLookupService.java | 5 +-
.../lookup/TestRestLookupServiceMarkReset.java | 2 +-
.../apache/nifi/oauth2/HttpProtocolStrategy.java | 3 +-
.../oauth2/JWTBearerOAuth2AccessTokenProvider.java | 3 +-
.../oauth2/StandardOauth2AccessTokenProvider.java | 5 +-
.../JWTBearerOAuth2AccessTokenProviderTest.java | 3 +-
.../StandardOauth2AccessTokenProviderTest.java | 2 +-
.../nifi/serialization/RecordSetWriterFactory.java | 8 +-
.../nifi/avro/AvroReaderWithExplicitSchema.java | 14 +-
.../avro/EmbeddedAvroSchemaAccessStrategy.java | 12 +-
.../nifi/avro/WriteAvroResultWithSchema.java | 10 +-
.../apache/nifi/csv/AbstractCSVRecordReader.java | 1 +
.../apache/nifi/csv/CSVHeaderSchemaStrategy.java | 17 +-
.../java/org/apache/nifi/csv/CSVRecordReader.java | 23 +-
.../java/org/apache/nifi/csv/CSVRecordSource.java | 15 +-
.../apache/nifi/csv/JacksonCSVRecordReader.java | 24 +-
.../java/org/apache/nifi/csv/WriteCSVResult.java | 15 +-
.../org/apache/nifi/grok/GrokRecordReader.java | 23 +-
.../org/apache/nifi/json/JsonPathValidator.java | 3 +-
.../serialization/DateTimeTextRecordSetWriter.java | 8 +-
.../org/apache/nifi/text/FreeFormTextWriter.java | 14 +-
.../nifi/windowsevent/WindowsEventLogReader.java | 1 -
.../windowsevent/WindowsEventLogRecordReader.java | 14 +-
.../java/org/apache/nifi/xml/WriteXMLResult.java | 7 +-
.../main/java/org/apache/nifi/xml/XMLReader.java | 430 ++++----
.../java/org/apache/nifi/xml/XMLRecordReader.java | 1148 ++++++++++----------
.../apache/nifi/xml/inference/XmlRecordSource.java | 12 +-
.../avro/TestAvroReaderWithExplicitSchema.java | 25 +-
.../org/apache/nifi/cef/TestCEFRecordReader.java | 4 +-
.../apache/nifi/csv/ITApacheCSVRecordReader.java | 11 +-
.../apache/nifi/csv/ITJacksonCSVRecordReader.java | 11 +-
.../org/apache/nifi/csv/TestCSVRecordReader.java | 25 +-
.../org/apache/nifi/csv/TestCSVValidators.java | 1 -
.../apache/nifi/csv/TestFastCSVRecordReader.java | 15 +-
.../nifi/csv/TestJacksonCSVRecordReader.java | 15 +-
.../org/apache/nifi/csv/TestWriteCSVResult.java | 26 +-
.../apache/nifi/csv/TestWriteFastCSVResult.java | 25 +-
.../org/apache/nifi/json/TestWriteJsonResult.java | 2 +-
.../sink/lookup/RecordSinkServiceLookup.java | 1 -
.../nifi/record/sink/TestLoggingRecordSink.java | 1 -
.../sink/lookup/TestRecordSinkServiceLookup.java | 1 -
.../services/JsonSchemaRegistry.java | 3 +-
.../services/MessageNameResolver.java | 1 +
.../nifi/ssl/PEMEncodedSSLContextProvider.java | 12 +-
.../ssl/StandardRestrictedSSLContextService.java | 5 +-
.../apache/nifi/ssl/StandardSSLContextService.java | 12 +-
.../nifi/ssl/PEMEncodedSSLContextProviderTest.java | 13 +-
.../StandardRestrictedSSLContextServiceTest.java | 5 +-
.../nifi/ssl/StandardSSLContextServiceTest.java | 8 +-
.../org/apache/nifi/ssl/SSLContextProvider.java | 2 +-
.../service/StandardWebClientServiceProvider.java | 9 +-
.../StandardWebClientServiceProviderTest.java | 9 +-
.../org/apache/nifi/update/attributes/Rule.java | 3 +-
.../update/attributes/serde/CriteriaSerDe.java | 14 +-
.../attributes/UpdateAttributeModelFactory.java | 2 +-
.../nifi/update/attributes/api/RuleResource.java | 42 +-
.../nifi/update/attributes/dto/ActionDTO.java | 4 +-
.../nifi/update/attributes/dto/ConditionDTO.java | 4 +-
.../nifi/update/attributes/dto/DtoFactory.java | 7 +-
.../apache/nifi/update/attributes/dto/RuleDTO.java | 3 +-
.../attributes/entity/EvaluationContextEntity.java | 1 +
.../nifi/update/attributes/entity/RuleEntity.java | 3 +-
.../nifi/update/attributes/entity/RulesEntity.java | 3 +-
.../attributes/mapper/ObjectMapperResolver.java | 1 -
.../AbstractWebSocketGatewayProcessor.java | 2 +-
.../nifi/processors/websocket/PutWebSocket.java | 46 +-
.../processors/websocket/TestConnectWebSocket.java | 1 -
.../processors/websocket/TestListenWebSocket.java | 1 -
.../processors/websocket/TestPutWebSocket.java | 1 -
.../nifi/websocket/WebSocketMessageRouter.java | 8 +-
.../nifi/websocket/TestWebSocketMessageRouter.java | 1 -
.../websocket/TestWebSocketMessageRouters.java | 1 -
.../nifi/websocket/jetty/JettyWebSocketClient.java | 3 +-
.../nifi/websocket/jetty/JettyWebSocketServer.java | 2 +-
.../jetty/ControllerServiceTestContext.java | 1 -
.../websocket/jetty/TestJettyWebSocketClient.java | 1 -
.../websocket/util/HeaderMapExtractorTest.java | 134 +--
.../windows/event/log/ConsumeWindowsEventLog.java | 1 -
.../jna/EventSubscribeXmlRenderingCallback.java | 3 +-
.../windows/event/log/JNALauncherInterceptor.java | 14 +-
.../nifi/services/zendesk/ZendeskRecordSink.java | 8 +-
.../FlowActionReporterConfigurationContext.java | 2 +-
.../LoginIdentityProviderConfigurationContext.java | 3 +-
.../AbstractPolicyBasedAuthorizer.java | 14 +-
.../nifi/components/state/StateProvider.java | 4 +-
.../state/StateProviderInitializationContext.java | 7 +-
.../NonComponentConfigurationContext.java | 3 +-
.../org/apache/nifi/controller/Triggerable.java | 4 +-
.../controller/repository/ContentRepository.java | 5 +-
.../nifi/controller/repository/QueueProvider.java | 4 +-
.../controller/repository/RepositoryRecord.java | 4 +-
.../nifi/controller/repository/SwapSummary.java | 4 +-
.../java/org/apache/nifi/events/EventReporter.java | 4 +-
.../lineage/ProvenanceEventLineageNode.java | 4 +-
.../org/apache/nifi/provenance/search/Query.java | 1 -
.../apache/nifi/provenance/search/QueryResult.java | 4 +-
.../nifi/web/NiFiWebConfigurationContext.java | 4 +-
.../provider/KubernetesConfigMapStateProvider.java | 23 +-
.../state/provider/StandardStateMap.java | 3 +-
.../zookeeper/CuratorACLProviderFactory.java | 8 +-
.../zookeeper/ZooKeeperStateProvider.java | 6 +-
.../java/org/apache/nifi/ldap/LdapProvider.java | 11 +-
.../org/apache/nifi/ldap/LdapsSocketFactory.java | 4 +-
.../nifi/ldap/ssl/LdapSslContextProvider.java | 2 +-
.../ldap/ssl/StandardLdapSslContextProvider.java | 2 +-
.../nifi/ldap/tenants/LdapUserGroupProvider.java | 12 +-
.../org/apache/nifi/ldap/tenants/TenantHolder.java | 1 -
.../ssl/StandardLdapSslContextProviderTest.java | 4 +-
.../nifi/provenance/AbstractRecordWriter.java | 10 +-
.../provenance/ByteArraySchemaRecordReader.java | 9 +-
.../provenance/ByteArraySchemaRecordWriter.java | 14 +-
.../provenance/EventIdFirstSchemaRecordReader.java | 13 +-
.../nifi/provenance/RepositoryConfiguration.java | 13 +-
.../provenance/WriteAheadProvenanceRepository.java | 1 -
.../provenance/authorization/EventAuthorizer.java | 8 +-
.../provenance/authorization/EventTransformer.java | 4 +-
.../nifi/provenance/index/EventIndexSearcher.java | 4 +-
.../nifi/provenance/index/EventIndexWriter.java | 6 +-
.../provenance/index/lucene/IndexableDocument.java | 4 +-
.../apache/nifi/provenance/lucene/DocsReader.java | 28 +-
.../lucene/DocumentToEventConverter.java | 6 +-
.../nifi/provenance/lucene/IndexManager.java | 6 +-
.../lucene/LuceneEventIndexSearcher.java | 6 +-
.../provenance/lucene/LuceneEventIndexWriter.java | 8 +-
.../provenance/lucene/UpdateMinimumEventId.java | 6 +-
.../schema/EventIdFirstHeaderSchema.java | 6 +-
.../apache/nifi/provenance/schema/EventRecord.java | 8 +-
.../nifi/provenance/schema/EventRecordFields.java | 8 +-
.../provenance/schema/LookupTableEventRecord.java | 12 +-
.../schema/LookupTableEventRecordFields.java | 8 +-
.../provenance/schema/LookupTableEventSchema.java | 13 +-
.../provenance/schema/ProvenanceEventSchema.java | 12 +-
.../serialization/CompressableRecordReader.java | 17 +-
.../serialization/EmptyRecordReader.java | 6 +-
.../provenance/serialization/RecordReader.java | 8 +-
.../provenance/serialization/RecordWriters.java | 8 +-
.../nifi/provenance/store/EventFileManager.java | 6 +-
.../nifi/provenance/store/EventStorePartition.java | 8 +-
.../nifi/provenance/store/RecordReaderFactory.java | 4 +-
.../nifi/provenance/store/RecordWriterFactory.java | 4 +-
.../nifi/provenance/store/StorageResult.java | 6 +-
.../store/iterator/AuthorizingEventIterator.java | 6 +-
.../SelectiveRecordReaderEventIterator.java | 14 +-
.../SequentialRecordReaderEventIterator.java | 8 +-
.../nifi/provenance/toc/StandardTocWriter.java | 6 +-
.../org/apache/nifi/provenance/toc/TocUtil.java | 4 +-
.../apache/nifi/provenance/util/CloseableUtil.java | 4 +-
.../apache/nifi/provenance/util/DumpEventFile.java | 10 +-
.../nifi/provenance/util/StorageSummaryEvent.java | 5 +-
.../provenance/AbstractTestRecordReaderWriter.java | 1 -
.../provenance/TestSchemaRecordReaderWriter.java | 46 +-
.../java/org/apache/nifi/provenance/TestUtil.java | 4 +-
.../provenance/store/TestEventFileManager.java | 6 +-
.../TestSelectiveRecordReaderEventIterator.java | 32 +-
.../nifi/provenance/toc/TestStandardTocReader.java | 8 +-
.../nifi/provenance/toc/TestStandardTocWriter.java | 6 +-
.../TestVolatileProvenanceRepository.java | 2 +-
.../documentation/PropertyDependency.java | 4 +-
.../documentation/PropertyDescription.java | 3 +-
.../questdb/CounterStatisticsResultProcessor.java | 2 +-
.../single/user/SingleUserAuthorizer.java | 8 +-
.../main/java/org/apache/nifi/history/History.java | 3 +-
.../nifi/authorization/AuthorizerFactoryBean.java | 41 +-
.../java/org/apache/nifi/web/api/dto/AboutDTO.java | 4 +-
.../apache/nifi/web/api/dto/AccessPolicyDTO.java | 2 +-
.../nifi/web/api/dto/AccessPolicySummaryDTO.java | 3 +-
.../nifi/web/api/dto/AccessTokenExpirationDTO.java | 4 +-
.../nifi/web/api/dto/AffectedComponentDTO.java | 2 +-
.../apache/nifi/web/api/dto/AllowableValueDTO.java | 1 -
.../nifi/web/api/dto/AnalyzeFlowRequestDTO.java | 1 -
.../nifi/web/api/dto/AsynchronousRequestDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/BannerDTO.java | 1 -
.../apache/nifi/web/api/dto/BatchSettingsDTO.java | 1 -
.../apache/nifi/web/api/dto/BulletinBoardDTO.java | 4 +-
.../org/apache/nifi/web/api/dto/BulletinDTO.java | 4 +-
.../apache/nifi/web/api/dto/BulletinQueryDTO.java | 1 -
.../org/apache/nifi/web/api/dto/BundleDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/ClusterDTO.java | 4 +-
.../apache/nifi/web/api/dto/ClusterSummaryDTO.java | 1 -
.../org/apache/nifi/web/api/dto/ComponentDTO.java | 1 -
.../nifi/web/api/dto/ComponentDifferenceDTO.java | 2 +-
.../nifi/web/api/dto/ComponentHistoryDTO.java | 2 +-
.../nifi/web/api/dto/ComponentReferenceDTO.java | 1 -
.../api/dto/ComponentRestrictionPermissionDTO.java | 2 +-
.../apache/nifi/web/api/dto/ComponentStateDTO.java | 1 -
.../web/api/dto/ComponentValidationResultDTO.java | 2 +-
.../nifi/web/api/dto/ConfigurationAnalysisDTO.java | 2 +-
.../apache/nifi/web/api/dto/ConnectableDTO.java | 1 -
.../apache/nifi/web/api/dto/ContentViewerDTO.java | 1 +
.../web/api/dto/ControllerConfigurationDTO.java | 1 -
.../org/apache/nifi/web/api/dto/ControllerDTO.java | 2 +-
.../nifi/web/api/dto/ControllerServiceApiDTO.java | 2 +-
.../nifi/web/api/dto/ControllerServiceDTO.java | 2 +-
.../ControllerServiceReferencingComponentDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/CounterDTO.java | 1 -
.../org/apache/nifi/web/api/dto/CountersDTO.java | 2 +-
.../nifi/web/api/dto/CountersSnapshotDTO.java | 4 +-
.../org/apache/nifi/web/api/dto/DifferenceDTO.java | 1 -
.../org/apache/nifi/web/api/dto/DimensionsDTO.java | 1 -
.../apache/nifi/web/api/dto/DocumentedTypeDTO.java | 2 +-
.../apache/nifi/web/api/dto/DropRequestDTO.java | 4 +-
.../nifi/web/api/dto/ExplicitRestrictionDTO.java | 1 -
.../nifi/web/api/dto/FlowAnalysisRuleDTO.java | 2 +-
.../nifi/web/api/dto/FlowConfigurationDTO.java | 4 +-
.../org/apache/nifi/web/api/dto/FlowFileDTO.java | 2 +-
.../nifi/web/api/dto/FlowFileSummaryDTO.java | 1 -
.../nifi/web/api/dto/FlowRegistryBucketDTO.java | 1 -
.../nifi/web/api/dto/FlowRegistryClientDTO.java | 2 +-
.../apache/nifi/web/api/dto/FlowSnippetDTO.java | 2 +-
.../nifi/web/api/dto/FlowUpdateRequestDTO.java | 2 +-
.../nifi/web/api/dto/JmxMetricsResultDTO.java | 1 -
.../java/org/apache/nifi/web/api/dto/LabelDTO.java | 2 +-
.../apache/nifi/web/api/dto/ListingRequestDTO.java | 4 +-
.../nifi/web/api/dto/NodeCountersSnapshotDTO.java | 1 -
.../java/org/apache/nifi/web/api/dto/NodeDTO.java | 4 +-
.../org/apache/nifi/web/api/dto/NodeEventDTO.java | 4 +-
.../api/dto/NodeSystemDiagnosticsSnapshotDTO.java | 1 -
.../nifi/web/api/dto/ParameterContextDTO.java | 2 +-
.../web/api/dto/ParameterContextReferenceDTO.java | 1 -
.../api/dto/ParameterContextUpdateRequestDTO.java | 2 +-
.../dto/ParameterContextValidationRequestDTO.java | 3 +-
.../dto/ParameterContextValidationResultsDTO.java | 1 +
.../org/apache/nifi/web/api/dto/ParameterDTO.java | 3 +-
...ParameterProviderApplyParametersRequestDTO.java | 2 +-
.../api/dto/ParameterProviderConfigurationDTO.java | 1 -
.../nifi/web/api/dto/ParameterProviderDTO.java | 4 +-
.../ParameterProviderReferencingComponentDTO.java | 1 -
.../nifi/web/api/dto/ParameterStatusDTO.java | 3 +-
.../apache/nifi/web/api/dto/PermissionsDTO.java | 1 -
.../java/org/apache/nifi/web/api/dto/PortDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/PositionDTO.java | 1 -
.../apache/nifi/web/api/dto/PreviousValueDTO.java | 4 +-
.../apache/nifi/web/api/dto/ProcessGroupDTO.java | 3 +-
.../nifi/web/api/dto/ProcessGroupNameDTO.java | 1 -
.../org/apache/nifi/web/api/dto/ProcessorDTO.java | 2 +-
.../web/api/dto/ProcessorRunStatusDetailsDTO.java | 2 +-
.../nifi/web/api/dto/PropertyDependencyDTO.java | 2 +-
.../nifi/web/api/dto/PropertyDescriptorDTO.java | 2 +-
.../nifi/web/api/dto/PropertyHistoryDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/QueueSizeDTO.java | 1 -
.../apache/nifi/web/api/dto/RelationshipDTO.java | 1 -
.../web/api/dto/RemoteProcessGroupContentsDTO.java | 2 +-
.../nifi/web/api/dto/RemoteProcessGroupDTO.java | 4 +-
.../apache/nifi/web/api/dto/ReportingTaskDTO.java | 2 +-
.../nifi/web/api/dto/RequiredPermissionDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/ResourceDTO.java | 1 -
.../org/apache/nifi/web/api/dto/RevisionDTO.java | 1 -
.../org/apache/nifi/web/api/dto/SnippetDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/StateEntryDTO.java | 1 -
.../org/apache/nifi/web/api/dto/StateMapDTO.java | 2 +-
.../nifi/web/api/dto/SystemDiagnosticsDTO.java | 2 +-
.../web/api/dto/SystemDiagnosticsSnapshotDTO.java | 4 +-
.../org/apache/nifi/web/api/dto/TenantDTO.java | 1 -
.../java/org/apache/nifi/web/api/dto/UserDTO.java | 2 +-
.../org/apache/nifi/web/api/dto/UserGroupDTO.java | 2 +-
.../nifi/web/api/dto/VerifyConfigRequestDTO.java | 2 +-
.../web/api/dto/VersionControlInformationDTO.java | 1 -
.../apache/nifi/web/api/dto/VersionedFlowDTO.java | 1 -
.../web/api/dto/VersionedFlowUpdateRequestDTO.java | 1 -
.../apache/nifi/web/api/dto/action/ActionDTO.java | 4 +-
.../apache/nifi/web/api/dto/action/HistoryDTO.java | 4 +-
.../nifi/web/api/dto/action/HistoryQueryDTO.java | 4 +-
.../component/details/ExtensionDetailsDTO.java | 1 -
.../details/RemoteProcessGroupDetailsDTO.java | 1 -
.../dto/action/details/ConfigureDetailsDTO.java | 1 -
.../api/dto/action/details/ConnectDetailsDTO.java | 1 -
.../web/api/dto/action/details/MoveDetailsDTO.java | 1 -
.../api/dto/action/details/PurgeDetailsDTO.java | 4 +-
.../dto/diagnostics/ClassLoaderDiagnosticsDTO.java | 4 +-
.../dto/diagnostics/ConnectionDiagnosticsDTO.java | 2 +-
.../ConnectionDiagnosticsSnapshotDTO.java | 2 +-
.../ControllerServiceDiagnosticsDTO.java | 4 +-
.../dto/diagnostics/GCDiagnosticsSnapshotDTO.java | 5 +-
.../GarbageCollectionDiagnosticsDTO.java | 7 +-
.../JVMControllerDiagnosticsSnapshotDTO.java | 3 +-
.../web/api/dto/diagnostics/JVMDiagnosticsDTO.java | 5 +-
.../dto/diagnostics/JVMDiagnosticsSnapshotDTO.java | 3 +-
.../diagnostics/JVMFlowDiagnosticsSnapshotDTO.java | 8 +-
.../JVMSystemDiagnosticsSnapshotDTO.java | 7 +-
.../dto/diagnostics/LocalQueuePartitionDTO.java | 1 -
.../diagnostics/NodeGCDiagnosticsSnapshotDTO.java | 3 +-
.../diagnostics/NodeJVMDiagnosticsSnapshotDTO.java | 3 +-
.../dto/diagnostics/ProcessorDiagnosticsDTO.java | 2 +-
.../dto/diagnostics/RemoteQueuePartitionDTO.java | 1 -
.../api/dto/diagnostics/RepositoryUsageDTO.java | 3 +-
.../web/api/dto/diagnostics/ThreadDumpDTO.java | 3 +-
.../nifi/web/api/dto/flow/FlowBreadcrumbDTO.java | 3 +-
.../org/apache/nifi/web/api/dto/flow/FlowDTO.java | 2 +-
.../nifi/web/api/dto/flow/ProcessGroupFlowDTO.java | 4 +-
.../nifi/web/api/dto/provenance/AttributeDTO.java | 1 -
.../nifi/web/api/dto/provenance/ProvenanceDTO.java | 4 +-
.../web/api/dto/provenance/ProvenanceEventDTO.java | 4 +-
.../api/dto/provenance/ProvenanceOptionsDTO.java | 2 +-
.../api/dto/provenance/ProvenanceRequestDTO.java | 4 +-
.../api/dto/provenance/ProvenanceResultsDTO.java | 4 +-
.../dto/provenance/ProvenanceSearchValueDTO.java | 1 -
.../provenance/ProvenanceSearchableFieldDTO.java | 1 -
.../web/api/dto/provenance/lineage/LineageDTO.java | 4 +-
.../dto/provenance/lineage/LineageRequestDTO.java | 1 -
.../dto/provenance/lineage/LineageResultsDTO.java | 2 +-
.../dto/provenance/lineage/ProvenanceLinkDTO.java | 4 +-
.../dto/provenance/lineage/ProvenanceNodeDTO.java | 4 +-
.../apache/nifi/web/api/dto/remote/PeerDTO.java | 1 -
.../api/dto/search/ComponentSearchResultDTO.java | 2 +-
.../web/api/dto/search/NodeSearchResultDTO.java | 1 -
.../web/api/dto/search/SearchResultGroupDTO.java | 1 -
.../nifi/web/api/dto/search/SearchResultsDTO.java | 2 +-
.../nifi/web/api/dto/status/ClusterStatusDTO.java | 2 +-
.../web/api/dto/status/ComponentStatusDTO.java | 1 -
.../api/dto/status/ConnectionStatisticsDTO.java | 4 +-
.../status/ConnectionStatisticsSnapshotDTO.java | 3 +-
.../web/api/dto/status/ConnectionStatusDTO.java | 4 +-
.../ConnectionStatusPredictionsSnapshotDTO.java | 1 -
.../dto/status/ConnectionStatusSnapshotDTO.java | 1 -
.../api/dto/status/ControllerServiceStatusDTO.java | 1 -
.../web/api/dto/status/ControllerStatusDTO.java | 1 -
.../api/dto/status/FlowAnalysisRuleStatusDTO.java | 1 -
.../NodeConnectionStatisticsSnapshotDTO.java | 1 -
.../status/NodeConnectionStatusSnapshotDTO.java | 1 -
.../nifi/web/api/dto/status/NodePortStatusDTO.java | 3 +-
.../api/dto/status/NodePortStatusSnapshotDTO.java | 1 -
.../dto/status/NodeProcessorStatusSnapshotDTO.java | 1 -
.../NodeRemoteProcessGroupStatusSnapshotDTO.java | 1 -
.../nifi/web/api/dto/status/NodeStatusDTO.java | 3 +-
.../web/api/dto/status/NodeStatusSnapshotsDTO.java | 2 +-
.../nifi/web/api/dto/status/PortStatusDTO.java | 4 +-
.../web/api/dto/status/PortStatusSnapshotDTO.java | 1 -
.../web/api/dto/status/ProcessGroupStatusDTO.java | 4 +-
.../dto/status/ProcessGroupStatusSnapshotDTO.java | 2 +-
.../web/api/dto/status/ProcessorStatusDTO.java | 4 +-
.../api/dto/status/ProcessorStatusSnapshotDTO.java | 1 -
.../dto/status/RemoteProcessGroupStatusDTO.java | 4 +-
.../RemoteProcessGroupStatusSnapshotDTO.java | 1 -
.../web/api/dto/status/ReportingTaskStatusDTO.java | 1 -
.../web/api/dto/status/StatusDescriptorDTO.java | 2 +-
.../nifi/web/api/dto/status/StatusHistoryDTO.java | 4 +-
.../nifi/web/api/dto/status/StatusSnapshotDTO.java | 2 +-
.../nifi/web/api/dto/util/DateTimeAdapter.java | 4 +-
.../nifi/web/api/dto/util/InstantAdapter.java | 1 +
.../apache/nifi/web/api/dto/util/TimeAdapter.java | 1 +
.../nifi/web/api/dto/util/TimestampAdapter.java | 4 +-
.../nifi/web/api/dto/util/TimezoneAdapter.java | 1 +
.../nifi/web/api/entity/AccessPolicyEntity.java | 4 +-
.../web/api/entity/AccessPolicySummaryEntity.java | 3 +-
.../apache/nifi/web/api/entity/ActionEntity.java | 4 +-
.../entity/ActivateControllerServicesEntity.java | 2 +-
.../web/api/entity/AffectedComponentEntity.java | 2 +-
.../web/api/entity/AnalyzeFlowRequestEntity.java | 3 +-
.../apache/nifi/web/api/entity/BannerEntity.java | 1 -
.../apache/nifi/web/api/entity/BulletinEntity.java | 4 +-
.../ClearBulletinsForGroupResultsEntity.java | 1 -
.../api/entity/ClearBulletinsRequestEntity.java | 1 -
.../web/api/entity/ClearBulletinsResultEntity.java | 2 +-
.../web/api/entity/ClusterSearchResultsEntity.java | 3 +-
.../nifi/web/api/entity/ClusterSummaryEntity.java | 3 +-
.../nifi/web/api/entity/ComponentEntity.java | 2 +-
.../web/api/entity/ComponentReferenceEntity.java | 3 +-
.../web/api/entity/ComponentRunStatusEntity.java | 2 +-
.../nifi/web/api/entity/ComponentStateEntity.java | 3 +-
.../entity/ComponentValidationResultEntity.java | 3 +-
.../entity/ComponentValidationResultsEntity.java | 2 +-
.../api/entity/ConfigurationAnalysisEntity.java | 3 +-
.../nifi/web/api/entity/ConnectionEntity.java | 2 +-
.../web/api/entity/ConnectionStatisticsEntity.java | 3 +-
.../web/api/entity/ConnectionStatusEntity.java | 3 +-
.../nifi/web/api/entity/ConnectionsEntity.java | 1 +
.../web/api/entity/ControllerBulletinsEntity.java | 2 +-
.../api/entity/ControllerConfigurationEntity.java | 3 +-
.../web/api/entity/ControllerServiceEntity.java | 3 +-
...ontrollerServiceReferencingComponentEntity.java | 3 +-
...ntrollerServiceReferencingComponentsEntity.java | 4 +-
.../entity/ControllerServiceRunStatusEntity.java | 1 -
.../api/entity/ControllerServiceTypesEntity.java | 3 +-
.../web/api/entity/ControllerServicesEntity.java | 4 +-
.../web/api/entity/CopySnippetRequestEntity.java | 1 -
.../web/api/entity/CreateActiveRequestEntity.java | 1 -
.../nifi/web/api/entity/CurrentUserEntity.java | 2 +-
.../nifi/web/api/entity/DropRequestEntity.java | 1 -
.../web/api/entity/FlowAnalysisResultEntity.java | 2 +-
.../web/api/entity/FlowAnalysisRuleEntity.java | 1 -
.../entity/FlowAnalysisRuleRunStatusEntity.java | 1 -
.../api/entity/FlowAnalysisRuleTypesEntity.java | 2 +-
.../nifi/web/api/entity/FlowBreadcrumbEntity.java | 3 +-
.../nifi/web/api/entity/FlowComparisonEntity.java | 6 +-
.../web/api/entity/FlowConfigurationEntity.java | 3 +-
.../org/apache/nifi/web/api/entity/FlowEntity.java | 3 +-
.../apache/nifi/web/api/entity/FlowFileEntity.java | 3 +-
.../web/api/entity/FlowRegistryBucketEntity.java | 3 +-
.../web/api/entity/FlowRegistryBucketsEntity.java | 1 +
.../web/api/entity/FlowRegistryClientEntity.java | 3 +-
.../api/entity/FlowRegistryClientTypesEntity.java | 2 +-
.../web/api/entity/FlowRegistryClientsEntity.java | 4 +-
.../apache/nifi/web/api/entity/FunnelsEntity.java | 1 +
.../nifi/web/api/entity/InputPortsEntity.java | 1 +
.../web/api/entity/JmxMetricsResultsEntity.java | 2 +-
.../apache/nifi/web/api/entity/LabelEntity.java | 3 +-
.../apache/nifi/web/api/entity/LabelsEntity.java | 1 +
.../nifi/web/api/entity/ListingRequestEntity.java | 3 +-
.../api/entity/NodeReplayLastEventSnapshotDTO.java | 1 -
.../nifi/web/api/entity/OutputPortsEntity.java | 1 +
.../web/api/entity/ParameterContextEntity.java | 3 +-
.../entity/ParameterContextReferenceEntity.java | 3 +-
.../api/entity/ParameterContextUpdateEntity.java | 2 +-
.../ParameterContextUpdateRequestEntity.java | 3 +-
.../ParameterContextValidationRequestEntity.java | 3 +-
.../web/api/entity/ParameterContextsEntity.java | 4 +-
.../nifi/web/api/entity/ParameterEntity.java | 3 +-
.../entity/ParameterGroupConfigurationEntity.java | 2 +-
...ameterProviderApplyParametersRequestEntity.java | 3 +-
.../ParameterProviderConfigurationEntity.java | 3 +-
.../web/api/entity/ParameterProviderEntity.java | 4 +-
...arameterProviderParameterApplicationEntity.java | 2 +-
.../ParameterProviderParameterFetchEntity.java | 3 +-
...arameterProviderReferencingComponentEntity.java | 3 +-
...rameterProviderReferencingComponentsEntity.java | 1 +
.../api/entity/ParameterProviderTypesEntity.java | 2 +-
.../apache/nifi/web/api/entity/PeersEntity.java | 2 +-
.../org/apache/nifi/web/api/entity/PortEntity.java | 3 +-
.../nifi/web/api/entity/PortRunStatusEntity.java | 1 -
.../nifi/web/api/entity/PortStatusEntity.java | 3 +-
.../web/api/entity/PrioritizerTypesEntity.java | 3 +-
.../nifi/web/api/entity/ProcessGroupEntity.java | 3 +-
.../web/api/entity/ProcessGroupFlowEntity.java | 3 +-
.../web/api/entity/ProcessGroupImportEntity.java | 3 +-
.../entity/ProcessGroupReplaceRequestEntity.java | 3 +-
.../web/api/entity/ProcessGroupStatusEntity.java | 1 -
.../web/api/entity/ProcessGroupUploadEntity.java | 3 +-
.../nifi/web/api/entity/ProcessGroupsEntity.java | 1 +
.../web/api/entity/ProcessorDiagnosticsEntity.java | 4 +-
.../nifi/web/api/entity/ProcessorEntity.java | 3 +-
.../entity/ProcessorRunStatusDetailsEntity.java | 3 +-
.../web/api/entity/ProcessorRunStatusEntity.java | 1 -
.../nifi/web/api/entity/ProcessorStatusEntity.java | 3 +-
.../nifi/web/api/entity/ProcessorTypesEntity.java | 3 +-
.../nifi/web/api/entity/ProcessorsEntity.java | 1 +
.../entity/ProcessorsRunStatusDetailsEntity.java | 1 +
.../web/api/entity/ProvenanceOptionsEntity.java | 1 -
.../web/api/entity/RemotePortRunStatusEntity.java | 1 -
.../web/api/entity/RemoteProcessGroupEntity.java | 3 +-
.../api/entity/RemoteProcessGroupPortEntity.java | 3 +-
.../api/entity/RemoteProcessGroupStatusEntity.java | 3 +-
.../web/api/entity/RemoteProcessGroupsEntity.java | 1 +
.../api/entity/ReplayLastEventRequestEntity.java | 1 -
.../api/entity/ReplayLastEventResponseEntity.java | 2 +-
.../web/api/entity/ReplayLastEventSnapshotDTO.java | 2 +-
.../nifi/web/api/entity/ReportingTaskEntity.java | 4 +-
.../api/entity/ReportingTaskRunStatusEntity.java | 1 -
.../web/api/entity/ReportingTaskTypesEntity.java | 3 +-
.../nifi/web/api/entity/ReportingTasksEntity.java | 4 +-
.../nifi/web/api/entity/ResourcesEntity.java | 2 +-
.../api/entity/RunStatusDetailsRequestEntity.java | 2 +-
.../nifi/web/api/entity/RuntimeManifestEntity.java | 3 +-
.../web/api/entity/ScheduleComponentsEntity.java | 2 +-
.../apache/nifi/web/api/entity/SnippetEntity.java | 3 +-
.../entity/StartVersionControlRequestEntity.java | 3 +-
.../nifi/web/api/entity/StatusHistoryEntity.java | 3 +-
.../web/api/entity/SubmitReplayRequestEntity.java | 1 -
.../web/api/entity/TenantCollectionEntity.java | 1 +
.../apache/nifi/web/api/entity/TenantEntity.java | 3 +-
.../apache/nifi/web/api/entity/TenantsEntity.java | 1 +
...ateControllerServiceReferenceRequestEntity.java | 2 +-
.../org/apache/nifi/web/api/entity/UserEntity.java | 3 +-
.../nifi/web/api/entity/UserGroupEntity.java | 3 +-
.../nifi/web/api/entity/UserGroupsEntity.java | 1 +
.../apache/nifi/web/api/entity/UsersEntity.java | 4 +-
.../web/api/entity/VerifyConfigRequestEntity.java | 3 +-
.../VersionControlComponentMappingEntity.java | 2 +-
.../entity/VersionControlInformationEntity.java | 3 +-
.../nifi/web/api/entity/VersionedFlowEntity.java | 3 +-
.../api/entity/VersionedFlowSnapshotEntity.java | 3 +-
.../VersionedFlowSnapshotMetadataEntity.java | 3 +-
.../VersionedFlowSnapshotMetadataSetEntity.java | 1 +
.../entity/VersionedFlowUpdateRequestEntity.java | 3 +-
.../nifi/web/api/entity/VersionedFlowsEntity.java | 1 +
.../VersionedReportingTaskImportRequestEntity.java | 3 +-
...VersionedReportingTaskImportResponseEntity.java | 2 +-
.../nifi/authorization/FileAccessPolicyMapper.java | 12 +-
.../FileAuthorizedUserGroupsMapper.java | 14 +-
.../FingerprintAccessPolicyMapper.java | 6 +-
.../FingerprintAuthorizedUserGroupsMapper.java | 6 +-
.../authorization/FileUserGroupProviderTest.java | 2 +-
.../repository/schema/ContentClaimFieldMap.java | 4 +-
.../repository/schema/ContentClaimSchema.java | 8 +-
.../repository/schema/FlowFileRecordFieldMap.java | 4 +-
.../repository/schema/FlowFileSchema.java | 6 +-
.../StandardAuthorizerConfigurationContext.java | 2 +-
.../authorization/StandardManagedAuthorizer.java | 6 +-
.../nifi/authorization/user/NiFiUserUtilsTest.java | 1 -
.../authorization/resource/DataAuthorizable.java | 3 +-
.../node/LeaderElectionNodeProtocolSender.java | 6 +-
.../coordination/node/NodeConnectionStatus.java | 7 +-
.../ClusterCoordinationProtocolSender.java | 6 +-
.../nifi/cluster/protocol/ConnectionResponse.java | 2 +-
.../apache/nifi/cluster/protocol/Heartbeat.java | 5 +-
.../nifi/cluster/protocol/HeartbeatPayload.java | 14 +-
.../nifi/cluster/protocol/NodeIdentifier.java | 6 +-
.../nifi/cluster/protocol/ProtocolListener.java | 4 +-
.../nifi/cluster/protocol/StandardDataFlow.java | 2 +-
.../ClusterCoordinationProtocolSenderListener.java | 10 +-
.../protocol/impl/SocketProtocolListener.java | 23 +-
.../cluster/protocol/jaxb/JaxbProtocolContext.java | 12 +-
.../jaxb/message/AdaptedConnectionRequest.java | 1 -
.../jaxb/message/AdaptedConnectionResponse.java | 2 +-
.../protocol/jaxb/message/AdaptedHeartbeat.java | 1 -
.../jaxb/message/AdaptedNodeConnectionStatus.java | 2 +-
.../protocol/jaxb/message/DataFlowAdapter.java | 1 -
.../jaxb/message/NodeConnectionStatusAdapter.java | 1 -
.../protocol/jaxb/message/ObjectFactory.java | 11 +-
.../message/ClusterWorkloadResponseMessage.java | 2 +-
.../protocol/message/ConnectionRequestMessage.java | 1 -
.../message/ConnectionResponseMessage.java | 3 +-
.../protocol/message/FlowResponseMessage.java | 1 -
.../cluster/protocol/message/HeartbeatMessage.java | 1 -
.../protocol/message/HeartbeatResponseMessage.java | 2 +-
.../NodeConnectionStatusResponseMessage.java | 1 -
.../protocol/message/NodeStatusChangeMessage.java | 1 -
.../cluster/protocol/message/OffloadMessage.java | 5 +-
.../nifi/cluster/protocol/message/PingMessage.java | 3 +-
.../message/ReconnectionRequestMessage.java | 4 +-
.../FrameworkClusterProtocolConfiguration.java | 2 +-
.../org/apache/nifi/io/socket/SocketListener.java | 7 +-
.../org/apache/nifi/io/socket/SocketUtils.java | 9 +-
.../protocol/impl/SocketProtocolListenerTest.java | 12 +-
.../jaxb/message/TestJaxbProtocolUtils.java | 2 +-
.../cluster/StandardClusterDetailsFactory.java | 1 -
.../coordination/http/EndpointResponseMerger.java | 4 +-
.../http/endpoints/AbstractNodeStatusEndpoint.java | 6 +-
.../endpoints/ComponentStateEndpointMerger.java | 16 +-
.../http/endpoints/CountersEndpointMerger.java | 10 +-
.../http/endpoints/DropRequestEndpointMerger.java | 10 +-
.../endpoints/FlowAnalysisRuleEndpointMerger.java | 2 +-
.../endpoints/FlowAnalysisRulesEndpointMerger.java | 2 +-
.../endpoints/ListFlowFilesEndpointMerger.java | 16 +-
.../ProcessorDiagnosticsEndpointMerger.java | 12 +-
.../ProcessorRunStatusDetailsEndpointMerger.java | 2 +-
.../endpoints/ProvenanceEventEndpointMerger.java | 10 +-
.../endpoints/SystemDiagnosticsEndpointMerger.java | 10 +-
.../VersionControlInformationEndpointMerger.java | 10 +-
.../http/replication/AsyncClusterResponse.java | 6 +-
.../http/replication/HttpReplicationClient.java | 4 +-
.../replication/RequestCompletionCallback.java | 4 +-
.../http/replication/ResponseUtils.java | 4 +-
.../replication/StandardAsyncClusterResponse.java | 12 +-
.../replication/ThreadPoolRequestReplicator.java | 7 +-
.../client/StandardHttpReplicationClient.java | 3 +-
.../http/replication/io/JsonEntitySerializer.java | 6 +-
.../http/replication/io/ReplicatedResponse.java | 27 +-
.../http/replication/io/XmlEntitySerializer.java | 8 +-
.../coordination/node/NodeStateManager.java | 4 +-
.../java/org/apache/nifi/cluster/event/Event.java | 4 +-
.../impl/FileBasedClusterNodeFirewall.java | 12 +-
.../manager/FlowAnalysisRuleEntityMerger.java | 2 +-
.../apache/nifi/cluster/manager/NodeResponse.java | 13 +-
.../VersionControlInformationEntityMerger.java | 4 +-
.../FrameworkClusterConfiguration.java | 2 +-
.../http/replication/TestResponseUtils.java | 2 +-
.../TestThreadPoolRequestReplicator.java | 8 +-
.../replication/io/TestJsonEntitySerializer.java | 18 +-
.../replication/util/MockReplicationClient.java | 17 +-
...dardFlowActionReporterConfigurationContext.java | 2 +-
.../validation/StandardValidationTrigger.java | 6 +-
.../AbstractFlowAnalysisRuleContext.java | 4 +-
.../flowanalysis/AbstractFlowAnalysisRuleNode.java | 2 +-
.../repository/StandardCounterRepository.java | 6 +-
.../repository/TransientClaimRepositoryRecord.java | 4 +-
.../repository/io/FlowFileAccessInputStream.java | 8 +-
.../repository/io/FlowFileAccessOutputStream.java | 6 +-
.../repository/io/TaskTerminationInputStream.java | 6 +-
.../repository/io/TaskTerminationOutputStream.java | 6 +-
.../StandardControllerServiceReference.java | 10 +-
.../nifi/controller/state/StandardStateMap.java | 3 +-
...StandardStateProviderInitializationContext.java | 11 +-
.../state/config/StateManagerConfiguration.java | 17 +-
.../manager/StandardStateManagerProvider.java | 31 +-
.../apache/nifi/groups/VersionControlFields.java | 4 +-
.../ComponentSpecificControllerServiceLookup.java | 4 +-
.../extension/NiFiRegistryExtensionRegistry.java | 2 +-
.../NiFiRegistryExternalResourceProvider.java | 2 +-
.../flow/FlowAnalyzingRegistryClientNode.java | 2 +-
.../flow/StandardVersionControlInformation.java | 4 +-
.../mapping/InstantiatedVersionedProcessGroup.java | 2 +-
.../flow/mapping/StandardComparableDataFlow.java | 4 +-
.../nifi/remote/StandardRemoteProcessGroup.java | 2 +-
.../repository/StandardProvenanceReporterTest.java | 1 -
.../repository/TestStandardFlowFileRecord.java | 6 +-
.../nifi/processor/TestStandardPropertyValue.java | 5 +-
.../flow/FlowAnalyzingRegistryClientNodeTest.java | 1 -
.../components/validation/ValidationState.java | 4 +-
.../nifi/controller/FlowAnalysisRuleNode.java | 4 +-
.../nifi/controller/ParameterProviderNode.java | 2 +-
.../apache/nifi/controller/ReloadComponent.java | 2 +-
.../org/apache/nifi/controller/WorkerQueue.java | 4 +-
.../nifi/controller/flow/VersionedDataflow.java | 2 +-
.../controller/repository/CounterRepository.java | 4 +-
.../controller/scheduling/SchedulingAgent.java | 6 +-
.../service/ControllerServiceReference.java | 4 +-
.../apache/nifi/logging/LogRepositoryFactory.java | 3 +-
.../nifi/registry/flow/FlowRegistryClientNode.java | 2 +-
...ardFlowRegistryClientInitializationContext.java | 2 +-
.../nifi/remote/protocol/ServerProtocol.java | 6 +-
.../apache/nifi/web/revision/RevisionClaim.java | 4 +-
.../apache/nifi/web/revision/RevisionManager.java | 1 -
.../apache/nifi/web/revision/RevisionUpdate.java | 4 +-
.../apache/nifi/util/CharacterFilterUtilsTest.java | 1 +
.../org/apache/nifi/cluster/BulletinsPayload.java | 16 +-
.../ClusterCoordinatorNodeInformant.java | 8 +-
.../apache/nifi/controller/ExtensionBuilder.java | 2 +-
.../controller/RingBufferGarbageCollectionLog.java | 6 +-
.../org/apache/nifi/controller/SnippetManager.java | 12 +-
.../apache/nifi/controller/StandardSnippet.java | 8 +-
.../nifi/controller/cluster/Heartbeater.java | 4 +-
.../nifi/controller/flow/StandardFlowManager.java | 3 +-
.../flowanalysis/StandardFlowAnalysisRuleNode.java | 6 +-
.../inheritance/BundleCompatibilityCheck.java | 4 +-
.../TaskTerminationAwareStateManager.java | 6 +-
.../nifi/controller/queue/DropFlowFileAction.java | 4 +-
.../queue/DropFlowFileRepositoryRecord.java | 6 +-
.../controller/queue/SwappablePriorityQueue.java | 1 -
.../queue/clustered/FlowFileContentAccess.java | 4 +-
.../clustered/SocketLoadBalancedFlowFileQueue.java | 2 +-
.../client/async/nio/LoadBalanceSession.java | 1 -
.../async/nio/NioAsyncLoadBalanceClient.java | 5 +-
.../clustered/client/async/nio/PeerChannel.java | 8 +-
.../clustered/partition/LocalQueuePartition.java | 2 +-
.../SwappablePriorityQueueLocalPartition.java | 2 +-
.../server/ClusterLoadBalanceAuthorizer.java | 4 +-
.../server/ConnectionLoadBalanceServer.java | 8 +-
.../clustered/server/LoadBalanceAuthorizer.java | 2 +-
.../server/StandardLoadBalanceProtocol.java | 2 +-
.../repository/BatchingSessionFactory.java | 21 +-
.../repository/NonPurgeableContentRepository.java | 5 +-
.../serialization/FlowEncodingVersion.java | 4 +-
.../controller/serialization/FlowSerializer.java | 4 +-
.../serialization/RunningComponentSetFilter.java | 1 +
.../serialization/VersionedDataflowMapper.java | 5 +-
.../nifi/controller/state/StateMapSerDe.java | 8 +-
.../state/providers/AbstractStateProvider.java | 4 +-
.../local/WriteAheadLocalStateProvider.java | 34 +-
.../CachingConnectionStatusAnalyticsEngine.java | 8 +-
.../analytics/ConnectionStatusAnalytics.java | 16 +-
.../analytics/ConnectionStatusAnalyticsEngine.java | 4 +-
.../analytics/StatusAnalyticsModelMapFactory.java | 12 +-
.../analytics/StatusMetricExtractFunction.java | 4 +-
.../models/BivariateStatusAnalyticsModel.java | 3 +-
.../status/analytics/models/SimpleRegression.java | 9 +-
.../controller/swap/SchemaSwapDeserializer.java | 12 +-
.../nifi/controller/swap/SchemaSwapSerializer.java | 16 +-
.../controller/swap/SimpleSwapDeserializer.java | 18 +-
.../nifi/controller/swap/StandardSwapContents.java | 6 +-
.../nifi/controller/swap/StandardSwapSummary.java | 6 +-
.../nifi/controller/swap/SwapDeserializer.java | 6 +-
.../apache/nifi/controller/swap/SwapSchema.java | 8 +-
.../nifi/controller/swap/SwapSerializer.java | 6 +-
.../nifi/controller/swap/SwapSummaryFieldMap.java | 10 +-
.../controller/tasks/ReportingTaskWrapper.java | 2 +-
.../bootstrap/tasks/DiagnosticAnalysisTask.java | 2 +-
.../tasks/OperatingSystemDiagnosticTask.java | 8 +-
.../events/NodeBulletinProcessingStrategy.java | 6 +-
.../nifi/flowanalysis/GhostFlowAnalysisRule.java | 1 +
.../configuration/FlowControllerConfiguration.java | 6 +-
.../configuration/ManagerConfiguration.java | 2 +-
.../configuration/SslContextConfiguration.java | 6 +-
.../framework/ssl/FrameworkKeyManagerBuilder.java | 2 +-
.../framework/ssl/FrameworkSslContextHolder.java | 2 +-
.../framework/ssl/FrameworkSslContextProvider.java | 8 +-
.../ssl/FrameworkTrustManagerBuilder.java | 2 +-
.../ssl/SecurityStoreChangedPathListener.java | 4 +-
.../java/org/apache/nifi/jaxb/AdaptedBulletin.java | 4 +-
.../java/org/apache/nifi/jaxb/BulletinAdapter.java | 1 -
.../persistence/StandardFlowConfigurationDAO.java | 19 +-
.../persistence/StandardSnippetDeserializer.java | 8 +-
.../persistence/StandardSnippetSerializer.java | 8 +-
.../org/apache/nifi/processor/GhostProcessor.java | 10 +-
.../apache/nifi/reporting/GhostReportingTask.java | 8 +-
.../apache/nifi/cluster/HeartbeatPayloadTest.java | 12 +-
.../nifi/controller/DummyScheduledProcessor.java | 1 -
.../controller/DummyScheduledReportingTask.java | 6 +-
.../queue/clustered/LoadBalancedQueueIT.java | 4 +-
.../queue/clustered/TestNaiveLimitThreshold.java | 2 +-
.../TestSocketLoadBalancedFlowFileQueue.java | 4 +-
.../client/async/nio/TestPeerChannel.java | 10 +-
.../server/ClusteredLoadBalanceAuthorizerTest.java | 4 +-
.../server/ConnectionLoadBalanceServerTest.java | 10 +-
.../repository/io/TestLimitedInputStream.java | 2 +-
.../nifi/controller/repository/util/DiskUtils.java | 6 +-
.../controller/scheduling/LongEnablingService.java | 4 +-
.../scheduling/TestStandardProcessScheduler.java | 2 +-
.../processors/FailOnScheduledProcessor.java | 6 +-
.../StandardControllerServiceProviderTest.java | 2 +-
.../TestStandardControllerServiceProvider.java | 2 +-
.../controller/service/mock/DummyProcessor.java | 6 +-
.../nifi/controller/service/mock/ServiceA.java | 4 +-
.../nifi/controller/service/mock/ServiceC.java | 4 +-
.../service/util/TestControllerService.java | 6 +-
.../state/providers/AbstractTestStateProvider.java | 8 +-
.../local/TestWriteAheadLocalStateProvider.java | 4 +-
.../analytics/TestConnectionStatusAnalytics.java | 36 +-
.../TestStatusAnalyticsModelMapFactory.java | 14 +-
.../JsonNodeStatusHistoryDumpFactoryTest.java | 1 -
...ComponentStatusRepositoryForComponentsTest.java | 2 +-
.../apache/nifi/controller/swap/MockFlowFile.java | 10 +-
.../events/TestNodeBulletinProcessingStrategy.java | 4 +-
.../TestFlowConfigurationArchiveManager.java | 2 +-
.../processors/DataGeneratorTestProcessor.java | 13 +-
.../processors/StubAttributeLoggerProcessor.java | 12 +-
...ernalResourceProviderInitializationContext.java | 2 +-
.../CollisionAwareResourceProviderWorkerTest.java | 1 -
.../apache/nifi/nar/TestLoadNativeLibFromNar.java | 11 +-
.../nar/TestLoadNativeLibViaSystemProperty.java | 16 +-
.../java/org/apache/nifi/nar/TestNarLoader.java | 1 -
.../java/org/apache/nifi/init/ReflectionUtils.java | 7 +-
...ockFlowRegistryClientInitializationContext.java | 2 +-
.../java/org/apache/nifi/nar/NarCloseable.java | 4 +-
.../nifi/nar/NarThreadContextClassLoader.java | 35 +-
.../apache/nifi/nar/TestInstanceClassLoader.java | 4 +-
.../apache/nifi/headless/HeadlessNiFiServer.java | 2 +-
.../java/org/apache/nifi/nar/NarClassLoader.java | 6 +-
.../main/java/org/apache/nifi/util/FileUtils.java | 3 +-
.../claim/TestStandardResourceClaimManager.java | 10 +-
.../src/main/java/org/apache/nifi/NiFi.java | 2 +-
.../apache/nifi/remote/RemoteResourceFactory.java | 10 +-
.../apache/nifi/remote/RemoteResourceManager.java | 11 +-
.../nifi/remote/SocketRemoteSiteListener.java | 35 +-
.../nifi/remote/StandardRemoteGroupPort.java | 2 +-
.../http/StandardHttpFlowFileServerProtocol.java | 2 +-
.../socket/SocketFlowFileServerProtocol.java | 19 +-
.../nifi/remote/TestSocketRemoteSiteListener.java | 1 +
.../apache/nifi/remote/TestStandardPublicPort.java | 5 +-
.../nifi/remote/TestStandardRemoteGroupPort.java | 2 +-
.../socket/TestSocketFlowFileServerProtocol.java | 2 +-
.../org/apache/nifi/action/FlowChangeAction.java | 1 +
.../org/apache/nifi/web/server/JettyServer.java | 79 +-
.../nifi/web/server/StandardServerProvider.java | 2 +-
.../connector/FrameworkServerConnectorFactory.java | 2 +-
.../filter/DataTransferExcludedDoSFilter.java | 4 +-
.../filter/StandardRequestFilterProvider.java | 2 +-
.../web/server/handler/HeaderWriterHandler.java | 3 +-
.../server/log/RequestAuthenticationFilter.java | 14 +-
.../web/server/StandardServerProviderTest.java | 4 +-
.../FrameworkServerConnectorFactoryTest.java | 4 +-
.../filter/DataTransferExcludedDoSFilterTest.java | 10 +-
.../filter/RestApiRequestFilterProviderTest.java | 2 +-
.../filter/StandardRequestFilterProviderTest.java | 2 +-
.../nifi/audit/RemoteProcessGroupAuditor.java | 25 +-
.../authorization/AuthorizeParameterReference.java | 4 +-
.../nifi/prometheusutil/VersionInfoRegistry.java | 2 +-
.../org/apache/nifi/web/NiFiServiceFacade.java | 2 +-
.../apache/nifi/web/NiFiWebApiConfiguration.java | 2 +-
.../apache/nifi/web/NiFiWebApiResourceConfig.java | 5 +-
.../apache/nifi/web/StandardNiFiContentAccess.java | 9 +-
.../apache/nifi/web/StandardNiFiServiceFacade.java | 4 +-
.../web/StandardNiFiWebConfigurationContext.java | 9 +-
.../nifi/web/api/AbstractParameterResource.java | 3 +-
.../apache/nifi/web/api/ApplicationResource.java | 31 +-
.../apache/nifi/web/api/ControllerResource.java | 8 +-
.../nifi/web/api/ControllerServiceResource.java | 2 +-
.../java/org/apache/nifi/web/api/FlowResource.java | 2 +-
.../apache/nifi/web/api/FlowUpdateResource.java | 9 +-
.../nifi/web/api/ParameterProviderResource.java | 4 +-
.../org/apache/nifi/web/api/ProcessorResource.java | 2 +-
.../apache/nifi/web/api/ProvenanceResource.java | 1 -
.../apache/nifi/web/api/ReportingTaskResource.java | 2 +-
.../api/config/AccessDeniedExceptionMapper.java | 9 +-
.../config/AuthorizationAccessExceptionMapper.java | 7 +-
.../web/api/config/ClusterExceptionMapper.java | 1 -
...onnectingNodeMutableRequestExceptionMapper.java | 4 +-
.../api/config/IllegalArgumentExceptionMapper.java | 5 +-
.../config/IllegalNodeOffloadExceptionMapper.java | 7 +-
.../api/config/IllegalStateExceptionMapper.java | 5 +-
.../web/api/config/InterruptedExceptionMapper.java | 1 -
.../api/config/InvalidRevisionExceptionMapper.java | 9 +-
.../JsonContentConversionExceptionMapper.java | 7 +-
.../web/api/config/JsonMappingExceptionMapper.java | 7 +-
.../web/api/config/JsonParseExceptionMapper.java | 2 +-
.../web/api/config/NiFiCoreExceptionMapper.java | 7 +-
.../NoClusterCoordinatorExceptionMapper.java | 1 -
.../web/api/config/NotFoundExceptionMapper.java | 7 +-
.../config/RangeNotSatisfiableExceptionMapper.java | 7 +-
.../config/ResourceNotFoundExceptionMapper.java | 9 +-
.../web/api/config/ValidationExceptionMapper.java | 2 +-
.../api/config/WebApplicationExceptionMapper.java | 7 +-
.../org/apache/nifi/web/api/dto/EntityFactory.java | 4 +-
.../web/api/filter/RedirectResourceFilter.java | 5 +-
.../metrics/AbstractPrometheusMetricsWriter.java | 1 +
.../web/api/metrics/jmx/JmxMetricsCollector.java | 8 +-
.../api/metrics/jmx/JmxMetricsResultConverter.java | 4 +-
.../nifi/web/api/request/ClientIdParameter.java | 3 +-
.../ApplicationStartupContextListener.java | 4 +-
.../apache/nifi/web/dao/impl/AbstractPortDAO.java | 2 +-
.../nifi/web/dao/impl/StandardConnectionDAO.java | 7 +-
.../nifi/web/dao/impl/StandardFlowRegistryDAO.java | 12 +-
.../dao/impl/StandardPolicyBasedAuthorizerDAO.java | 4 +-
.../nifi/web/dao/impl/StandardProcessGroupDAO.java | 3 +-
.../apache/nifi/web/filter/ExceptionFilter.java | 3 +-
.../apache/nifi/web/util/ClientResponseUtils.java | 2 +-
.../util/ClusterReplicationComponentLifecycle.java | 12 +-
.../nifi/web/util/ParameterContextReplacer.java | 2 +-
.../org/apache/nifi/audit/TestLabelAuditor.java | 2 +-
.../apache/nifi/audit/TestProcessorAuditor.java | 1 -
.../nifi/web/StandardNiFiServiceFacadeTest.java | 5 +-
.../nifi/web/api/TestApplicationResource.java | 4 +-
.../nifi/web/api/TestDataTransferResource.java | 14 +-
.../org/apache/nifi/web/api/TestFlowResource.java | 7 +-
.../nifi/web/api/TestProcessGroupResource.java | 4 +-
.../nifi/web/api/TestSiteToSiteResource.java | 4 +-
.../apache/nifi/web/api/TestVersionsResource.java | 2 +-
.../JsonContentConversionExceptionMapperTest.java | 2 +-
.../web/api/filter/TestRedirectResourceFilter.java | 4 +-
.../metrics/jmx/JmxMetricsResultConverterTest.java | 2 +-
.../web/dao/impl/StandardProcessorDAOTest.java | 2 +-
.../web/dao/impl/TestStandardProcessGroupDAO.java | 10 +-
.../ProcessorMetadataMatcherTest.java | 1 -
.../search/query/RegexSearchQueryParserTest.java | 1 -
.../nifi/web/util/ResponseBuilderUtilsTest.java | 2 -
.../org/apache/nifi/web/util/SnippetUtilsTest.java | 1 -
.../nifi/web/revision/RevisionComparator.java | 4 +-
.../nifi/web/revision/StandardRevisionClaim.java | 4 +-
.../nifi/web/revision/StandardRevisionUpdate.java | 6 +-
.../web/security/NiFiAuthenticationFilter.java | 12 +-
.../security/NiFiAuthenticationRequestToken.java | 4 +-
.../nifi/web/security/ProxiedEntitiesUtils.java | 17 +-
.../security/StandardAuthenticationEntryPoint.java | 4 +-
.../NiFiAnonymousAuthenticationFilter.java | 3 +-
.../ClientRegistrationConfiguration.java | 2 +-
.../JwtAuthenticationSecurityConfiguration.java | 6 +-
.../configuration/OidcSecurityConfiguration.java | 4 +-
.../SamlAuthenticationSecurityConfiguration.java | 16 +-
.../configuration/WebSecurityConfiguration.java | 4 +-
.../security/cookie/ApplicationCookieService.java | 1 +
.../cookie/StandardApplicationCookieService.java | 6 +-
.../security/csrf/CsrfCookieRequestMatcher.java | 2 +-
.../security/csrf/SkipReplicatedCsrfFilter.java | 8 +-
.../csrf/StandardCookieCsrfTokenRepository.java | 6 +-
.../jwt/resolver/StandardBearerTokenResolver.java | 5 +-
.../jwt/revocation/JwtRevocationValidator.java | 2 +-
.../web/security/log/AuthenticationUserFilter.java | 8 +-
.../web/security/logout/StandardLogoutFilter.java | 8 +-
.../StandardOidcIdTokenDecoderFactory.java | 6 +-
.../client/web/OidcBearerTokenRefreshFilter.java | 8 +-
.../StandardAuthorizationRequestRepository.java | 4 +-
...StandardOAuth2AuthorizationRequestResolver.java | 2 +-
.../StandardOidcAuthorizedClientRepository.java | 4 +-
.../oidc/logout/OidcLogoutSuccessHandler.java | 6 +-
.../StandardClientRegistrationProvider.java | 8 +-
.../OidcAuthenticationSuccessHandler.java | 4 +-
.../web/security/requests/ContentLengthFilter.java | 6 +-
.../StandardRegistrationBuilderProvider.java | 4 +-
...StandardRelyingPartyRegistrationRepository.java | 4 +-
.../StandardRelyingPartyRegistrationResolver.java | 2 +-
...andardSaml2AuthenticationRequestRepository.java | 4 +-
.../Saml2AuthenticationSuccessHandler.java | 4 +-
.../logout/Saml2LocalLogoutFilter.java | 1 +
.../logout/Saml2LogoutSuccessHandler.java | 4 +-
.../logout/Saml2SingleLogoutFilter.java | 8 +-
.../logout/Saml2SingleLogoutHandler.java | 5 +-
.../StandardSaml2LogoutRequestRepository.java | 4 +-
.../spring/LoginIdentityProviderFactoryBean.java | 31 +-
...dLoginIdentityProviderConfigurationContext.java | 3 +-
.../x509/SubjectDnX509PrincipalExtractor.java | 4 +-
.../security/x509/X509AuthenticationFilter.java | 2 +-
.../security/x509/X509CertificateExtractor.java | 3 +-
.../StandardAuthenticationEntryPointTest.java | 6 +-
.../StandardApplicationCookieServiceTest.java | 6 +-
.../csrf/SkipReplicatedCsrfFilterTest.java | 7 +-
.../StandardCookieCsrfTokenRepositoryTest.java | 3 +-
.../resolver/StandardBearerTokenResolverTest.java | 5 +-
.../security/log/AuthenticationUserFilterTest.java | 8 +-
.../web/OidcBearerTokenRefreshFilterTest.java | 4 +-
...StandardAuthorizationRequestRepositoryTest.java | 3 +-
...dardOAuth2AuthorizationRequestResolverTest.java | 3 +-
.../oidc/logout/OidcLogoutSuccessHandlerTest.java | 2 +-
.../OidcAuthenticationSuccessHandlerTest.java | 4 +-
.../StandardRegistrationBuilderProviderTest.java | 11 +-
...dardRelyingPartyRegistrationRepositoryTest.java | 6 +-
...rdSaml2AuthenticationRequestRepositoryTest.java | 3 +-
.../Saml2AuthenticationSuccessHandlerTest.java | 4 +-
.../logout/Saml2LocalLogoutFilterTest.java | 2 +-
.../logout/Saml2LogoutSuccessHandlerTest.java | 2 +-
.../logout/Saml2SingleLogoutFilterTest.java | 4 +-
.../StandardSaml2LogoutRequestRepositoryTest.java | 2 +-
.../x509/X509AuthenticationProviderTest.java | 15 +-
.../nifi/extension/manifest/AllowableValue.java | 3 -
.../apache/nifi/extension/manifest/Attribute.java | 1 -
.../apache/nifi/extension/manifest/BuildInfo.java | 1 -
.../manifest/ControllerServiceDefinition.java | 2 +-
.../nifi/extension/manifest/DefaultSchedule.java | 1 -
.../nifi/extension/manifest/DefaultSettings.java | 1 -
.../apache/nifi/extension/manifest/Dependency.java | 1 -
.../nifi/extension/manifest/DependentValues.java | 2 +-
.../nifi/extension/manifest/DeprecationNotice.java | 2 +-
.../nifi/extension/manifest/DynamicProperty.java | 1 -
.../extension/manifest/DynamicRelationship.java | 3 -
.../apache/nifi/extension/manifest/Extension.java | 2 +-
.../nifi/extension/manifest/ExtensionManifest.java | 2 +-
.../extension/manifest/MultiProcessorUseCase.java | 1 +
.../apache/nifi/extension/manifest/ParentNar.java | 1 -
.../apache/nifi/extension/manifest/Property.java | 2 +-
.../extension/manifest/ProvidedServiceAPI.java | 2 +-
.../nifi/extension/manifest/Relationship.java | 1 -
.../extension/manifest/ResourceDefinition.java | 2 +-
.../apache/nifi/extension/manifest/Restricted.java | 2 +-
.../nifi/extension/manifest/Restriction.java | 2 +-
.../apache/nifi/extension/manifest/Stateful.java | 2 +-
.../manifest/SystemResourceConsideration.java | 1 -
.../apache/nifi/extension/manifest/UseCase.java | 1 +
.../parser/jaxb/JAXBExtensionManifestParser.java | 10 +-
.../java/org/apache/nifi/state/MockStateMap.java | 3 +-
.../nifi/util/ControllerServiceConfiguration.java | 5 +-
.../nifi/util/MockControllerServiceLookup.java | 7 +-
.../java/org/apache/nifi/util/MockEventAccess.java | 14 +-
.../java/org/apache/nifi/util/MockFlowFile.java | 10 +-
.../org/apache/nifi/util/MockFlowFileQueue.java | 4 +-
.../org/apache/nifi/util/MockKerberosContext.java | 3 +-
.../org/apache/nifi/util/MockParameterLookup.java | 1 -
.../org/apache/nifi/util/MockProcessSession.java | 39 +-
.../util/MockProcessorInitializationContext.java | 7 +-
.../org/apache/nifi/util/MockPropertyContext.java | 5 +-
.../org/apache/nifi/util/MockPropertyValue.java | 11 +-
.../org/apache/nifi/util/MockReportingContext.java | 13 +-
.../util/MockReportingInitializationContext.java | 9 +-
.../java/org/apache/nifi/util/ReflectionUtils.java | 5 +-
.../org/apache/nifi/util/SharedSessionState.java | 7 +-
.../apache/nifi/util/TestMockParameterLookup.java | 1 -
.../nifi/registry/bootstrap/BootstrapCodec.java | 4 +-
.../minificpp/MiNiFiCppBundleExtractor.java | 2 +-
.../bundle/extract/nar/NarBundleExtractor.java | 2 +-
.../nifi/registry/bundle/model/BundleDetails.java | 3 +-
.../bundle/extract/nar/TestNarBundleExtractor.java | 4 +-
.../registry/client/NiFiRegistryClientConfig.java | 4 +-
.../client/impl/AbstractCRUDJerseyClient.java | 6 +-
.../registry/client/impl/AbstractJerseyClient.java | 8 +-
.../nifi/registry/client/impl/ClientUtils.java | 2 +-
.../registry/client/impl/JerseyAccessClient.java | 6 +-
.../registry/client/impl/JerseyBucketClient.java | 6 +-
.../registry/client/impl/JerseyBundleClient.java | 2 +-
.../client/impl/JerseyExtensionRepoClient.java | 10 +-
.../registry/client/impl/JerseyFlowClient.java | 6 +-
.../client/impl/JerseyFlowSnapshotClient.java | 6 +-
.../registry/client/impl/JerseyItemsClient.java | 2 +-
.../client/impl/JerseyNiFiRegistryClient.java | 10 +-
.../registry/client/impl/JerseyPoliciesClient.java | 2 +-
.../registry/client/impl/JerseyTenantsClient.java | 2 +-
.../registry/client/impl/JerseyUserClient.java | 2 +-
.../apache/nifi/registry/about/RegistryAbout.java | 1 -
.../apache/nifi/registry/authorization/Tenant.java | 6 +-
.../apache/nifi/registry/authorization/User.java | 1 +
.../org/apache/nifi/registry/bucket/Bucket.java | 3 +-
.../apache/nifi/registry/bucket/BucketItem.java | 3 +-
.../registry/extension/bundle/BundleVersion.java | 3 +-
.../extension/bundle/BundleVersionDependency.java | 2 +-
.../extension/bundle/BundleVersionMetadata.java | 4 +-
.../extension/repo/ExtensionRepoArtifact.java | 2 +-
.../extension/repo/ExtensionRepoBucket.java | 2 +-
.../extension/repo/ExtensionRepoGroup.java | 2 +-
.../repo/ExtensionRepoVersionSummary.java | 2 +-
.../nifi/registry/flow/VersionedFlowSnapshot.java | 5 +-
.../flow/VersionedFlowSnapshotMetadata.java | 4 +-
.../org/apache/nifi/registry/link/JaxbLink.java | 2 +-
.../org/apache/nifi/registry/link/LinkAdapter.java | 1 +
.../registry/flow/diff/ComparableDataFlow.java | 2 +-
.../nifi/registry/flow/diff/FlowComparator.java | 4 +-
.../nifi/registry/flow/diff/FlowDifference.java | 4 +-
.../flow/diff/StandardComparableDataFlow.java | 2 +-
.../registry/db/CustomFlywayConfiguration.java | 2 +-
.../registry/db/CustomFlywayMigrationStrategy.java | 2 +-
.../nifi/registry/db/entity/ExtensionEntity.java | 2 +-
.../registry/db/mapper/BucketEntityRowMapper.java | 2 +-
.../db/mapper/BucketItemEntityRowMapper.java | 2 +-
.../db/mapper/ExtensionEntityRowMapper.java | 2 +-
.../registry/db/mapper/FlowEntityRowMapper.java | 2 +-
.../db/mapper/FlowSnapshotEntityRowMapper.java | 2 +-
.../registry/db/mapper/KeyEntityRowMapper.java | 2 +-
.../db/migration/LegacyDataSourceFactory.java | 2 +-
.../db/migration/LegacyDatabaseService.java | 2 +-
.../apache/nifi/registry/event/EventService.java | 2 +-
.../nifi/registry/extension/ExtensionManager.java | 6 +-
.../nifi/registry/provider/ProviderFactory.java | 4 +-
.../registry/provider/StandardProviderFactory.java | 29 +-
.../StandardBundlePersistenceContext.java | 4 +-
.../flow/DatabaseFlowPersistenceProvider.java | 2 +-
.../provider/hook/ScriptEventHookProvider.java | 12 +-
.../authentication/IdentityProviderFactory.java | 25 +-
.../AbstractPolicyBasedAuthorizer.java | 6 +-
.../security/authorization/AuthorizerFactory.java | 43 +-
.../authorization/StandardManagedAuthorizer.java | 6 +-
.../database/DatabaseAccessPolicyProvider.java | 2 +-
.../database/DatabaseUserGroupProvider.java | 2 +-
.../authorization/file/AuthorizationsHolder.java | 5 +-
.../file/FileAccessPolicyProvider.java | 24 +-
.../authorization/file/FileUserGroupProvider.java | 24 +-
.../authorization/file/UserGroupHolder.java | 5 +-
.../security/ldap/LdapIdentityProvider.java | 4 +-
.../registry/security/ldap/LdapsSocketFactory.java | 4 +-
.../ldap/tenants/LdapUserGroupProvider.java | 12 +-
.../security/ldap/tenants/TenantHolder.java | 1 -
.../jackson/SerializationContainer.java | 2 +-
.../serialization/jaxb/JAXBSerializer.java | 10 +-
.../nifi/registry/service/RegistryService.java | 6 +-
.../extension/BundleMetadataExtractors.java | 2 +-
.../extension/docs/HtmlExtensionDocWriter.java | 9 +-
.../nifi/registry/service/mapper/FlowMappings.java | 2 +-
.../registry/GenerateExtensionManifestSchema.java | 8 +-
.../provider/MockFlowPersistenceProvider.java | 2 +-
.../provider/TestStandardProviderFactory.java | 2 +-
.../flow/TestDatabaseFlowPersistenceProvider.java | 2 +-
.../flow/git/TestGitFlowPersistenceProvider.java | 19 +-
.../provider/hook/TestScriptEventHookProvider.java | 3 +-
.../database/TestDatabaseAccessPolicyProvider.java | 2 +-
.../database/TestDatabaseUserGroupProvider.java | 2 +-
.../serialization/TestFlowContentSerializer.java | 2 +-
.../nifi/registry/service/TestRegistryService.java | 8 +-
.../ApplicationServerConnectorFactory.java | 2 +-
.../jetty/handler/HeaderWriterHandler.java | 3 +-
.../jetty/handler/StandardHandlerProvider.java | 8 +-
.../ApplicationServerConnectorFactoryTest.java | 2 +-
.../properties/util/IdentityMappingUtil.java | 2 +-
.../revision/jdbc/TestJdbcRevisionManager.java | 2 +-
.../authentication/BasicAuthIdentityProvider.java | 3 +-
.../authentication/BearerAuthIdentityProvider.java | 3 +-
.../security/authentication/IdentityProvider.java | 3 +-
.../nifi/registry/db/MariaDBDataSourceFactory.java | 3 +-
.../nifi/registry/db/MySqlDataSourceFactory.java | 3 +-
.../registry/db/Postgres11DataSourceFactory.java | 3 +-
.../registry/db/Postgres12DataSourceFactory.java | 3 +-
.../registry/db/Postgres13DataSourceFactory.java | 3 +-
.../org/apache/nifi/registry/util/FileUtils.java | 3 +-
.../registry/NiFiRegistryPropertiesFactory.java | 3 +-
.../registry/web/NiFiRegistryResourceConfig.java | 9 +-
.../nifi/registry/web/api/AccessResource.java | 4 +-
.../nifi/registry/web/api/ApplicationResource.java | 15 +-
.../web/mapper/AccessDeniedExceptionMapper.java | 9 +-
.../web/mapper/AdministrationExceptionMapper.java | 7 +-
...ticationCredentialsNotFoundExceptionMapper.java | 7 +-
.../mapper/AuthorizationAccessExceptionMapper.java | 7 +-
.../web/mapper/BadRequestExceptionMapper.java | 9 +-
.../mapper/ConstraintViolationExceptionMapper.java | 9 +-
.../web/mapper/IllegalStateExceptionMapper.java | 7 +-
.../InvalidAuthenticationExceptionMapper.java | 7 +-
.../web/mapper/InvalidRevisionExceptionMapper.java | 7 +-
.../web/mapper/NiFiRegistryJsonProvider.java | 7 +-
.../web/mapper/NotAllowedExceptionMapper.java | 9 +-
.../web/mapper/NotFoundExceptionMapper.java | 1 -
.../web/mapper/QueryParamExceptionMapper.java | 7 +-
.../mapper/ResourceNotFoundExceptionMapper.java | 7 +-
.../web/mapper/SerializationExceptionMapper.java | 7 +-
.../web/mapper/UnauthorizedExceptionMapper.java | 7 +-
.../web/mapper/UntrustedProxyExceptionMapper.java | 7 +-
.../web/security/NiFiRegistrySecurityConfig.java | 3 +-
.../authentication/AnonymousIdentityFilter.java | 3 +-
.../security/authentication/IdentityFilter.java | 10 +-
.../kerberos/KerberosSpnegoIdentityProvider.java | 4 +-
.../oidc/StandardOidcIdentityProvider.java | 48 +-
.../x509/X509CertificateExtractor.java | 2 +-
.../authentication/x509/X509IdentityProvider.java | 2 +-
.../authorization/ResourceAuthorizationFilter.java | 12 +-
.../web/service/ExportedVersionedFlowSnapshot.java | 1 -
.../apache/nifi/registry/web/api/BucketsIT.java | 9 +-
.../org/apache/nifi/registry/web/api/FlowsIT.java | 12 +-
.../nifi/registry/web/api/IntegrationTestBase.java | 10 +-
.../registry/web/api/IntegrationTestUtils.java | 4 +-
.../nifi/registry/web/api/NoRevisionsIT.java | 7 +-
.../apache/nifi/registry/web/api/SecureFileIT.java | 6 +-
.../nifi/registry/web/api/SecureKerberosIT.java | 4 +-
.../nifi/registry/web/api/TenantResourceTest.java | 2 +-
.../nifi/registry/web/filter/LoginFilter.java | 1 +
.../FlowPersistenceProviderMigrator.java | 3 +-
.../FlowPersistenceProviderMigratorTest.java | 5 +-
.../nifi/stateless/engine/NarUnpackLock.java | 5 +-
...ropertiesFileEngineConfigurationParserTest.java | 2 +-
.../extensions/FileSystemExtensionRepository.java | 2 +-
.../config/PropertiesFileFlowDefinitionParser.java | 2 +-
.../stateless/config/SslConfigurationUtil.java | 10 +-
.../core/RegistryFlowSnapshotProvider.java | 7 +-
.../nifi/stateless/engine/ComponentBuilder.java | 15 +-
.../stateless/engine/StatelessReloadComponent.java | 2 +-
.../stateless/engine/StatelessSchedulingAgent.java | 2 +-
.../repository/ByteArrayContentRepository.java | 13 +-
.../StatelessFileSystemContentRepository.java | 25 +-
.../nifi/stateless/VersionedFlowBuilder.java | 2 +-
.../stateless/basics/CancelFlowExecutionIT.java | 2 +-
.../nifi/stateless/basics/CloneFlowFileIT.java | 4 +-
.../nifi/stateless/basics/CreatesFlowFileIT.java | 2 +-
.../nifi/stateless/basics/InputOutputIT.java | 4 +-
.../apache/nifi/stateless/basics/LoopingIT.java | 2 +-
.../apache/nifi/stateless/basics/SplittingIT.java | 2 +-
.../classloader/InstanceClassLoaderIT.java | 2 +-
.../tests/system/DependOnProperties.java | 5 +-
.../nifi/tests/system/AggregateNiFiInstance.java | 2 +-
.../org/apache/nifi/tests/system/NiFiInstance.java | 2 +-
.../nifi/tests/system/NiFiInstanceCache.java | 2 +-
.../org/apache/nifi/tests/system/NiFiSystemIT.java | 2 +-
.../tests/system/NiFiSystemKeyStoreProvider.java | 4 +-
.../SpawnedStandaloneNiFiInstanceFactory.java | 2 +-
.../nifi/toolkit/cli/api/ResolvedReference.java | 4 +-
.../command/registry/NiFiRegistryCommandGroup.java | 2 +-
.../TestRegisteredFlowSnapshotMetadataResult.java | 1 -
.../nifi/toolkit/client/NiFiClientConfig.java | 5 +-
.../nifi/toolkit/client/impl/JerseyNiFiClient.java | 3 +-
.../OIDCClientCredentialsRequestConfig.java | 5 +-
.../nifi/toolkit/client/TestProcessGroupBox.java | 4 +-
2021 files changed, 8850 insertions(+), 9042 deletions(-)
