diff --git a/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedStageExecution.java b/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedStageExecution.java
index 2ba98b003ccc..3e01c9e3966a 100644
--- a/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedStageExecution.java
+++ b/core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedStageExecution.java
@@ -207,13 +207,13 @@ public void addStateChangeListener(StateChangeListener<State> stateChangeListene
     }
 
     @Override
-    public synchronized void beginScheduling()
+    public void beginScheduling()
     {
         stateMachine.transitionToScheduling();
     }
 
     @Override
-    public synchronized void transitionToSchedulingSplits()
+    public void transitionToSchedulingSplits()
     {
         stateMachine.transitionToSchedulingSplits();
     }