Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
import com.google.common.collect.ArrayListMultimap;
import com.google.common.collect.ListMultimap;
import com.google.common.collect.Multimaps;
import io.airlift.log.Logger;
import io.trino.execution.StageId;
import io.trino.execution.TaskId;
import io.trino.execution.executor.timesharing.SimulationTask.IntermediateTask;
Expand All @@ -35,6 +36,8 @@

class SimulationController
{
private static final Logger log = Logger.get(SimulationController.class);

private static final int DEFAULT_MIN_SPLITS_PER_TASK = 3;

private final TimeSharingTaskExecutor taskExecutor;
Expand Down Expand Up @@ -63,7 +66,7 @@ public synchronized void addTaskSpecification(TaskSpecification spec)

public synchronized void clearPendingQueue()
{
System.out.println("Clearing pending queue..");
log.info("Clearing pending queue..");
clearPendingQueue.set(true);
}

Expand Down Expand Up @@ -116,7 +119,7 @@ private synchronized void scheduleSplitsForRunningTasks()
return;
}

System.out.println("Cleared pending queue.");
log.info("Clearing pending queue.");
clearPendingQueue.set(false);
}

Expand Down Expand Up @@ -151,9 +154,7 @@ private synchronized void replaceCompletedTasks()
if (specification.getTotalTasks().isPresent() &&
specificationEnabled.get(specification) &&
specification.getTotalTasks().getAsInt() <= completedTasks.get(specification).size() + runningTasks.get(specification).size()) {
System.out.println();
System.out.println(specification.getName() + " disabled for reaching target count " + specification.getTotalTasks());
System.out.println();
log.info("\n%s disabled for reaching target count %s\n", specification.getName(), specification.getTotalTasks());
disableSpecification(specification);
continue;
}
Expand Down
Loading