[opt](routine-load) do not schedule invalid task (#34918)

This commit is contained in:
HHoflittlefish777
2024-05-21 11:56:09 +08:00
committed by yiguolei
parent fb28d0b185
commit 44bb2bb639

View File

@ -123,6 +123,9 @@ public class RoutineLoadTaskScheduler extends MasterDaemon {
}
try {
if (routineLoadManager.getJob(routineLoadTaskInfo.getJobId()).isFinal()) {
return;
}
// check if topic has more data to consume
if (!routineLoadTaskInfo.hasMoreDataToConsume()) {
needScheduleTasksQueue.addLast(routineLoadTaskInfo);