This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/org.apache.hadoop-hadoop-common-3.2.3
in repository https://gitbox.apache.org/repos/asf/nifi.git
discard 464ba92725 Bump hadoop-common
add 6ae1590aef NIFI-9954 This closes #5993. Upgraded Spring Framework from
5.3.18 to 5.3.19
add 6ee3d32ca3 NIFI-9918: 'Parse XML Attributes' property added to
XMLReader NIFI-9918: Fixed review findings NIFI-9918: Example added to
XMLReader's additionalDetails.html on the new property. Minor documentation
fixes.
add 4b66299cf6 NIFI-9944: Fixed issue with using modules in
InvokeScriptedProcessor
add 8b08795e18 NIFI-9944 Configured maven-dependency-plugin for JavaScript
test JAR
add ac2d7d1e54 NIFI-9968 Added null check before System.setProperty() in
test methods
add fbfdcdca9f NIFI-9970 Restructured Pull Request Template
add a97c20cdb2 NIFI-9936 Added DescribedValue in PropertyDescriptor
Builder for AllowableValues
add 569929269a NIFI-9956: Fix QuerySalesforceObject schema parsing with
nested field strategy
add 2d5e24c0a2 NIFI-9975 Upgraded OWASP Dependency Check from 6.5.3 to
7.1.0
add fc2f539c7d NIFI-9976 Upgraded json-smart to 2.4.8
add 7271e8cea7 NIFI-7234 Standardized on Avro 1.11.0 NIFI-7234 Replaced
Jackson 1.X references with Jackson 2.X references in various classes.
NIFI-7234 Added jackson-annotations to nifi-hdfs-processors. NIFI-7234 Various
updates to bring our test cases into better alignment with the Avro
specification as of 1.11. Fixed a checkstyle issue.
add 5aa71570ff NIFI-9977 In StandardOauth2AccessTokenProvider add new
property to be able to set "scope".
add 21b263bd71 NIFI-9979 Removed nifi-druid-bundle and associated
components
add b04632129f NIFI-9798 Added Proxy Support for ConsumeGCPubSub and
PublishGCPubSub
add e175b146cd NIFI-9978: - Updating the condition under which we show the
Download Flow menu items.
add 04121c9d6a NIFI-8533: Replace deprecated jython-shaded with jython-slim
add 0f6679f2df NIFI-9980 Corrected conflicting GCP dependencies
add 3699d42116 NIFI-9932 Upgrade minimist from 1.2.5 to 1.2.6
add e20aa0ea2a NIFI-9755 Added ConsumeTwitter Processor
add 272325cb4e NIFI-9988 Corrected Property Decryption for Authorizers and
Providers
add 64f9b66141 NIFI-9984 Allow 200-series responses in OAuth2 Access Token
Provider
add ea75a0a996 NIFI-9995 Replaced Custom Filters with Spring Security
HeaderWriter
add 5e8b4d3144 NIFI-9997 Upgraded Ranger from 2.1.0 to 2.2.0 (#6022)
add 8f3445d48f NIFI-10000 Updated Pull Request Template Summary
add 65dbbc9e76 NIFI-9966 Corrects the registry loading of large flowfiles
from git
add 0c8305950c NIFI-9987 Standardize Commons IO on version 2.11.0
add 9c2e255fae NIFI-9986 Upgraded commons-configuration2 to 2.7 for
Accumulo
add b25201dd22 NIFI-9993: Fixed bug in initialization in which the Content
Repo did not properly increment the counter for how many files exist in the
archive directories. This was causing the counter to become negative in some
cases, which caused processors to incorrectly pause, waiting for content
archive cleanup to occur when, in fact, there were no files archived
add 728744a49b NIFI-9998: This closes #6023. Upgrade Hive3 to 3.1.3
add c3829e2198 NIFI-9999 Refactored MiNiFi tests using JUnit 5
add 9311188785 NIFI-10004: Allow loading .class files that are relative to
the NAR directory, in addition to the .jar / .nar files
add a038309ba4 NIFI-10006 Upgraded async from 2.6.3 to 2.6.4 for Registry
add 8aaa3d2f10 NIFI-9991 Fix: The asn1
StandardRecordModelIteratorProvider's interator returns only the first object
read from the input stream.
add 8247910a81 NIFI-9865: Add Atlas lineage for GCS processors (PutHDFS)
add dfc8b9c4c8 NIFI-10009 - bump Kudu client from 1.15 to 1.16
add e2b5773027 NIFI-9969 Add extension restrictions to C2 component
definition model
add a528b89169 NIFI-10003 - NiFi build fails in UTC+ time zones
add 4a60d1673e NIFI-10023: Ensure that any files that are archived upon
startup properly increment the archival count in the content repo
add 7cdbde1eba NIFI-10020 This closes #6039. Corrected
ClassNotFoundException in EmailNotificationService
add e826aca8f2 NIFI-10024 This closes #6041. Upgraded Netty from 4.1.74 to
4.1.77
add eecdf38158 NIFI-10014 Upgraded Registry Test JDBC Drivers
add 5215cc0ca0 NIFI-10026 This closes #6043. Added jakarta.activation
runtime dependency to bootstrap
add 313d70520d NIFI-9470 This closes #6027. Allow creation of Parameter
Context without any Inherited Parameter Contexts
add 30f7c1ba1e NIFI-9990 This closes #6030. Improved FTP 550 file
unavailable handling
add 8031b62351 NIFI-10001: When enabling a collection of Controller
Services, change… (#6042)
add 3f16a41ca1 NIFI-10010: ListenTCP adds Certificate Subject and Issuer
FlowFile attributes
add bd1e033d55 NIFI-9967: Added FlowSerializationStrategy to determine
which flow formats (XML,JSON) to save
add eba1318529 NIFI-10028: Added QuerySalesforceObject additionalDetails
and improved age field property descriptions
add 2a8d07641e NIFI-9895 Allow parameters to reference controller services
(#5958)
add 85d5e2071b NIFI-10031 Downgraded Jakarta Mail from 2.0.1 to 1.6.7
(#6052)
add fe424a2d42 NIFI-9805 Refactored Distributed Cache Servers using Netty
add 88e53eae8c NIFI-10001: Fixed bugs that caused some components to not
have their scheduled state updated. (#6049)
add 7754e8903e NIFI-10015 Upgraded Hadoop from 3.3.0 to 3.3.2
add 1cfca0d978 NIFI-10036: Corrected Elasticsearch Client Service to
prefix paths for all requests
add 38b51b0dde NIFI-10037: When system test fails to clean up flow,
destroy the entire environment so that the next test starts in a healthy state.
Name troubleshooting directories with the name of the test class to avoid
ambiguity. Also added a log statement so that we know which test is running
when looking at the log output from the tests themselves. Finally, found an
issue in AbstractComponentNode in which we iterate over the elements in a Map
and call setProperty, which can upda [...]
add e0976f42d3 NIFI-3869 Added HTTP/2 support to ListenHTTP and
HandleHttpRequest
add 9c9c708c14 NIFI-10043 fix ElasticsearchClient integration tests
following JUnit5 upgrade; update Elasticsearch and json-path dependency versions
add e74557f990 NIFI-10027: Add support for WEBP images to the image viewer
add 41b3778d67 NIFI-10044: Add content viewer support for YAML
add a4797327fc NIFI-7230: Created toInstant(), formatInstant(), toNanos()
and toMicros() expression language functions.
add c9c7d5f5a3 NIFI-10038 Added Java 17 to system-tests workflow (#6060)
add 99be62be67 NIFI-9958 Add Framework Support for Sensitive Dynamic
Properties (#6057)
add 205c58230b NIFI-9879 Add min/max age and min/max size properties to
ListAzure processors
add d664708dd3 NIFI-10049: When unscheduling reporting task, increment its
concurrent task count until we've finished all shutdown logic and then
decrement it, in much the same way that we do for processors
add e5203db960 NIFI-10046 Upgraded Gson to 2.9.0
add f66540eb6d NIFI-9951 Add proxy support to Azure ADLS and Blob v12
processors
add 83316736f8 NIFI-9959 Add UI Support for Sensitive Dynamic Properties
(#6073)
add 35d8bb5ca9 NIFI-10051: Clear Controller Services' state in a
background thread instead of the web thread.
add 98ec2563e9 NIFI-10059 Remove incorrect removal of controller service
from cache (#6082)
add d79b390836 NIFI-10056 Wrap table scan in a kerberos action in
KuduLookupService so that expired TGTs are renewed automatically.
add 9878df9f5a NIFI-9867 Adding new tests to increase Test Coverage of
GetTwitter
add 005fbe3c50 NIFI-10063: Wait for processor to become valid before
attempting to start it
add 314232ca6c NIFI-10072: Adding LoadBalanceStatus to ConnectionStatus
(#6086)
add 45cc3cefe5 NIFI-10069 Updated multiple components to support Sensitive
Dynamic Properties
add 0d45fef702 NIFI-10074 Fix potential UnsupportedOperationException in
PutSmbFile.customValidate. (#6088)
add 48de70a568 NIFI-10071: Adding support for HashiCorp Vault K/V version
2 Secrets Engine (#6087)
add 1f9672c18b NIFI-10075 Improved TestListSFTP configuration verification
add 7f93cb4c91 NIFI-6943 Set DataDogReportingTask API Key Property as
Sensitive
add 04aa32cd57 NIFI-10054: Improve SendTrapSNMP error handling
add 5a2992c243 NIFI-9960 Add documentation for Sensitive Dynamic
Properties (#6089)
add b5e61109f6 NIFI-9538: Add C2 heartbeat capability to minifi-c2-service
add 2015a4f22c NIFI-10086 Upgraded Spring Framework from 5.3.19 to 5.3.20
add 4c2fc216ab NIFI-9671 Deprecated GetTwitter in favor of ConsumeTwitter
add 639ab328c9 NIFI-10057: Add support for SQL Server's DATETIMEOFFSET
type to ExecuteSQL processors
add 4b655ecb68 NIFI-9804 Added HTTP/2 support to Application Server
add 1342ea7025 NIFI-10079 Upgraded ZooKeeper from 3.5.9 to 3.8.0
add 91952cde8a Bump hadoop-common
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (464ba92725)
\
N -- N -- N
refs/heads/dependabot/maven/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/org.apache.hadoop-hadoop-common-3.2.3
(91952cde8a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 104 ++--
.github/workflows/system-tests.yml | 42 ++
README.md | 32 +-
.../protocol/component/api/ExtensionComponent.java | 31 +
.../c2/protocol/component/api/Restriction.java | 61 ++
.../nifi/minifi/bootstrap/RunMiNiFiTest.java | 79 +--
.../ConfigurationChangeCoordinatorTest.java | 28 +-
.../WholeConfigDifferentiatorTest.java | 17 +-
.../ingestors/FileChangeIngestorTest.java | 47 +-
.../ingestors/PullHttpChangeIngestorSSLTest.java | 4 +-
.../ingestors/PullHttpChangeIngestorTest.java | 4 +-
.../ingestors/RestChangeIngestorSSLTest.java | 28 +-
.../ingestors/RestChangeIngestorTest.java | 10 +-
.../common/PullHttpChangeIngestorCommonTest.java | 19 +-
.../common/RestChangeIngestorCommonTest.java | 66 +-
.../bootstrap/util/ConfigTransformerTest.java | 37 +-
.../bootstrap/util/OrderedPropertiesTest.java | 6 +-
.../bootstrap/util/ParentGroupIdResolverTest.java | 9 +-
.../apache/nifi/minifi/c2/api/Configuration.java | 8 +
minifi/minifi-c2/minifi-c2-assembly/pom.xml | 2 +-
.../src/main/resources/conf/authorizations.yaml | 28 +
.../FileSystemWritableConfiguration.java | 11 +
.../minifi-c2-cache/minifi-c2-cache-s3/pom.xml | 5 -
.../c2/cache/s3/S3WritableConfiguration.java | 8 +-
.../minifi-c2/minifi-c2-integration-tests/pom.xml | 4 +-
.../c2/integration/test/AbstractTestSecure.java | 23 +-
.../c2/integration/test/AbstractTestUnsecure.java | 10 +-
.../DelegatingConfigurationProviderSecureTest.java | 18 +-
...elegatingConfigurationProviderUnsecureTest.java | 12 +-
.../test/FileSystemCacheProviderSecureTest.java | 16 +-
.../test/FileSystemCacheProviderUnsecureTest.java | 12 +-
.../NiFiRestConfigurationProviderSecureTest.java | 16 +-
.../NiFiRestConfigurationProviderUnsecureTest.java | 12 +-
.../cache/CacheConfigurationProviderTest.java | 8 +-
.../DelegatingConfigurationProviderTest.java | 37 +-
.../minifi-c2-provider-nifi-rest/pom.xml | 7 +-
.../rest/NiFiRestConfigurationProviderTest.java | 12 +-
.../nifi/rest/TemplatesIteratorExceptionTest.java | 5 +-
.../provider/nifi/rest/TemplatesIteratorTest.java | 15 +-
minifi/minifi-c2/minifi-c2-service/pom.xml | 22 +-
.../minifi/c2/configuration/C2ResourceConfig.java | 3 +
.../nifi/minifi/c2/service/C2JsonProvider.java | 37 +-
.../minifi/c2/service/C2JsonProviderFeature.java | 26 +-
.../nifi/minifi/c2/service/C2ProtocolContext.java | 96 +++
.../nifi/minifi/c2/service/C2ProtocolService.java | 19 +-
.../nifi/minifi/c2/service/ConfigService.java | 182 +++++-
.../minifi/c2/service/SimpleC2ProtocolService.java | 127 ++++
.../minifi/commons/schema/ConfigSchemaTest.java | 16 +-
.../commons/schema/ConnectionSchemaTest.java | 10 +-
.../commons/schema/ProcessGroupSchemaTest.java | 12 +-
.../schema/RemoteProcessGroupSchemaTest.java | 10 +-
.../schema/SecurityPropertiesSchemaTest.java | 12 +-
.../schema/serialization/SchemaLoaderTest.java | 22 +-
.../commons/schema/v1/ConfigSchemaV1Test.java | 6 +-
.../commons/schema/v1/ConnectionSchemaV1Test.java | 10 +-
.../commons/schema/v1/ProcessorSchemaV1Test.java | 10 +-
.../schema/v2/RemoteProcessGroupSchemaV2Test.java | 12 +-
.../minifi/commons/status/StatusReportTest.java | 4 +-
minifi/minifi-integration-tests/pom.xml | 4 +-
.../c2/HierarchicalC2IntegrationTest.java | 24 +-
.../standalone/test/StandaloneXmlTest.java | 12 +-
.../standalone/test/StandaloneYamlTest.java | 71 +--
.../nifi/minifi/integration/util/LogUtil.java | 2 +-
.../minifi/status/StatusConfigReporterTest.java | 81 ++-
.../toolkit/configuration/ConfigMainTest.java | 37 +-
.../configuration/dto/BaseSchemaTester.java | 7 +-
.../configuration/dto/ConnectionSchemaTest.java | 36 +-
.../dto/FlowControllerSchemaTest.java | 20 +-
.../configuration/dto/PortSchemaFunctionTest.java | 16 +-
.../configuration/dto/ProcessorSchemaTest.java | 8 +-
.../dto/RemoteInputPortSchemaTest.java | 8 +-
.../dto/RemoteProcessGroupSchemaTest.java | 19 +-
minifi/pom.xml | 34 +-
.../SupportsSensitiveDynamicProperties.java | 33 +-
.../org/apache/nifi/components/AllowableValue.java | 5 +-
.../org/apache/nifi/components/DescribedValue.java | 75 +--
.../apache/nifi/components/PropertyDescriptor.java | 16 +-
.../nifi/controller/status/ConnectionStatus.java | 12 +
.../nifi/controller/status/LoadBalanceStatus.java | 16 +-
.../nifi/controller/status/ProcessGroupStatus.java | 23 +
.../documentation/AbstractDocumentationWriter.java | 4 +
.../documentation/xml/XmlDocumentationWriter.java | 9 +
.../nifi/expression/AttributeExpression.java | 5 +-
.../apache/nifi/components/EnumAllowableValue.java | 83 +--
.../nifi/components/TestPropertyDescriptor.java | 61 +-
nifi-assembly/LICENSE | 23 +
nifi-assembly/src/main/assembly/common.xml | 2 +
nifi-bootstrap/pom.xml | 17 +-
.../email/EmailNotificationService.java | 20 +-
.../email/EmailNotificationServiceTest.java | 6 +-
.../language/antlr/AttributeExpressionLexer.g | 4 +
.../language/antlr/AttributeExpressionParser.g | 7 +-
.../language/compile/ExpressionCompiler.java | 59 ++
.../language/evaluation/InstantEvaluator.java} | 34 +-
.../language/evaluation/InstantQueryResult.java | 36 +-
.../evaluation/cast/EpochTimeEvaluator.java | 59 ++
.../evaluation/cast/InstantCastEvaluator.java | 93 +++
.../evaluation/cast/NumberCastEvaluator.java | 7 +-
.../evaluation/cast/WholeNumberCastEvaluator.java | 3 +
.../functions/InstantFormatEvaluator.java | 71 +++
.../functions/NumberToInstantEvaluator.java | 52 ++
.../functions/StringToInstantEvaluator.java | 68 +++
.../attribute/expression/language/TestQuery.java | 158 +++++
.../nifi-jetty-configuration}/pom.xml | 33 +-
.../connector/ApplicationLayerProtocol.java | 24 +-
.../connector/ServerConnectorFactory.java | 25 +-
.../connector/StandardServerConnectorFactory.java | 197 ++++++
.../alpn/ALPNServerConnectionFactory.java | 64 ++
.../connector/alpn/StandardALPNProcessor.java | 123 ++++
.../StandardServerConnectorFactoryTest.java | 172 ++++++
.../java/org/apache/nifi/util/NiFiProperties.java | 12 +
.../nifi-property-protection-factory/pom.xml | 1 -
.../scheme/StandardProtectionSchemeResolver.java | 4 +-
.../StandardProtectionSchemeResolverTest.java | 9 +
.../apache/nifi/record/path/TestRecordPath.java | 4 +-
.../serialization/record/ResultSetRecordSet.java | 1 +
nifi-commons/nifi-single-user-utils/pom.xml | 1 -
nifi-commons/nifi-socket-utils/pom.xml | 1 -
.../remote/io/socket/SocketChannelInputStream.java | 188 ------
.../io/socket/SocketChannelOutputStream.java | 124 ----
.../HashiCorpVaultCommunicationService.java | 24 +-
...StandardHashiCorpVaultCommunicationService.java | 13 +-
.../config/HashiCorpVaultConfiguration.java | 26 +
.../hashicorp/config/HashiCorpVaultProperties.java | 54 +-
.../config/lookup/BeanPropertyLookup.java | 7 +-
...andardHashiCorpVaultCommunicationServiceIT.java | 26 +-
.../hashicorp/TestHashiCorpVaultConfiguration.java | 24 +
...StandardHashiCorpVaultCommunicationService.java | 31 +-
nifi-commons/pom.xml | 1 +
nifi-dependency-check-maven/suppressions.xml | 20 -
.../src/main/asciidoc/administration-guide.adoc | 8 +
nifi-docs/src/main/asciidoc/developer-guide.adoc | 34 +-
.../main/asciidoc/expression-language-guide.adoc | 90 +++
.../images/add-property-sensitive-value-dialog.png | Bin 0 -> 15549 bytes
nifi-docs/src/main/asciidoc/user-guide.adoc | 15 +-
.../nifi-nifi-example-processors/pom.xml | 1 -
nifi-external/nifi-spark-receiver/pom.xml | 9 -
.../impl/StandardRuntimeManifestBuilder.java | 21 +
.../nifi/runtime/manifest/TestRuntimeManifest.java | 22 +
nifi-nar-bundles/nifi-accumulo-bundle/pom.xml | 8 +-
.../org/apache/nifi/jasn1/JASN1RecordReader.java | 1 -
.../jasn1/StandardRecordModelIteratorProvider.java | 59 +-
.../analyzer/AbstractDirectoryAnalyzer.java | 55 ++
.../atlas/provenance/analyzer/AwsS3Directory.java | 31 +-
.../atlas/provenance/analyzer/GCSDirectory.java | 76 +++
...fi.atlas.provenance.NiFiProvenanceEventAnalyzer | 1 +
.../provenance/analyzer/TestGCSDirectory.java | 142 +++++
.../nifi-avro-bundle/nifi-avro-processors/pom.xml | 1 -
.../nifi-aws-abstract-processors/pom.xml | 1 -
.../nifi/processors/aws/dynamodb/PutDynamoDB.java | 21 +-
.../nifi-azure-processors/pom.xml | 7 +-
.../azure/AbstractAzureBlobProcessor_v12.java | 18 +-
.../AbstractAzureDataLakeStorageProcessor.java | 52 +-
.../azure/storage/AbstractListAzureProcessor.java | 85 +++
.../azure/storage/DeleteAzureBlobStorage_v12.java | 9 +-
.../azure/storage/DeleteAzureDataLakeStorage.java | 4 +-
.../azure/storage/FetchAzureBlobStorage_v12.java | 13 +-
.../azure/storage/FetchAzureDataLakeStorage.java | 21 +-
.../azure/storage/ListAzureBlobStorage.java | 18 +-
.../azure/storage/ListAzureBlobStorage_v12.java | 12 +-
.../azure/storage/ListAzureDataLakeStorage.java | 13 +-
.../azure/storage/MoveAzureDataLakeStorage.java | 4 +-
.../azure/storage/PutAzureBlobStorage_v12.java | 17 +-
.../azure/storage/PutAzureDataLakeStorage.java | 22 +-
.../azure/storage/utils/AzureStorageUtils.java | 44 ++
.../azure/storage/AbstractAzureBlobStorageIT.java | 9 +-
.../storage/AbstractAzureBlobStorage_v12IT.java | 3 +-
.../storage/AbstractAzureDataLakeStorageIT.java | 5 +-
.../azure/storage/AbstractAzureStorageIT.java | 71 ++-
.../storage/ITDeleteAzureBlobStorage_v12.java | 11 +
.../storage/ITDeleteAzureDataLakeStorage.java | 18 +
.../azure/storage/ITFetchAzureBlobStorage_v12.java | 11 +
.../azure/storage/ITFetchAzureDataLakeStorage.java | 29 +-
.../azure/storage/ITListAzureBlobStorage.java | 68 ++-
.../azure/storage/ITListAzureBlobStorage_v12.java | 68 ++-
.../azure/storage/ITListAzureDataLakeStorage.java | 57 +-
.../azure/storage/ITMoveAzureDataLakeStorage.java | 22 +-
.../azure/storage/ITPutAzureBlobStorage.java | 19 +-
.../azure/storage/ITPutAzureBlobStorage_v12.java | 9 +
.../azure/storage/ITPutAzureDataLakeStorage.java | 19 +-
.../nifi-azure-reporting-task/pom.xml | 1 -
.../nifi-beats-processors/pom.xml | 1 -
.../nifi-cassandra-processors/pom.xml | 1 -
.../processors/cassandra/QueryCassandraTest.java | 2 +-
.../reporting/datadog/DataDogReportingTask.java | 18 +-
.../datadog/TestDataDogReportingTask.java | 95 ++-
.../src/main/resources/META-INF/LICENSE | 329 ----------
.../src/main/resources/META-INF/NOTICE | 599 ------------------
.../nifi-druid-controller-service-api/pom.xml | 100 ---
.../nifi-druid-controller-service/pom.xml | 72 ---
.../druid/DruidTranquilityController.java | 675 ---------------------
.../org.apache.nifi.controller.ControllerService | 16 -
.../druid/DruidTranquilityControllerTest.java | 98 ---
.../nifi-druid-bundle/nifi-druid-nar/pom.xml | 45 --
.../src/main/resources/META-INF/LICENSE | 209 -------
.../src/main/resources/META-INF/NOTICE | 5 -
.../nifi-druid-processors/pom.xml | 81 ---
.../nifi/processors/druid/PutDruidRecord.java | 365 -----------
.../services/org.apache.nifi.processor.Processor | 16 -
.../druid/MockDruidTranquilityController.java | 153 -----
.../nifi/processors/druid/PutDruidRecordTest.java | 113 ----
nifi-nar-bundles/nifi-druid-bundle/pom.xml | 163 -----
.../nifi-elasticsearch-client-service/pom.xml | 12 +-
.../ElasticSearchClientServiceImpl.java | 10 +-
.../ElasticSearchClientService_IT.groovy | 19 +-
.../nifi-elasticsearch-processors/pom.xml | 1 -
.../nifi-elasticsearch-restapi-processors/pom.xml | 3 +-
.../nifi-email-processors/pom.xml | 1 -
.../nifi-evtx-bundle/nifi-evtx-processors/pom.xml | 1 -
.../nifi-database-utils/pom.xml | 2 -
.../java/org/apache/nifi/util/db/JdbcCommon.java | 1 +
.../nifi-extension-utils/nifi-event-listen/pom.xml | 1 -
.../nifi/event/transport/SslSessionStatus.java} | 31 +-
.../event/transport/message/ByteArrayMessage.java | 13 +-
.../netty/codec/SocketByteArrayMessageDecoder.java | 48 +-
.../nifi-extension-utils/nifi-hadoop-utils/pom.xml | 6 -
.../nifi-avro-record-utils/pom.xml | 2 -
.../java/org/apache/nifi/avro/AvroTypeUtil.java | 2 +-
.../schema/access/InferenceSchemaStrategy.java | 2 +-
.../org/apache/nifi/avro/TestAvroTypeUtil.java | 376 ++++++------
.../apache/nifi/avro/defaultArrayInRecords1.json | 2 +-
.../org/apache/nifi/avro/defaultArrayValue1.json | 2 +-
.../resources/org/apache/nifi/avro/schema.json | 24 +-
.../nifi/web/api/dto/ControllerServiceDTO.java | 30 +
.../nifi/web/api/dto/ProcessorConfigDTO.java | 15 +
.../org/apache/nifi/web/api/dto/ProcessorDTO.java | 15 +
.../apache/nifi/web/api/dto/ReportingTaskDTO.java | 31 +
.../html/HtmlDocumentationWriter.java | 16 +
.../html/ProcessorDocumentationWriterTest.java | 2 +
.../nifi/controller/flow/AbstractFlowManager.java | 2 +
.../reporting/AbstractReportingContext.java | 11 +-
.../service/StandardControllerServiceNode.java | 4 +-
.../service/StandardControllerServiceProvider.java | 9 +-
.../StandardVersionedComponentSynchronizer.java | 139 +++--
.../apache/nifi/groups/StandardProcessGroup.java | 26 +-
.../StandardParameterReferenceManager.java | 73 +++
.../nifi/processor/StandardProcessContext.java | 5 +-
.../flow/mapping/NiFiRegistryFlowMapper.java | 53 +-
.../apache/nifi/reporting/AbstractEventAccess.java | 13 +
...StandardVersionedComponentSynchronizerTest.java | 11 +-
.../parameter/TestStandardParameterContext.java | 6 +
.../nifi/controller/AbstractComponentNode.java | 107 ++--
.../org/apache/nifi/controller/ComponentNode.java | 36 +-
.../nifi/groups/FlowSynchronizationOptions.java | 25 +
.../nifi/parameter/ParameterReferenceManager.java | 15 +
.../ParameterReferencedControllerServiceData.java | 63 ++
.../nifi/controller/TestAbstractComponentNode.java | 79 ++-
.../nifi-framework/nifi-framework-core/pom.xml | 10 +
.../controller/FlowSerializationStrategy.java} | 23 +-
.../nifi/controller/StandardFlowService.java | 14 +-
.../nifi/controller/StandardFlowSnippet.java | 6 +-
.../org/apache/nifi/controller/TemplateUtils.java | 1 +
.../nifi/controller/XmlFlowSynchronizer.java | 6 +-
.../nifi/controller/flow/StandardFlowManager.java | 3 +-
.../reporting/StandardReportingContext.java | 6 +-
.../reporting/StandardReportingTaskNode.java | 4 +-
.../repository/FileSystemRepository.java | 64 +-
.../scheduling/StandardProcessScheduler.java | 11 +-
.../serialization/AffectedComponentSet.java | 5 +-
.../serialization/FlowFromDOMFactory.java | 24 +-
.../serialization/VersionedFlowSynchronizer.java | 54 +-
.../service/ControllerServiceLoader.java | 3 +-
.../state/server/ZooKeeperStateServer.java | 6 +-
.../persistence/StandardFlowConfigurationDAO.java | 13 +-
.../spring/StandardFlowServiceFactoryBean.java | 4 +-
.../nifi/controller/StandardFlowServiceTest.java | 3 +-
.../repository/TestFileSystemRepository.java | 63 ++
.../nifi/integration/FrameworkIntegrationTest.java | 3 +-
.../nifi/integration/versioned/ImportFlowIT.java | 36 +-
.../election/ITSecureClientZooKeeperFactory.java | 2 +-
.../flow/mapping/NiFiRegistryFlowMapperTest.java | 7 +-
.../src/test/resources/conf/nifi.properties | 2 +
.../apache/nifi/headless/HeadlessNiFiServer.java | 4 +-
.../nifi-framework/nifi-resources/pom.xml | 1 +
.../resources/conf/bootstrap-hashicorp-vault.conf | 2 +
.../src/main/resources/conf/nifi.properties | 1 +
.../remote/io/socket/TestSocketChannelStreams.java | 231 -------
.../nifi-framework/nifi-web/nifi-jetty/pom.xml | 13 +
.../org/apache/nifi/web/server/JettyServer.java | 362 ++---------
.../connector/FrameworkServerConnectorFactory.java | 199 ++++++
.../filter/StandardRequestFilterProvider.java | 38 +-
.../apache/nifi/web/server/JettyServerTest.java | 181 ------
.../FrameworkServerConnectorFactoryTest.java | 195 ++++++
.../filter/RestApiRequestFilterProviderTest.java | 10 +-
.../filter/StandardRequestFilterProviderTest.java | 12 +-
.../nifi/audit/ControllerServiceAuditor.java | 13 +-
.../java/org/apache/nifi/audit/NiFiAuditor.java | 2 +
.../org/apache/nifi/audit/ProcessorAuditor.java | 19 +-
.../apache/nifi/audit/ReportingTaskAuditor.java | 13 +-
.../nifi/authorization/AuthorizableLookup.java | 3 +-
.../AuthorizeControllerServiceReference.java | 57 +-
.../nifi/authorization/ComponentAuthorizable.java | 3 +-
.../authorization/StandardAuthorizableLookup.java | 11 +-
.../org/apache/nifi/web/NiFiServiceFacade.java | 9 +-
.../apache/nifi/web/StandardNiFiServiceFacade.java | 61 +-
.../nifi/web/api/ControllerServiceResource.java | 10 +-
.../nifi/web/api/ParameterContextResource.java | 62 +-
.../org/apache/nifi/web/api/ProcessorResource.java | 10 +-
.../apache/nifi/web/api/ReportingTaskResource.java | 10 +-
.../org/apache/nifi/web/api/dto/DtoFactory.java | 20 +-
.../web/dao/impl/StandardControllerServiceDAO.java | 3 +-
.../web/dao/impl/StandardParameterContextDAO.java | 6 +-
.../nifi/web/dao/impl/StandardProcessorDAO.java | 4 +-
.../web/dao/impl/StandardReportingTaskDAO.java | 4 +-
.../nifi/web/dao/impl/StandardSnippetDAO.java | 32 +-
.../headers/ContentSecurityPolicyFilter.java | 57 --
.../headers/StrictTransportSecurityFilter.java | 58 --
.../headers/XContentTypeOptionsFilter.java | 58 --
.../web/security/headers/XFrameOptionsFilter.java | 58 --
.../web/security/headers/XSSProtectionFilter.java | 58 --
.../security/headers/HTTPHeaderFiltersTest.java | 160 -----
.../main/webapp/js/jquery/modal/jquery.modal.css | 2 +-
.../jquery/propertytable/jquery.propertytable.js | 192 ++++--
.../main/webapp/js/nf/canvas/nf-context-menu.js | 4 +-
.../webapp/js/nf/canvas/nf-controller-service.js | 9 +-
.../js/nf/canvas/nf-processor-configuration.js | 10 +-
.../main/webapp/js/nf/canvas/nf-reporting-task.js | 9 +-
nifi-nar-bundles/nifi-framework-bundle/pom.xml | 17 +-
.../nifi-gcp-bundle/nifi-gcp-processors/pom.xml | 3 -
.../pubsub/AbstractGCPubSubWithProxyProcessor.java | 85 +++
.../processors/gcp/pubsub/ConsumeGCPubSub.java | 14 +-
.../processors/gcp/pubsub/PublishGCPubSub.java | 16 +-
.../nifi-gcp-bundle/nifi-gcp-services-api/pom.xml | 12 -
nifi-nar-bundles/nifi-gcp-bundle/pom.xml | 12 +-
.../nifi-geohash-processors/pom.xml | 2 -
.../nifi-graph-processors/pom.xml | 1 -
.../nifi-graph-test-clients/pom.xml | 6 -
.../nifi-groovyx-processors/pom.xml | 1 -
.../nifi-grpc-bundle/nifi-grpc-processors/pom.xml | 1 -
.../nifi-hdfs-processors/pom.xml | 1 -
.../processors/hadoop/inotify/GetHDFSEvents.java | 2 +-
.../nifi-hadoop-libraries-nar/pom.xml | 3 -
.../nifi-hadoop-libraries-bundle/pom.xml | 6 -
nifi-nar-bundles/nifi-hbase-bundle/pom.xml | 6 -
.../nifi-hive-bundle/nifi-hive-processors/pom.xml | 8 +
.../apache/hadoop/hive/ql/io/orc/NiFiOrcUtils.java | 8 +-
.../nifi/processors/hive/PutHiveStreaming.java | 2 +
.../org/apache/nifi/util/orc/TestNiFiOrcUtils.java | 3 +-
.../nifi-hive-bundle/nifi-hive3-processors/pom.xml | 77 +--
nifi-nar-bundles/nifi-hive-bundle/pom.xml | 5 +-
.../nifi-ignite-processors/pom.xml | 1 -
.../nifi-influxdb-processors/pom.xml | 1 -
nifi-nar-bundles/nifi-jetty-bundle/pom.xml | 10 +
.../nifi-jms-bundle/nifi-jms-processors/pom.xml | 1 -
.../nifi-kafka-1-0-processors/pom.xml | 1 -
.../nifi-kafka-2-0-processors/pom.xml | 1 -
.../nifi-kafka-2-6-processors/pom.xml | 1 -
.../nifi/controller/kudu/KuduLookupService.java | 12 +
nifi-nar-bundles/nifi-kudu-bundle/pom.xml | 2 +-
.../org/apache/nifi/web/ImageViewerController.java | 3 +-
.../src/main/webapp/META-INF/nifi-content-viewer | 3 +-
.../nifi-mongodb-processors/pom.xml | 1 -
nifi-nar-bundles/nifi-parquet-bundle/pom.xml | 6 -
.../nifi-ranger-bundle/nifi-ranger-plugin/pom.xml | 2 +-
nifi-nar-bundles/nifi-ranger-bundle/pom.xml | 10 -
.../nifi-registry-service/pom.xml | 1 -
.../nifi-rethinkdb-processors/pom.xml | 2 -
.../salesforce/QuerySalesforceObject.java | 17 +-
.../additionalDetails.html | 72 +++
.../nifi-scripting-processors/pom.xml | 33 +-
.../nifi/processors/script/ExecuteScript.java | 6 +-
.../processors/script/InvokeScriptedProcessor.java | 14 +-
.../reporting/script/ScriptedReportingTask.java | 2 +
.../apache/nifi/script/ScriptRunnerFactory.java | 2 +-
.../processors/script/TestInvokeJavascript.java | 64 +-
.../src/test/resources/javascript/test_reader.js | 4 +-
.../reporting/AbstractSiteToSiteReportingTask.java | 32 +-
.../org/apache/nifi/processors/smb/PutSmbFile.java | 2 +-
.../nifi/snmp/operations/SendTrapSNMPHandler.java | 10 +-
.../snmp/operations/SendTrapSNMPHandlerTest.java | 41 +-
.../src/main/resources/META-INF/NOTICE | 9 +
.../nifi-twitter-processors/pom.xml | 20 +
.../nifi/processors/twitter/ConsumeTwitter.java | 355 +++++++++++
.../apache/nifi/processors/twitter/GetTwitter.java | 3 +
.../nifi/processors/twitter/StreamEndpoint.java} | 31 +-
.../processors/twitter/TweetStreamService.java | 235 +++++++
.../services/org.apache.nifi.processor.Processor | 3 +-
.../processors/twitter/TestConsumeTwitter.java | 85 +++
.../nifi/processors/twitter/TestGetTwitter.java | 198 +++++-
.../nifi-solr-bundle/nifi-solr-processors/pom.xml | 1 -
nifi-nar-bundles/nifi-solr-bundle/pom.xml | 10 -
.../nifi-livy-controller-service/pom.xml | 1 -
.../nifi-spark-bundle/nifi-livy-processors/pom.xml | 1 -
nifi-nar-bundles/nifi-spark-bundle/pom.xml | 4 -
.../nifi-splunk-processors/pom.xml | 1 -
.../nifi-spring-processors/pom.xml | 1 -
.../nifi-standard-content-viewer/pom.xml | 5 +
.../nifi/web/StandardContentViewerController.java | 36 +-
.../src/main/resources/META-INF/NOTICE | 6 +-
.../src/main/webapp/META-INF/nifi-content-viewer | 9 +-
.../nifi-standard-processors/pom.xml | 13 +
.../nifi/processors/standard/ConvertJSONToSQL.java | 18 +-
.../processors/standard/ExecuteStreamCommand.java | 92 ++-
.../processors/standard/HandleHttpRequest.java | 99 +--
.../processors/standard/HandleHttpResponse.java | 1 -
.../nifi/processors/standard/InvokeHTTP.java | 2 +
.../nifi/processors/standard/ListenHTTP.java | 86 ++-
.../apache/nifi/processors/standard/ListenTCP.java | 26 +-
.../standard/http/HttpProtocolStrategy.java | 68 +++
.../nifi/processors/standard/util/FTPTransfer.java | 26 +-
.../processors/standard/TestConvertJSONToSQL.java | 8 +-
.../processors/standard/TestConvertRecord.java | 4 +-
.../apache/nifi/processors/standard/TestFTP.java | 58 +-
.../nifi/processors/standard/TestListSFTP.java | 46 +-
.../nifi/processors/standard/TestListenHTTP.java | 10 +-
.../nifi/processors/standard/TestListenTCP.java | 19 +-
nifi-nar-bundles/nifi-standard-bundle/pom.xml | 10 -
.../org/apache/nifi/dbcp/DBCPConnectionPool.java | 2 +
.../apache/nifi/dbcp/HikariCPConnectionPool.java | 2 +
.../cache/operations/CacheOperation.java} | 25 +-
.../distributed/cache/operations/MapOperation.java | 3 +-
.../distributed/cache/operations/SetOperation.java | 3 +-
...tOperation.java => StandardCacheOperation.java} | 10 +-
.../nifi-distributed-cache-server/pom.xml | 5 +
.../cache/server/AbstractCacheServer.java | 247 --------
.../cache/server/DistributedSetCacheServer.java | 10 +-
.../distributed/cache/server/EventCacheServer.java | 113 ++++
.../distributed/cache/server/SetCacheServer.java | 102 ----
.../server/codec/CacheOperationResultEncoder.java} | 32 +-
.../cache/server/codec/CacheRequestDecoder.java | 243 ++++++++
.../server/codec/CacheVersionRequestHandler.java | 81 +++
.../server/codec/CacheVersionResponseEncoder.java | 41 ++
.../cache/server/codec/MapCacheRequestDecoder.java | 150 +++++
.../cache/server/codec/MapCacheRequestHandler.java | 178 ++++++
.../server/codec/MapRemoveResponseEncoder.java} | 29 +-
.../server/codec/MapSizeResponseEncoder.java} | 29 +-
.../server/codec/MapValueResponseEncoder.java | 43 ++
.../cache/server/codec/SetCacheRequestHandler.java | 80 +++
.../server/map/DistributedMapCacheServer.java | 23 +-
.../cache/server/map/MapCacheServer.java | 252 --------
.../cache/server/map/StandardMapCacheServer.java | 124 ++++
.../server/protocol/CacheOperationResult.java} | 23 +-
.../cache/server/protocol/CacheRequest.java} | 31 +-
.../server/protocol/CacheVersionRequest.java} | 26 +-
.../server/protocol/CacheVersionResponse.java} | 29 +-
.../cache/server/protocol/MapCacheRequest.java | 113 ++++
.../cache/server/protocol/MapRemoveResponse.java} | 26 +-
.../cache/server/protocol/MapSizeResponse.java} | 26 +-
.../cache/server/protocol/MapValueResponse.java} | 44 +-
.../cache/server/set/StandardSetCacheServer.java | 107 ++++
.../cache/server/map/DistributedMapCacheTest.java | 33 +-
.../server/map/DistributedMapCacheTlsTest.java | 28 +-
.../server/map/StandardMapCacheServerTest.java | 175 ++++++
.../map/TestDistributedMapServerAndClient.java | 10 +-
.../cache/server/set/DistributedSetCacheTest.java | 25 +-
.../nifi-distributed-cache-services-bundle/pom.xml | 9 -
.../nifi-hadoop-dbcp-service-bundle/pom.xml | 6 -
.../nifi-hbase_1_1_2-client-service-bundle/pom.xml | 7 -
.../nifi-hbase_2-client-service-bundle/pom.xml | 7 -
.../nifi-hwx-schema-registry-service/pom.xml | 1 -
.../oauth2/StandardOauth2AccessTokenProvider.java | 36 +-
.../StandardOauth2AccessTokenProviderTest.java | 15 +-
.../org/apache/nifi/proxy/ProxyConfiguration.java | 15 +-
.../java/org/apache/nifi/proxy/SocksVersion.java} | 18 +-
.../proxy/StandardProxyConfigurationService.java | 26 +-
.../nifi-record-serialization-services/pom.xml | 17 +-
.../main/java/org/apache/nifi/xml/XMLReader.java | 21 +-
.../java/org/apache/nifi/xml/XMLRecordReader.java | 120 ++--
.../apache/nifi/xml/inference/XmlRecordSource.java | 20 +-
.../additionalDetails.html | 196 ++++--
.../org/apache/nifi/xml/TestInferXmlSchema.java | 25 +-
.../java/org/apache/nifi/xml/TestXMLReader.java | 21 +-
.../org/apache/nifi/xml/TestXMLRecordReader.java | 247 ++++++--
.../nifi-windows-event-log-processors/pom.xml | 1 -
nifi-nar-bundles/pom.xml | 1 -
.../src/main/assembly/dependencies.xml | 2 +
.../nifi/registry/flow/diff/DifferenceType.java | 5 +
.../registry/flow/diff/StandardFlowComparator.java | 32 +-
.../registry/flow/diff/StandardFlowDifference.java | 18 +-
.../flow/diff/StaticDifferenceDescriptor.java | 34 +-
.../provider/flow/git/GitFlowMetaData.java | 5 +-
.../nifi/registry/service/RegistryService.java | 2 +-
.../flow/git/TestGitFlowPersistenceProvider.java | 29 +
.../resources/conf/bootstrap-hashicorp-vault.conf | 2 +
.../nifi-registry-core/nifi-registry-test/pom.xml | 6 +-
.../nifi/registry/db/MariaDBDataSourceFactory.java | 4 +-
.../src/main/package-lock.json | 128 +---
nifi-registry/nifi-registry-core/pom.xml | 5 -
.../nifi-registry-ranger-plugin/pom.xml | 3 +-
.../nifi-registry-ranger/pom.xml | 10 -
nifi-registry/pom.xml | 2 +-
.../src/main/assembly/common.xml | 2 +
nifi-stateless/nifi-stateless-bootstrap/pom.xml | 14 +
.../stateless/bootstrap/StatelessBootstrap.java | 34 +-
.../bootstrap/TestStatelessBootstrap.java | 45 ++
.../org/apache/nifi/stateless/FakeBootstrap.class | 13 +
.../reporting/StatelessReportingContext.java | 6 +-
.../reporting/StatelessReportingTaskNode.java | 2 +-
.../system/SensitiveDynamicPropertiesService.java | 30 +-
.../SensitiveDynamicPropertiesProcessor.java | 74 +++
.../SensitiveDynamicPropertiesReportingTask.java | 27 +-
.../org.apache.nifi.controller.ControllerService | 1 +
.../services/org.apache.nifi.processor.Processor | 1 +
.../org.apache.nifi.reporting.ReportingTask | 1 +
.../src/test/assembly/dependencies.xml | 2 +
.../apache/nifi/tests/system/NiFiClientUtil.java | 60 +-
.../org/apache/nifi/tests/system/NiFiSystemIT.java | 8 +
.../tests/system/TroubleshootingTestWatcher.java | 11 +-
.../system/clustering/FlowSynchronizationIT.java | 34 ++
.../clustering/JoinClusterWithDifferentFlow.java | 30 +-
.../ControllerServiceApiValidationIT.java | 1 +
.../ControllerServiceDynamicPropertiesIT.java | 100 +++
.../tests/system/loadbalance/LoadBalanceIT.java | 54 +-
.../processor/ProcessorDynamicPropertiesIT.java | 102 ++++
.../system/reportingtask/ReportingTaskIT.java | 71 +++
.../tests/system/rpg/RemoteProcessGroupIT.java | 1 +
.../resources/conf/clustered/node1/nifi.properties | 2 +-
.../resources/conf/clustered/node2/nifi.properties | 2 +-
.../test/resources/conf/default/nifi.properties | 2 +-
.../resources/flows/mismatched-flows/flow1.xml.gz | Bin 3553 -> 3554 bytes
.../resources/flows/mismatched-flows/flow2.xml.gz | Bin 3530 -> 3530 bytes
nifi-toolkit/nifi-toolkit-api/pom.xml | 1 -
.../src/main/assembly/dependencies.xml | 2 +
nifi-toolkit/nifi-toolkit-cli/pom.xml | 1 -
.../impl/client/nifi/ControllerServicesClient.java | 2 +
.../cli/impl/client/nifi/ProcessorClient.java | 3 +
.../cli/impl/client/nifi/ReportingTasksClient.java | 2 +
.../nifi/impl/JerseyControllerServicesClient.java | 18 +
.../client/nifi/impl/JerseyProcessorClient.java | 18 +
.../nifi/impl/JerseyReportingTasksClient.java | 17 +
nifi-toolkit/nifi-toolkit-s2s/pom.xml | 1 -
nifi-toolkit/nifi-toolkit-tls/pom.xml | 1 -
.../nifi-toolkit-zookeeper-migrator/pom.xml | 2 -
pom.xml | 59 +-
524 files changed, 11040 insertions(+), 8367 deletions(-)
create mode 100644
c2/c2-protocol/c2-protocol-component-api/src/main/java/org/apache/nifi/c2/protocol/component/api/Restriction.java
copy
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
minifi/minifi-c2/minifi-c2-service/src/main/java/org/apache/nifi/minifi/c2/service/C2JsonProvider.java
(54%)
copy
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/SetOperation.java
=>
minifi/minifi-c2/minifi-c2-service/src/main/java/org/apache/nifi/minifi/c2/service/C2JsonProviderFeature.java
(64%)
create mode 100644
minifi/minifi-c2/minifi-c2-service/src/main/java/org/apache/nifi/minifi/c2/service/C2ProtocolContext.java
copy
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
minifi/minifi-c2/minifi-c2-service/src/main/java/org/apache/nifi/minifi/c2/service/C2ProtocolService.java
(65%)
create mode 100644
minifi/minifi-c2/minifi-c2-service/src/main/java/org/apache/nifi/minifi/c2/service/SimpleC2ProtocolService.java
copy
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-api/src/main/java/org/apache/nifi/annotation/behavior/SupportsSensitiveDynamicProperties.java
(58%)
copy
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/SetOperation.java
=> nifi-api/src/main/java/org/apache/nifi/components/DescribedValue.java (63%)
copy
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-api/src/main/java/org/apache/nifi/controller/status/LoadBalanceStatus.java
(70%)
copy
minifi/minifi-c2/minifi-c2-service/src/main/java/org/apache/nifi/minifi/c2/configuration/C2ResourceConfig.java
=> nifi-api/src/test/java/org/apache/nifi/components/EnumAllowableValue.java
(54%)
rename
nifi-commons/{nifi-security-socket-ssl/src/main/java/org/apache/nifi/remote/io/socket/ssl/SSLSocketChannelOutputStream.java
=>
nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/InstantEvaluator.java}
(53%)
copy
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/InstantQueryResult.java
(56%)
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/cast/EpochTimeEvaluator.java
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/cast/InstantCastEvaluator.java
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/InstantFormatEvaluator.java
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/NumberToInstantEvaluator.java
create mode 100644
nifi-commons/nifi-expression-language/src/main/java/org/apache/nifi/attribute/expression/language/evaluation/functions/StringToInstantEvaluator.java
rename
{nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api-nar =>
nifi-commons/nifi-jetty-configuration}/pom.xml (61%)
copy
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-commons/nifi-jetty-configuration/src/main/java/org/apache/nifi/jetty/configuration/connector/ApplicationLayerProtocol.java
(67%)
copy
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-commons/nifi-jetty-configuration/src/main/java/org/apache/nifi/jetty/configuration/connector/ServerConnectorFactory.java
(70%)
create mode 100644
nifi-commons/nifi-jetty-configuration/src/main/java/org/apache/nifi/jetty/configuration/connector/StandardServerConnectorFactory.java
create mode 100644
nifi-commons/nifi-jetty-configuration/src/main/java/org/apache/nifi/jetty/configuration/connector/alpn/ALPNServerConnectionFactory.java
create mode 100644
nifi-commons/nifi-jetty-configuration/src/main/java/org/apache/nifi/jetty/configuration/connector/alpn/StandardALPNProcessor.java
create mode 100644
nifi-commons/nifi-jetty-configuration/src/test/java/org/apache/nifi/jetty/configuration/connector/StandardServerConnectorFactoryTest.java
delete mode 100644
nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/socket/SocketChannelInputStream.java
delete mode 100644
nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/socket/SocketChannelOutputStream.java
create mode 100644
nifi-docs/src/main/asciidoc/images/add-property-sensitive-value-dialog.png
create mode 100644
nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/provenance/analyzer/AbstractDirectoryAnalyzer.java
create mode 100644
nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/main/java/org/apache/nifi/atlas/provenance/analyzer/GCSDirectory.java
create mode 100644
nifi-nar-bundles/nifi-atlas-bundle/nifi-atlas-reporting-task/src/test/java/org/apache/nifi/atlas/provenance/analyzer/TestGCSDirectory.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/AbstractListAzureProcessor.java
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api-nar/src/main/resources/META-INF/LICENSE
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api-nar/src/main/resources/META-INF/NOTICE
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service-api/pom.xml
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service/pom.xml
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service/src/main/java/org/apache/nifi/controller/druid/DruidTranquilityController.java
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-controller-service/src/test/java/org/apache/nifi/controller/druid/DruidTranquilityControllerTest.java
delete mode 100644 nifi-nar-bundles/nifi-druid-bundle/nifi-druid-nar/pom.xml
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-nar/src/main/resources/META-INF/LICENSE
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-nar/src/main/resources/META-INF/NOTICE
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-processors/pom.xml
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-processors/src/main/java/org/apache/nifi/processors/druid/PutDruidRecord.java
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-processors/src/test/java/org/apache/nifi/controller/druid/MockDruidTranquilityController.java
delete mode 100644
nifi-nar-bundles/nifi-druid-bundle/nifi-druid-processors/src/test/java/org/apache/nifi/processors/druid/PutDruidRecordTest.java
delete mode 100644 nifi-nar-bundles/nifi-druid-bundle/pom.xml
copy
nifi-nar-bundles/{nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/SetOperation.java
=>
nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/SslSessionStatus.java}
(59%)
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/parameter/ParameterReferencedControllerServiceData.java
copy
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowSerializationStrategy.java}
(69%)
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/test/java/org/apache/nifi/remote/io/socket/TestSocketChannelStreams.java
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/main/java/org/apache/nifi/web/server/connector/FrameworkServerConnectorFactory.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/test/java/org/apache/nifi/web/server/JettyServerTest.java
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-jetty/src/test/java/org/apache/nifi/web/server/connector/FrameworkServerConnectorFactoryTest.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/headers/ContentSecurityPolicyFilter.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/headers/StrictTransportSecurityFilter.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/headers/XContentTypeOptionsFilter.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/headers/XFrameOptionsFilter.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/headers/XSSProtectionFilter.java
delete mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/test/java/org/apache/nifi/web/security/headers/HTTPHeaderFiltersTest.java
create mode 100644
nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/AbstractGCPubSubWithProxyProcessor.java
create mode 100644
nifi-nar-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/resources/docs/org.apache.nifi.processors.salesforce.QuerySalesforceObject/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/ConsumeTwitter.java
copy
nifi-nar-bundles/{nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/StreamEndpoint.java}
(60%)
create mode 100644
nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
create mode 100644
nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/test/java/org/apache/nifi/processors/twitter/TestConsumeTwitter.java
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/http/HttpProtocolStrategy.java
copy
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/CacheOperation.java}
(70%)
copy
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/{SetOperation.java
=> StandardCacheOperation.java} (82%)
delete mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/AbstractCacheServer.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/EventCacheServer.java
delete mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/SetCacheServer.java
copy
nifi-nar-bundles/{nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/CacheOperationResultEncoder.java}
(52%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/CacheRequestDecoder.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/CacheVersionRequestHandler.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/CacheVersionResponseEncoder.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/MapCacheRequestDecoder.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/MapCacheRequestHandler.java
copy
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/{nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/SetOperation.java
=>
nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/MapRemoveResponseEncoder.java}
(54%)
copy
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/{nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/operations/SetOperation.java
=>
nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/MapSizeResponseEncoder.java}
(55%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/MapValueResponseEncoder.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/codec/SetCacheRequestHandler.java
delete mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/map/MapCacheServer.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/map/StandardMapCacheServer.java
copy
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/CacheOperationResult.java}
(70%)
copy
nifi-nar-bundles/{nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/CacheRequest.java}
(54%)
copy
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/CacheVersionRequest.java}
(67%)
copy
nifi-nar-bundles/{nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/CacheVersionResponse.java}
(61%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/MapCacheRequest.java
copy
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/MapRemoveResponse.java}
(70%)
copy
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/MapSizeResponse.java}
(70%)
copy
nifi-nar-bundles/{nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/protocol/MapValueResponse.java}
(53%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/main/java/org/apache/nifi/distributed/cache/server/set/StandardSetCacheServer.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-server/src/test/java/org/apache/nifi/distributed/cache/server/map/StandardMapCacheServerTest.java
rename
nifi-nar-bundles/{nifi-druid-bundle/nifi-druid-controller-service-api/src/main/java/org/apache/nifi/controller/api/druid/DruidTranquilityService.java
=>
nifi-standard-services/nifi-proxy-configuration-api/src/main/java/org/apache/nifi/proxy/SocksVersion.java}
(70%)
create mode 100644
nifi-stateless/nifi-stateless-bootstrap/src/test/java/org/apache/nifi/stateless/bootstrap/TestStatelessBootstrap.java
create mode 100644
nifi-stateless/nifi-stateless-bootstrap/src/test/resources/test-lib/org/apache/nifi/stateless/FakeBootstrap.class
copy
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/cs/tests/system/SensitiveDynamicPropertiesService.java
(56%)
create mode 100644
nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/processors/tests/system/SensitiveDynamicPropertiesProcessor.java
copy
nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/message/ByteArrayMessage.java
=>
nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/reporting/SensitiveDynamicPropertiesReportingTask.java
(56%)
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/controllerservice/ControllerServiceDynamicPropertiesIT.java
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/processor/ProcessorDynamicPropertiesIT.java
