This is an automated email from the ASF dual-hosted git repository.
kharekartik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 90bf116554b Increase scope for createTaskManager to allow overriding
it (#17495)
90bf116554b is described below
commit 90bf116554b197a46264a8be679b7402f560ec33
Author: Shounak kulkarni <[email protected]>
AuthorDate: Tue Jan 13 15:19:05 2026 +0530
Increase scope for createTaskManager to allow overriding it (#17495)
---
.../main/java/org/apache/pinot/controller/BaseControllerStarter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pinot-controller/src/main/java/org/apache/pinot/controller/BaseControllerStarter.java
b/pinot-controller/src/main/java/org/apache/pinot/controller/BaseControllerStarter.java
index df0a2a6c8f6..3e9efbecdec 100644
---
a/pinot-controller/src/main/java/org/apache/pinot/controller/BaseControllerStarter.java
+++
b/pinot-controller/src/main/java/org/apache/pinot/controller/BaseControllerStarter.java
@@ -1001,7 +1001,7 @@ public abstract class BaseControllerStarter implements
ServiceStartable {
/**
* Creates a TaskManager instance as specified in the configuration.
*/
- private PinotTaskManager createTaskManager() {
+ protected PinotTaskManager createTaskManager() {
String taskManagerClass =
_config.getProperty(CommonConstants.Controller.CONFIG_OF_TASK_MANAGER_CLASS,
CommonConstants.Controller.DEFAULT_TASK_MANAGER_CLASS);
LOGGER.info("Creating TaskManager with class: {}", taskManagerClass);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
