This is an automated email from the ASF dual-hosted git repository.
jtao 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 5cf9c3b104 set tables for controller task scheduling (#15594)
5cf9c3b104 is described below
commit 5cf9c3b104e782d181a6451b998c96b745571a56
Author: liranjiao <[email protected]>
AuthorDate: Fri Apr 18 14:48:29 2025 -0700
set tables for controller task scheduling (#15594)
---
.../apache/pinot/controller/helix/core/minion/PinotTaskManager.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java
b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java
index eab658a521..ef86dbab2d 100644
---
a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java
+++
b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java
@@ -19,6 +19,7 @@
package org.apache.pinot.controller.helix.core.minion;
import com.google.common.base.Preconditions;
+import com.google.common.collect.ImmutableSet;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.ArrayList;
@@ -811,7 +812,8 @@ public class PinotTaskManager extends
ControllerPeriodicTask<Void> {
protected void processTables(List<String> tableNamesWithType, Properties
taskProperties) {
TaskSchedulingContext context = new TaskSchedulingContext()
.setLeader(true)
- .setTriggeredBy(CommonConstants.TaskTriggers.CRON_TRIGGER.name());
+ .setTriggeredBy(CommonConstants.TaskTriggers.CRON_TRIGGER.name())
+ .setTablesToSchedule(ImmutableSet.copyOf(tableNamesWithType));
// cron schedule
scheduleTasks(context);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
