You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jg...@apache.org on 2022/03/30 15:07:56 UTC
[nifi] branch main updated: NIFI-9820 Reduced Kudu Client Worker Count default setting
This is an automated email from the ASF dual-hosted git repository.
jgresock pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new b53fb87 NIFI-9820 Reduced Kudu Client Worker Count default setting
b53fb87 is described below
commit b53fb87aa1af5638744f4b35d074c8ae433f98a2
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 1bccf96..6abb407 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)