You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2022/04/04 18:29:15 UTC
[nifi] 20/31: NIFI-9820 Reduced Kudu Client Worker Count default setting
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch support/nifi-1.16
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit daafd08aaebb3c4fcf149e25999d869b9fe94d3c
Author: exceptionfactory <ex...@apache.org>
AuthorDate: Mon Mar 21 09:54:35 2022 -0500
NIFI-9820 Reduced Kudu Client Worker Count default setting
- Changed default Kudu Client Worker Count to number of runtime-reported available processors
Signed-off-by: Joe Gresock <jg...@gmail.com>
This closes #5886.
---
.../java/org/apache/nifi/processors/kudu/AbstractKuduProcessor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/AbstractKuduProcessor.java b/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/AbstractKuduProcessor.java
index 1bccf969c0..6abb407619 100644
--- a/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/AbstractKuduProcessor.java
+++ b/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/AbstractKuduProcessor.java
@@ -142,11 +142,11 @@ public abstract class AbstractKuduProcessor extends AbstractProcessor {
.expressionLanguageSupported(ExpressionLanguageScope.VARIABLE_REGISTRY)
.build();
- private static final int DEFAULT_WORKER_COUNT = 2 * Runtime.getRuntime().availableProcessors();
+ private static final int DEFAULT_WORKER_COUNT = Runtime.getRuntime().availableProcessors();
static final PropertyDescriptor WORKER_COUNT = new Builder()
.name("worker-count")
.displayName("Kudu Client Worker Count")
- .description("The maximum number of worker threads handling Kudu client read and write operations. Defaults to the number of available processors multiplied by 2.")
+ .description("The maximum number of worker threads handling Kudu client read and write operations. Defaults to the number of available processors.")
.required(true)
.defaultValue(Integer.toString(DEFAULT_WORKER_COUNT))
.addValidator(StandardValidators.POSITIVE_INTEGER_VALIDATOR)