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 <[email protected]>
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 <[email protected]>
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)
