diff --git a/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedQueryScheduler.java b/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedQueryScheduler.java
index d228f37cd43a..1c60ef496dba 100644
--- a/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedQueryScheduler.java
+++ b/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedQueryScheduler.java
@@ -1341,7 +1341,7 @@ else if (!result.getBlocked().isDone()) {
                         // allow for schedule to resume scheduling (e.g. when some active stage completes
                         // and dependent stages can be started)
                         stagesScheduleResult.getRescheduleFuture().ifPresent(futures::add);
-                        try (TimeStat.BlockTimer timer = schedulerStats.getSleepTime().time()) {
+                        try (TimeStat.BlockTimer _ = schedulerStats.getSleepTime().time()) {
                             tryGetFutureValue(whenAnyComplete(futures.build()), 1, SECONDS);
                         }
                         for (ListenableFuture<Void> blockedStage : blockedStages) {
@@ -1361,17 +1361,12 @@ else if (!result.getBlocked().isDone()) {
                 fail(t, Optional.empty());
             }
             finally {
-                RuntimeException closeError = new RuntimeException();
                 for (StageScheduler scheduler : stageSchedulers.values()) {
                     try {
                         scheduler.close();
                     }
                     catch (Throwable t) {
                         fail(t, Optional.empty());
-                        // Self-suppression not permitted
-                        if (closeError != t) {
-                            closeError.addSuppressed(t);
-                        }
                     }
                 }
             }