This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a change to branch NIFI-16315
in repository https://gitbox.apache.org/repos/asf/nifi.git
omit c87753603ad NIFI-16315 Apply IPv4 vs IPv6 UDP payload limits in PutUDP
omit 7671cc01c57 NIFI-16315 Reject oversized PutUDP FlowFiles before
copying content
add 68a6149ca06 NIFI-16311 Initialize ParseSyslog parser in @OnScheduled
(#11639)
add e18682cad42 NIFI-16314 Trim trailing spaces in fragment attribute docs
(#11641)
add 25c8f625d6f NIFI-16313 Align SegmentContent docs with filename
attributes (#11640)
add 7d29d839c9d NIFI-16316 Guard against null component names in (#11644)
add be626038b3e NIFI-16069 Improved PutIcebergRecord support for complex
types and Timestamps (#11391)
add c7fa678a12c NIFI-16324 Include property defaults during Connector
Verify Configuration (#11651)
add 7a5b4dd3105 NIFI-16321 Added Attribute Handling for Counters and
Gauges (#11648)
add d9fcfac1112 NIFI-16323 Deprecated PutUDP Processor for Removal (#11649)
add b6a04999e8a NIFI-16319 Fixed reloading of symlinked Security Stores
(#11653)
add 3766b74a50d NIFI-16320 Prevent connector GET from racing
working-context recreation. (#11647)
add 360783e60ed NIFI-16303 Integrated Property Encryption Provider to
Framework (#11659)
add 3f4162f2aec NIFI-15718 Validate ZIP CRC-32 checksums in UnpackContent
(#11636)
add 2f8d65a4342 NIFI-16328 Bump GCP to 26.88.0, Kotlin to 2.4.20, jGit to
7.8.0, and others (#11661)
add af5138f47fc NIFI-16329 Added Coordinate Validation for Registry NAR
Bundles (#11662)
add 47167e16d16 NIFI-16322 Stream GenerateFlowFile content instead of a
full-size byte array (#11650)
add e13a3be763f NIFI-16315 Reject oversized PutUDP FlowFiles before
copying content
add d12c7375709 NIFI-16315 Apply IPv4 vs IPv6 UDP payload limits in PutUDP
add fd59f5df4af NIFI-16315 Remove additional PutUDP payload tests
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 (c87753603ad)
\
N -- N -- N refs/heads/NIFI-16315 (fd59f5df4af)
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:
minifi/minifi-assembly/pom.xml | 6 +
.../minifi-commons-framework/pom.xml | 5 -
.../service/StandardFlowPropertyEncryptor.java | 11 +-
.../service/StandardFlowPropertyEncryptorTest.java | 10 +-
.../nifi-connector-mock-server/pom.xml | 5 -
...or.java => MockPropertyEncryptionProvider.java} | 17 +-
.../server/StandardConnectorMockServer.java | 5 +-
.../src/main/asciidoc/administration-guide.adoc | 47 +-
.../org/apache/nifi/processors/avro/SplitAvro.java | 2 +-
.../processors/email/ExtractEmailAttachments.java | 4 +-
nifi-extension-bundles/nifi-gcp-bundle/pom.xml | 2 +-
nifi-extension-bundles/nifi-graph-bundle/pom.xml | 2 +-
.../groovyx/flow/ProcessSessionWrap.java | 10 +
.../iceberg/parquet/ParquetIcebergWriterTest.java | 57 +++
.../processors/iceberg/record/DelegatedRecord.java | 2 +-
.../processors/iceberg/record/RecordConverter.java | 146 +++++-
.../iceberg/record/RecordConverterTest.java | 301 ++++++++++++
.../reporting/SiteToSiteStatusReportingTask.java | 2 +-
.../TestSiteToSiteStatusReportingTask.java | 21 +
.../nifi/processors/standard/GenerateFlowFile.java | 131 ++++--
.../nifi/processors/standard/ParseSyslog.java | 15 +-
.../nifi/processors/standard/PartitionRecord.java | 2 +-
.../apache/nifi/processors/standard/PutUDP.java | 2 +
.../nifi/processors/standard/SegmentContent.java | 4 +-
.../nifi/processors/standard/SplitContent.java | 2 +-
.../apache/nifi/processors/standard/SplitJson.java | 2 +-
.../nifi/processors/standard/SplitRecord.java | 2 +-
.../apache/nifi/processors/standard/SplitText.java | 2 +-
.../apache/nifi/processors/standard/SplitXml.java | 2 +-
.../nifi/processors/standard/UnpackContent.java | 168 +++++--
.../processors/standard/TestGenerateFlowFile.java | 73 ++-
.../nifi/processors/standard/TestParseSyslog.java | 21 +
.../standard/TestPutUDPPayloadLimit.java | 169 -------
.../processors/standard/TestSegmentContent.java | 44 +-
.../processors/standard/TestUnpackContent.java | 311 +++++++++++-
.../nifi/controller/metrics/CounterRecord.java | 30 ++
.../nifi/controller/metrics/GaugeRecord.java | 30 ++
.../nifi-framework-components/pom.xml | 5 -
.../controller/flowanalysis/FlowAnalysisUtil.java | 26 +-
.../repository/AbstractRepositoryContext.java | 5 +-
.../controller/repository/RepositoryContext.java | 3 +-
.../repository/StandardProcessSession.java | 90 +++-
.../WeakHashMapProcessSessionFactory.java | 10 +
.../StandardVersionedComponentSynchronizer.java | 106 +++--
.../apache/nifi/groups/StandardProcessGroup.java | 43 +-
.../FilterSensitiveParameterValueMapper.java | 3 +-
.../nifi/parameter/ParameterValueMapper.java | 3 +-
.../parameter/StandardParameterValueMapper.java | 43 +-
.../flow/mapping/VersionedComponentFlowMapper.java | 48 +-
.../apache/nifi/reporting/AbstractEventAccess.java | 4 +
.../PropertyEncryptionProviderFactory.java | 135 ++++++
.../ProviderSensitiveValueDecryptor.java | 50 ++
.../repository/StandardProcessSessionTest.java | 66 ++-
...StandardVersionedComponentSynchronizerTest.java | 52 +-
.../nifi/groups/StandardProcessGroupTest.java | 8 +-
.../TestStandardParameterValueMapper.java | 62 ++-
.../mapping/TestVersionedComponentFlowMapper.java | 111 ++++-
.../nifi/groups/FlowSynchronizationOptions.java | 60 ++-
.../org/apache/nifi/groups/PropertyDecryptor.java | 24 -
.../registry/flow/mapping/FlowMappingOptions.java | 38 +-
.../flow/mapping/SensitiveValueEncryptor.java | 22 -
...ernalPassThroughPropertyEncryptionProvider.java | 19 +-
.../encryption/PropertyEncryptionEncoder.java | 73 +++
.../encryption/SensitivePropertyCodec.java | 76 +++
.../SensitivePropertyContextFactory.java | 95 ++++
...lPassThroughPropertyEncryptionProviderTest.java | 57 +++
.../encryption/PropertyEncryptionEncoderTest.java | 82 ++++
.../encryption/SensitivePropertyCodecTest.java | 114 +++++
.../SensitivePropertyContextFactoryTest.java | 117 +++++
.../nifi-framework/nifi-framework-core/pom.xml | 5 -
.../connector/StandardConnectorNode.java | 524 +++++++++++++++------
.../org/apache/nifi/controller/FlowController.java | 22 +-
.../flow/FlowControllerFlowContextFactory.java | 3 +-
.../FlowControllerProcessGroupFacadeFactory.java | 3 +-
.../nifi/controller/flow/StandardFlowManager.java | 47 +-
.../flow/StandardStatelessGroupNodeFactory.java | 6 +-
.../repository/BatchingSessionFactory.java | 10 +
.../controller/serialization/FlowSerializer.java | 3 -
.../serialization/FlowSynchronizationUtils.java | 53 ++-
.../StandardVersionedReportingTaskImporter.java | 10 +-
.../serialization/VersionedDataflowMapper.java | 7 +-
.../serialization/VersionedFlowSerializer.java | 4 +-
.../serialization/VersionedFlowSynchronizer.java | 60 +--
.../nifi/encrypt/PropertyEncryptorFactory.java | 46 --
.../configuration/FlowControllerConfiguration.java | 105 +----
.../configuration/SslContextConfiguration.java | 123 +----
.../ssl/SecurityStoreChangedPathListener.java | 89 ----
.../framework/ssl/SecurityStoreMonitorCommand.java | 133 ++++++
.../framework/ssl/WatchServiceMonitorCommand.java | 107 -----
.../connector/TestStandardConnectorNode.java | 288 ++++++++---
.../repository/BatchingSessionFactoryTest.java | 40 +-
.../VersionedFlowSynchronizerTest.java | 15 +-
.../ssl/SecurityStoreMonitorCommandTest.java | 159 +++++++
.../ssl/WatchServiceMonitorCommandTest.java | 80 ----
.../nifi/reporting/AbstractEventAccessTest.java | 53 +++
.../nifi-framework/nifi-headless-server/pom.xml | 5 -
.../apache/nifi/headless/HeadlessNiFiServer.java | 11 +-
.../apache/nifi/web/StandardNiFiServiceFacade.java | 4 +-
.../nifi-web/nifi-web-security/pom.xml | 5 -
.../configuration/OidcSecurityConfiguration.java | 10 +-
.../StandardAuthorizedClientConverter.java | 17 +-
.../StandardAuthorizedClientConverterTest.java | 16 +-
.../org/apache/nifi/util/GaugeMeasurement.java | 9 +-
.../main/java/org/apache/nifi/util/MetricKey.java | 14 +-
.../org/apache/nifi/util/MockProcessSession.java | 60 +--
.../org/apache/nifi/util/SharedSessionState.java | 90 +++-
.../nifi/util/StandardProcessorTestRunner.java | 10 +
.../main/java/org/apache/nifi/util/TestRunner.java | 18 +
.../nifi/util/TestStandardProcessorTestRunner.java | 67 ++-
.../bundle/extract/nar/NarBundleExtractor.java | 34 +-
.../registry/bundle/model/BundleIdentifier.java | 8 +-
.../nifi/registry/bundle/util/BundleUtils.java | 12 +
.../bundle/extract/nar/TestNarBundleExtractor.java | 28 +-
.../bundle/model/TestBundleIdentifier.java | 30 +-
.../nifi/registry/bundle/util/TestBundleUtils.java | 43 ++
...escriptor.java => SensitiveValueDecryptor.java} | 26 +-
.../registry/flow/diff/StandardFlowComparator.java | 83 +++-
.../flow/diff/TestStandardFlowComparator.java | 57 ++-
.../FileSystemBundlePersistenceProvider.java | 25 +-
.../extension/StandardBundleCoordinate.java | 4 +
.../extension/StandardBundleVersionCoordinate.java | 5 +
.../flow/FileSystemFlowPersistenceProvider.java | 24 +-
.../flow/git/GitFlowPersistenceProvider.java | 21 +-
.../nifi/registry/service/RegistryService.java | 24 +-
.../extension/StandardExtensionService.java | 35 +-
.../TestFileSystemBundlePersistenceProvider.java | 57 ++-
.../extension/TestStandardBundleCoordinate.java | 57 +++
.../TestStandardBundleVersionCoordinate.java | 67 +++
.../TestFileSystemFlowPersistenceProvider.java | 12 +
.../flow/git/TestGitFlowPersistenceProvider.java | 29 ++
.../nifi/registry/service/TestRegistryService.java | 27 ++
.../org/apache/nifi/registry/util/FileUtils.java | 27 ++
.../apache/nifi/registry/util/TestFileUtils.java | 30 ++
.../registry/aws/S3BundlePersistenceProvider.java | 7 +-
nifi-registry/pom.xml | 2 +-
.../nifi-stateless-engine/pom.xml | 5 -
.../stateless/engine/StandardStatelessEngine.java | 13 -
.../nifi/stateless/engine/StatelessEngine.java | 2 -
.../stateless/engine/StatelessFlowManager.java | 4 +-
.../flow/StandardStatelessDataflowFactory.java | 29 --
.../metrics/SystemTestComponentMetricReporter.java | 6 +-
.../nifi/processors/tests/system/UpdateMetric.java | 7 +-
.../encryption/PropertyEncryptionProviderIT.java | 158 +++++++
.../system/metrics/ComponentMetricReporterIT.java | 9 +-
nifi-toolkit/nifi-toolkit-cli/pom.xml | 2 +-
pom.xml | 6 +-
146 files changed, 4912 insertions(+), 1749 deletions(-)
copy
nifi-connector-mock-bundle/nifi-connector-mock-server/src/main/java/org/apache/nifi/mock/connector/server/{NopPropertyEncryptor.java
=> MockPropertyEncryptionProvider.java} (56%)
create mode 100644
nifi-extension-bundles/nifi-iceberg-bundle/nifi-iceberg-processors/src/test/java/org/apache/nifi/processors/iceberg/record/RecordConverterTest.java
delete mode 100644
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutUDPPayloadLimit.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/security/encryption/PropertyEncryptionProviderFactory.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/security/encryption/ProviderSensitiveValueDecryptor.java
delete mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/groups/PropertyDecryptor.java
delete mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/registry/flow/mapping/SensitiveValueEncryptor.java
rename
nifi-connector-mock-bundle/nifi-connector-mock-server/src/main/java/org/apache/nifi/mock/connector/server/NopPropertyEncryptor.java
=>
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/security/encryption/InternalPassThroughPropertyEncryptionProvider.java
(50%)
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/security/encryption/PropertyEncryptionEncoder.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/security/encryption/SensitivePropertyCodec.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/security/encryption/SensitivePropertyContextFactory.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/test/java/org/apache/nifi/security/encryption/InternalPassThroughPropertyEncryptionProviderTest.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/test/java/org/apache/nifi/security/encryption/PropertyEncryptionEncoderTest.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/test/java/org/apache/nifi/security/encryption/SensitivePropertyCodecTest.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/test/java/org/apache/nifi/security/encryption/SensitivePropertyContextFactoryTest.java
delete mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/encrypt/PropertyEncryptorFactory.java
delete mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/SecurityStoreChangedPathListener.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/SecurityStoreMonitorCommand.java
delete mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/framework/ssl/WatchServiceMonitorCommand.java
create mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/framework/ssl/SecurityStoreMonitorCommandTest.java
delete mode 100644
nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/framework/ssl/WatchServiceMonitorCommandTest.java
copy nifi-commons/nifi-utils/src/main/java/org/apache/nifi/util/Triple.java =>
nifi-mock/src/main/java/org/apache/nifi/util/GaugeMeasurement.java (79%)
copy
nifi-commons/nifi-flowfile-packager/src/main/java/org/apache/nifi/util/FlowFilePackager.java
=> nifi-mock/src/main/java/org/apache/nifi/util/MetricKey.java (73%)
copy
nifi-extension-bundles/nifi-pgp-bundle/nifi-pgp-service-api/src/test/java/org/apache/nifi/pgp/service/api/KeyIdentifierConverterTest.java
=>
nifi-registry/nifi-registry-core/nifi-registry-bundle-utils/src/test/java/org/apache/nifi/registry/bundle/model/TestBundleIdentifier.java
(50%)
create mode 100644
nifi-registry/nifi-registry-core/nifi-registry-bundle-utils/src/test/java/org/apache/nifi/registry/bundle/util/TestBundleUtils.java
copy
nifi-registry/nifi-registry-core/nifi-registry-flow-diff/src/main/java/org/apache/nifi/registry/flow/diff/{DifferenceDescriptor.java
=> SensitiveValueDecryptor.java} (54%)
create mode 100644
nifi-registry/nifi-registry-core/nifi-registry-framework/src/test/java/org/apache/nifi/registry/provider/extension/TestStandardBundleCoordinate.java
create mode 100644
nifi-registry/nifi-registry-core/nifi-registry-framework/src/test/java/org/apache/nifi/registry/provider/extension/TestStandardBundleVersionCoordinate.java
create mode 100644
nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/encryption/PropertyEncryptionProviderIT.java
