diff --git a/core/trino-main/src/main/java/io/trino/execution/SqlTask.java b/core/trino-main/src/main/java/io/trino/execution/SqlTask.java index 2e6d91a581dc..46f9db069649 100644 --- a/core/trino-main/src/main/java/io/trino/execution/SqlTask.java +++ b/core/trino-main/src/main/java/io/trino/execution/SqlTask.java @@ -498,8 +498,8 @@ public TaskInfo updateTask( } // taskExecution can still be null if the creation was skipped if (taskExecution != null) { - taskExecution.addSplitAssignments(splitAssignments); taskExecution.getTaskContext().addDynamicFilter(dynamicFilterDomains); + taskExecution.addSplitAssignments(splitAssignments); } // update speculative flag