- Removed hamcrest-all from default dependencies
- Added groovy-test to selected modules with Groovy test classes
- Added junit-vintage-engine to selected modules with JUnit 4 test classes
- Corrected references to JUnit 4 assertions in JUnit 5 test classes
- Removed several unnecessary test classes from nifi-socket-utils
- Removed duplicative Registry toolkit test classes
- Removed Kudu integration tests
Signed-off-by: Matt Burgess <mattyb149@apache.org>
This closes#7233
(cherry picked from commit ca6c7f704164e922e11d72e7c972a50ac46e6b0e)
- Added Message Derivation Strategy to PublishGCPubSub with FlowFile and Record options
- Added API Endpoint property to PublishGCPPubSub and ConsumeGCPubSub
- Added Batch configuration properties
This closes#7274
Signed-off-by: David Handermann <exceptionfactory@apache.org>
(cherry picked from commit 336b857442109e1f2c8b3b6108106514609159f5)
- Resolved BufferOverflowException in PeerChannel with Bouncy Castle Provider
- Changed prepareForWrite() to use Destination Buffer remaining instead of Application Buffer Size
- Changed encrypt() to Packet Buffer Size instead of Application Buffer Size
Add two new properties:
nifi.stateless.component.enableTimeout
nifi.stateless.processor.startTimeout
to allow configuring the StatelessEngine and ProcessScheduler.
This allows an operator to configure what kind of startup time the flow can
tolerate.
Previously these values were hard coded.
- Modified file handling to include both REGULAR and UNKNOWN File Types returned from an SFTP server
This closes#7365
Signed-off-by: David Handermann <exceptionfactory@apache.org>
(cherry picked from commit 45e8226f89be9b954f870ce00807eab80dfb6a0d)
Rather than creating many FlowFiles with the same Content Claim, refactored content repos' OutputStreams and ClaimWriteCache so that a new ContentClaim is created for each FlowFile. This ensures that we have a content claim offset of 0. The poor performance was due to having to use StreamUtils.skip() in conjunction with the CipherInputStream, which would only skip a max of 511 bytes at a time. By using a separate Content Claim per FlowFile, we no longer need to seek after creating the CipherInputStream
This closes#7363
Signed-off-by: David Handermann <exceptionfactory@apache.org>
(cherry picked from commit 702c6350344e4ae4cd31349747e96c1384017ed4)
- Deprecated GetAzureQueueStorage and PutAzureQueueStorage
This closes#7269
Signed-off-by: David Handermann <exceptionfactory@apache.org>
(cherry picked from commit b11373af7b017f83c3b579c6aefc7cb7a1816bfd)
* NIFI-11464 Improvements for importing nested versioned flows
- Introduce FlowSnapshotContainer to return root snapshot + children
- Introduce ControllerServiceResolver to extract logic from service facade
- Update resolution logic to correctly consider all services in the hierarchy
- Merge additional parameter contexts and parameter providers from child to parent
- Add unit test for controller service resolver
- Replace use of emptSet/emptyMap with new set/map instance
Also added client caching in blob v_12 processors which was needed to support multiple credentials provided by the new lookup service
Backported
This closes#7300
Signed-off-by: Nandor Soma Abonyi <nsabonyi@apache.org>
(cherry picked from commit 963518d943c75c8d053834be51c2947470767229)
- Moved Java tests from groovy directory to java directory and removed groovy directory from nifi-web-utils
This closes#7333
Signed-off-by: David Handermann <exceptionfactory@apache.org>
(cherry picked from commit 27b5a2f931e10ce1f25351e8b1070924a3ece196)
