diff --git a/core/trino-main/src/main/java/io/trino/execution/scheduler/EventDrivenTaskSource.java b/core/trino-main/src/main/java/io/trino/execution/scheduler/EventDrivenTaskSource.java
index d6ffa62e943f..98c28d40b47b 100644
--- a/core/trino-main/src/main/java/io/trino/execution/scheduler/EventDrivenTaskSource.java
+++ b/core/trino-main/src/main/java/io/trino/execution/scheduler/EventDrivenTaskSource.java
@@ -464,7 +464,7 @@ private synchronized void processNext()
                 return;
             }
             verify(splitLoadingFuture == null || splitLoadingFuture.isDone(), "splitLoadingFuture is still running");
-            long start = System.currentTimeMillis();
+            long start = System.nanoTime();
             splitLoadingFuture = splitSource.getNextBatch(splitBatchSize);
             Futures.addCallback(splitLoadingFuture, new FutureCallback<>()
             {
@@ -472,7 +472,7 @@ private synchronized void processNext()
                 public void onSuccess(SplitBatch result)
                 {
                     try {
-                        getSplitTimeRecorder.accept(System.currentTimeMillis() - start);
+                        getSplitTimeRecorder.accept(start);
                         ListMultimap<Integer, Split> splits = result.getSplits().stream()
                                 .collect(toImmutableListMultimap(splitToPartition::applyAsInt, Function.identity()));
                         callback.update(splits, result.isLastBatch());