You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2022/02/15 20:40:50 UTC
[nifi] branch main updated (84b2484 -> 63a543c)
This is an automated email from the ASF dual-hosted git repository.
markap14 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 84b2484 NIFI-9684 Fix: When starting/stopping selected process group, it sends the parent process group id to the REST interface that is responsible to enable/disable transmission for all remote process groups within a process group. Need to send the id of the select process group instead. (#5764)
add 63a543c NIFI-9475 Provide Framework-Level Retries for NiFi Relationships (#5593)
No new revisions were added by this update.
Summary of changes:
.../org/apache/nifi/flow/VersionedProcessor.java | 49 +++
.../org/apache/nifi/processor/ProcessContext.java | 10 +
.../org/apache/nifi/util/MockProcessContext.java | 10 +
.../nifi/web/api/dto/ProcessorConfigDTO.java | 50 +++
.../apache/nifi/web/api/dto/RelationshipDTO.java | 15 +
.../nifi/controller/StandardProcessorNode.java | 78 +++++
.../repository/StandardProcessSession.java | 239 ++++++++++++++-
.../repository/StandardProvenanceReporter.java | 5 +
.../scheduling/ConnectableProcessContext.java | 11 +
.../groups/StandardProcessGroupSynchronizer.java | 14 +
.../nifi/processor/StandardProcessContext.java | 10 +
.../flow/mapping/NiFiRegistryFlowMapper.java | 4 +
.../flow/mapping/TestNiFiRegistryFlowMapper.java | 2 +
.../org/apache/nifi/connectable/Connectable.java | 19 ++
.../org/apache/nifi/controller/AbstractPort.java | 42 +++
.../apache/nifi/controller/BackoffMechanism.java | 5 +-
.../org/apache/nifi/controller/StandardFunnel.java | 42 +++
.../provenance/InternalProvenanceReporter.java | 2 +
.../nifi/controller/StandardFlowSnippet.java | 6 +
.../nifi/controller/XmlFlowSynchronizer.java | 7 +
.../serialization/FlowFromDOMFactory.java | 15 +
.../serialization/StandardFlowSerializer.java | 7 +
.../nifi/fingerprint/FingerprintFactory.java | 12 +
.../src/main/resources/FlowConfiguration.xsd | 16 +
.../apache/nifi/controller/TestFlowController.java | 12 +
.../repository/StandardProcessSessionIT.java | 339 +++++++++++++++++++++
.../flow/mapping/NiFiRegistryFlowMapperTest.java | 2 +
.../org/apache/nifi/mock/MockProcessContext.java | 10 +
.../org/apache/nifi/audit/ProcessorAuditor.java | 22 ++
.../org/apache/nifi/web/api/ProcessorResource.java | 21 ++
.../org/apache/nifi/web/api/dto/DtoFactory.java | 10 +
.../nifi/web/dao/impl/StandardProcessorDAO.java | 27 +-
.../nifi/registry/flow/diff/DifferenceType.java | 20 ++
.../registry/flow/diff/StandardFlowComparator.java | 4 +
.../nifi/stateless/VersionedFlowBuilder.java | 4 +
.../{MergingIT.java => StatelessRetryIT.java} | 51 ++--
.../processors/tests/system/SplitTextByLine.java | 86 ++++++
.../services/org.apache.nifi.processor.Processor | 1 +
.../nifi/tests/system/processor/RetryIT.java | 329 ++++++++++++++++++++
39 files changed, 1566 insertions(+), 42 deletions(-)
copy nifi-framework-api/src/main/java/org/apache/nifi/controller/DecommissionTask.java => nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/BackoffMechanism.java (90%)
copy nifi-system-tests/nifi-stateless-system-test-suite/src/test/java/org/apache/nifi/stateless/basics/{MergingIT.java => StatelessRetryIT.java} (55%)
create mode 100644 nifi-system-tests/nifi-system-test-extensions-bundle/nifi-system-test-extensions/src/main/java/org/apache/nifi/processors/tests/system/SplitTextByLine.java
create mode 100644 nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/processor/RetryIT.java