diff --git a/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java b/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java index af31a9b89cb7..7ff03d397776 100644 --- a/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java +++ b/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java @@ -578,7 +578,7 @@ private synchronized void triggerUpdate() { // synchronized so that needsUpdate is not cleared in sendUpdate before actual request is sent needsUpdate.set(true); - sendUpdate(); + scheduleUpdate(); } private synchronized void sendUpdate()