From b53fb87aa1af5638744f4b35d074c8ae433f98a2 Mon Sep 17 00:00:00 2001 From: exceptionfactory Date: Mon, 21 Mar 2022 09:54:35 -0500 Subject: [PATCH] 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 This closes #5886. --- .../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)