This is an automated email from the ASF dual-hosted git repository.
jgresock pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 151a936 NIFI-9288: Updated data model to use for cnofig verification
requests so that only properties are necessary not the full component/config
dtos. Also added endpoint necessary for determining which attributes are
referenced by a component's properties and removed the referencedAttributes
field from the compnoents themselves, since there's now a new endpoint for it.
Also fixed a bug that was encountered where the VerifyConfigRequestDTO's
complete flag was incorrect in case [...]
new d722b82 NIFI-9248 Use hive-exec:core instead of the "regular"
hive-exec dependency
new be2b80d NIFI-9292: Added getInputPortNames() and getOutputPortNames()
to StatelessDataflowDefinition and getReadOnlyExtensionsDirectories() to
StatelessEngineConfiguration - Addressed issue identified in system test where
a flow can fail due to FailurePortEncounteredException but then purge the flow
in the background after the call to trigger completes
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kafka/connect/StatelessKafkaConnectorUtil.java | 6 ++
.../nar/StandardExtensionDiscoveringManager.java | 6 ++
.../nifi-hive-bundle/nifi-hive3-processors/pom.xml | 83 ++++++++++++++++++++++
.../processors/stateless/ExecuteStateless.java | 15 ++++
.../PropertiesFileEngineConfigurationParser.java | 21 ++++++
.../engine/StatelessEngineConfiguration.java | 36 ++++++++++
.../nifi/stateless/flow/DataflowDefinition.java | 4 ++
...ropertiesFileEngineConfigurationParserTest.java | 29 ++++++++
nifi-stateless/nifi-stateless-assembly/README.md | 9 ++-
.../stateless/bootstrap/StatelessBootstrap.java | 6 ++
.../nifi/extensions/ExtensionRepository.java | 2 +
.../extensions/FileSystemExtensionRepository.java | 62 +++++++++++-----
.../nifi/stateless/engine/FlowPurgeAction.java | 8 +--
.../engine/StandardExecutionProgress.java | 8 ++-
.../stateless/engine/StandardStatelessEngine.java | 34 ++++++---
.../stateless/flow/StandardDataflowDefinition.java | 18 ++++-
.../flow/StandardStatelessDataflowFactory.java | 5 +-
.../nifi/stateless/flow/StandardStatelessFlow.java | 4 +-
.../TestPropertiesFileFlowDefinitionParser.java | 6 ++
.../apache/nifi/stateless/StatelessSystemIT.java | 22 ++++++
20 files changed, 343 insertions(+), 41 deletions(-)
copy nifi-api/src/main/java/org/apache/nifi/reporting/Severity.java =>
nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/engine/FlowPurgeAction.java
(89%)