The class that the blacklist scheduler will report the blacklist.
The class that specifies the eviction strategy to use in blacklist scheduler.
The timeout on DRPC requests within the DRPC server.
the class that specifies the scheduling priority strategy to use in ResourceAwareScheduler.
How often cluster metrics data is published to metrics consumer.
Class implementing WorkerMetricsProcessor.
Class implementing MetricStore.
What Network Topography detection classes should we use.
The cgroup root for oci container.
The root of cgroup for oci to use.
The directory of nscd - name service cache daemon, e.g.
A list of ports that can run workers on this supervisor.
How long a worker can go without heartbeating during the initial launch before the supervisor tries to restart the worker process.
How long a worker can go without heartbeating before the supervisor tries to restart the worker process.
How often a worker should check and notify upstream workers about its tasks that are no longer experiencing BP and able to receive
new messages.
Configures park time if using WaitStrategyPark for BackPressure.
Configures steps used to determine progression to the next level of wait .. if using WaitStrategyProgressive for BackPressure.
Configures steps used to determine progression to the next level of wait .. if using WaitStrategyProgressive for BackPressure.
Configures sleep time if using WaitStrategyProgressive for BackPressure.
How often to send flush tuple to the executors for flushing out batched events.
Configures park time for WaitStrategyPark.
Configures number of iterations to spend in level 1 of WaitStrategyProgressive, before progressing to level 2.
Configures number of iterations to spend in level 2 of WaitStrategyProgressive, before progressing to level 3.
Configures sleep time for WaitStrategyProgressive.
Disable load aware grouping support.
If number of items in task's overflowQ exceeds this, new messages coming from other workers to this task will be dropped This
prevents OutOfMemoryException that can occur in rare scenarios in the presence of BackPressure.
This signifies the load congestion among target tasks in scope.
This signifies the load congestion among target tasks in scope.
The maximum amount of time given to the topology to fully process a message emitted by a spout.
The number of tuples to batch before sending to the destination executor.
The strategy to use when scheduling a topology with Resource Aware Scheduler.
Max pending tuples in one ShellBolt.
Check recvQ after every N invocations of Spout's nextTuple() [when ACKing is disabled].
Configures park time for WaitStrategyPark for spout.
Configures number of iterations to spend in level 1 of WaitStrategyProgressive, before progressing to level 2.
Configures number of iterations to spend in level 2 of WaitStrategyProgressive, before progressing to level 3.
Configures sleep time for WaitStrategyProgressive.
The maximum amount of time a component gives a source of state to synchronize before it requests synchronization again.
Topology configurable worker heartbeat timeout before the supervisor tries to restart the worker process.