diff --git a/core/trino-main/src/main/java/io/trino/operator/Driver.java b/core/trino-main/src/main/java/io/trino/operator/Driver.java
index 7944881d70fb..218fed73eb92 100644
--- a/core/trino-main/src/main/java/io/trino/operator/Driver.java
+++ b/core/trino-main/src/main/java/io/trino/operator/Driver.java
@@ -28,7 +28,6 @@
 import io.trino.metadata.Split;
 import io.trino.spi.Page;
 import io.trino.spi.TrinoException;
-import io.trino.sql.planner.plan.PlanNodeId;
 
 import javax.annotation.concurrent.GuardedBy;
 
@@ -164,11 +163,6 @@ public ListenableFuture<Void> getDestroyedFuture()
         return destroyedFuture;
     }
 
-    public Optional<PlanNodeId> getSourceId()
-    {
-        return sourceOperator.map(SourceOperator::getSourceId);
-    }
-
     @Override
     public void close()
     {