diff --git a/core/trino-main/src/main/java/io/trino/execution/executor/timesharing/TimeSharingTaskExecutor.java b/core/trino-main/src/main/java/io/trino/execution/executor/timesharing/TimeSharingTaskExecutor.java index d9b623481bfb9..4536d9437af13 100644 --- a/core/trino-main/src/main/java/io/trino/execution/executor/timesharing/TimeSharingTaskExecutor.java +++ b/core/trino-main/src/main/java/io/trino/execution/executor/timesharing/TimeSharingTaskExecutor.java @@ -669,6 +669,12 @@ public DistributionStat getLeafSplitsSize() return leafSplitsSize; } + @Managed + public synchronized int getCurrentLeafSplitsSize() + { + return allSplits.size() - intermediateSplits.size(); + } + @Managed public int getRunningSplits() {