File tree 3 files changed +6
-1
lines changed
qa/testFixtures/src/main/resources
main/java/org/elasticsearch/xpack/esql/plugin
test/java/org/elasticsearch/xpack/esql/action 3 files changed +6
-1
lines changed Original file line number Diff line number Diff line change 3
3
"id" : 5326 ,
4
4
"type" : " transport" ,
5
5
"action" : " indices:data/read/esql" ,
6
+ "status" : " Ks5ApyqMTtWj5LrKigmCjQ" ,
6
7
"description" : " FROM test | STATS MAX(d) by a, b" , <1>
7
8
"start_time" : " 2023-07-31T15:46:32.328Z" ,
8
9
"start_time_in_millis" : 1690818392328 ,
Original file line number Diff line number Diff line change 7
7
8
8
package org .elasticsearch .xpack .esql .plugin ;
9
9
10
+ import org .elasticsearch .common .Strings ;
10
11
import org .elasticsearch .common .io .stream .NamedWriteableRegistry ;
11
12
import org .elasticsearch .common .io .stream .StreamInput ;
12
13
import org .elasticsearch .common .io .stream .StreamOutput ;
@@ -47,6 +48,6 @@ public void writeTo(StreamOutput out) throws IOException {
47
48
48
49
@ Override
49
50
public XContentBuilder toXContent (XContentBuilder builder , Params params ) throws IOException {
50
- return builder .rawValue (id );
51
+ return builder .rawValue (Strings . format ( " \" %s \" " , id ) );
51
52
}
52
53
}
Original file line number Diff line number Diff line change 38
38
import org .elasticsearch .xpack .esql .parser .ParsingException ;
39
39
import org .elasticsearch .xpack .esql .parser .QueryParam ;
40
40
import org .elasticsearch .xpack .esql .parser .QueryParams ;
41
+ import org .elasticsearch .xpack .esql .plugin .EsqlDocIdStatus ;
41
42
42
43
import java .io .IOException ;
43
44
import java .util .ArrayList ;
@@ -621,6 +622,8 @@ public void testTask() throws IOException {
621
622
.replaceAll ("FROM test \\ | STATS MAX\\ (d\\ ) by a, b" , query )
622
623
.replaceAll ("5326" , Integer .toString (id ))
623
624
.replaceAll ("2j8UKw1bRO283PMwDugNNg" , localNode )
625
+ .replaceAll ("Ks5ApyqMTtWj5LrKigmCjQ" , ((EsqlDocIdStatus ) taskInfo .status ()).id ())
626
+ .replaceAll ("2023-07-31T15:46:32\\ .328Z" , DateFieldMapper .DEFAULT_DATE_TIME_FORMATTER .formatMillis (taskInfo .startTime ()))
624
627
.replaceAll ("2023-07-31T15:46:32\\ .328Z" , DateFieldMapper .DEFAULT_DATE_TIME_FORMATTER .formatMillis (taskInfo .startTime ()))
625
628
.replaceAll ("1690818392328" , Long .toString (taskInfo .startTime ()))
626
629
.replaceAll ("41.7ms" , TimeValue .timeValueNanos (taskInfo .runningTimeNanos ()).toString ())
You can’t perform that action at this time.
0 commit comments