This is an automated email from the ASF dual-hosted git repository. martinzink pushed a commit to branch minifi-api-property in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
commit 446da68da32fa0b1f2a08d068d527fe065981d97 Author: Martin Zink <[email protected]> AuthorDate: Tue Mar 18 14:00:41 2025 +0100 skip ProvenanceReportingTask setUrl if hostStr.empty() parseProcessorNode: maxConcurrentTasks removed value_or --- libminifi/src/core/flow/StructuredConfiguration.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/libminifi/src/core/flow/StructuredConfiguration.cpp b/libminifi/src/core/flow/StructuredConfiguration.cpp index 44f6f14bd..5eb856c5f 100644 --- a/libminifi/src/core/flow/StructuredConfiguration.cpp +++ b/libminifi/src/core/flow/StructuredConfiguration.cpp @@ -584,7 +584,7 @@ void StructuredConfiguration::parseProvenanceReporting(const Node& node, core::P auto hostStr = node["host"].getString().value(); std::string portStr = node["port"].getIntegerAsString().value(); - if (auto port = parsing::parseIntegral<int64_t>(portStr)) { + if (auto port = parsing::parseIntegral<int64_t>(portStr); port && !hostStr.empty()) { logger_->log_debug("ProvenanceReportingTask port {}", *port); std::string url = hostStr + ":" + portStr; reportTask->setURL(url); @@ -753,9 +753,9 @@ void StructuredConfiguration::parseRPGPort(const Node& port_node, core::ProcessG if (auto tasksNode = port_node[schema_.max_concurrent_tasks]) { const std::string raw_max_concurrent_tasks = tasksNode.getIntegerAsString().value(); - if (auto max_concurrent_tasks = parsing::parseIntegral<uint8_t>(raw_max_concurrent_tasks).value_or(0)) { - logger_->log_debug("parseProcessorNode: maxConcurrentTasks => [{}]", max_concurrent_tasks); - processor.setMaxConcurrentTasks(max_concurrent_tasks); + if (auto max_concurrent_tasks = parsing::parseIntegral<uint8_t>(raw_max_concurrent_tasks); max_concurrent_tasks) { + logger_->log_debug("parseProcessorNode: maxConcurrentTasks => [{}]", *max_concurrent_tasks); + processor.setMaxConcurrentTasks(*max_concurrent_tasks); } } }
