(pinot) branch master updated: set tables for controller task scheduling (#15594)

[jtao]

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 <liranj...@gmail.com>
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: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org