From ee96e2423d5992a609e139dee6657fb225c8c692 Mon Sep 17 00:00:00 2001 From: Luigi Dell'Aquila Date: Mon, 30 Sep 2024 10:20:23 +0200 Subject: [PATCH 1/2] ES|QL: pin 'now' as query start time --- .../org/elasticsearch/xpack/esql/session/Configuration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java index 33a48d2e7df05..5981ec2de5b82 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java @@ -163,7 +163,7 @@ public String query() { * Note: Currently, it returns {@link System#currentTimeMillis()}, but this value will be serialized between nodes. */ public long absoluteStartedTimeInMillis() { - return System.currentTimeMillis(); + return now.toInstant().toEpochMilli(); } /** From 6e31a34fd061948a20173c24ee6979d0e623de3f Mon Sep 17 00:00:00 2001 From: Luigi Dell'Aquila Date: Mon, 30 Sep 2024 11:43:22 +0200 Subject: [PATCH 2/2] Javadoc --- .../java/org/elasticsearch/xpack/esql/session/Configuration.java | 1 - 1 file changed, 1 deletion(-) diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java index 5981ec2de5b82..22aed6487f87a 100644 --- a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java +++ b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/Configuration.java @@ -160,7 +160,6 @@ public String query() { /** * Returns the current time in milliseconds from the time epoch for the execution of this request. * It ensures consistency by using the same value on all nodes involved in the search request. - * Note: Currently, it returns {@link System#currentTimeMillis()}, but this value will be serialized between nodes. */ public long absoluteStartedTimeInMillis() { return now.toInstant().toEpochMilli();