Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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 <jgresock@gmail.com>

This closes #5886.
This commit is contained in:
exceptionfactory 2022-03-21 09:54:35 -05:00 committed by Joe Gresock
parent d09b828333
commit b53fb87aa1
No known key found for this signature in database
GPG Key ID: 37F5B9B6E258C8B7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/AbstractKuduProcessor.java
View File

@ -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)