Skip to content

Commit 079f73a

Browse files
committed
fixup
1 parent 2349873 commit 079f73a

File tree

1 file changed

+17
-7
lines changed

1 file changed

+17
-7
lines changed

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/RandomizedTimeSeriesIT.java

Lines changed: 17 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -216,9 +216,14 @@ public void testGroupBySubset() {
216216
for (List<Object> row : rows) {
217217
var rowKey = getRowKey(row, dimensions, 6);
218218
var docValues = valuesInWindow(groups.get(rowKey), "gauge_hdd.bytes.used");
219-
// Max of int is always int, so we can safely round the result.
220-
var valuesAsInts = docValues.stream().toList();
221-
assertThat(valuesAsInts, containsInAnyOrder(docValues.toArray()));
219+
if (row.get(0) instanceof List) {
220+
assertThat(
221+
(Collection<Long>) row.get(0),
222+
containsInAnyOrder(docValues.stream().mapToLong(Integer::longValue).boxed().toArray(Long[]::new))
223+
);
224+
} else {
225+
assertThat(row.get(0), equalTo(docValues.getFirst().longValue()));
226+
}
222227
assertThat(row.get(1), equalTo(Math.round(aggregateValuesInWindow(docValues, Agg.MAX))));
223228
assertThat(row.get(2), equalTo(Math.round(aggregateValuesInWindow(docValues, Agg.MIN))));
224229
assertThat(row.get(3), equalTo((long) docValues.size()));
@@ -252,10 +257,15 @@ public void testGroupByNothing() {
252257
var groups = groupedRows(documents, List.of(), 60);
253258
for (List<Object> row : rows) {
254259
var windowStart = windowStart(row.get(6), 60);
255-
var docValues = valuesInWindow(groups.get(List.of(Long.toString(windowStart))), "gauge_hdd.bytes.used");
256-
// Make sure that expected timestamps and values are present
257-
var valuesAsInts = docValues.stream().toList();
258-
assertThat(valuesAsInts, containsInAnyOrder(docValues.toArray()));
260+
List<Integer> docValues = valuesInWindow(groups.get(List.of(Long.toString(windowStart))), "gauge_hdd.bytes.used");
261+
if (row.get(0) instanceof List) {
262+
assertThat(
263+
(Collection<Long>) row.get(0),
264+
containsInAnyOrder(docValues.stream().mapToLong(Integer::longValue).boxed().toArray(Long[]::new))
265+
);
266+
} else {
267+
assertThat(row.get(0), equalTo(docValues.getFirst().longValue()));
268+
}
259269
assertThat(row.get(1), equalTo(Math.round(aggregateValuesInWindow(docValues, Agg.MAX))));
260270
assertThat(row.get(2), equalTo(Math.round(aggregateValuesInWindow(docValues, Agg.MIN))));
261271
assertThat(row.get(3), equalTo((long) docValues.size()));

0 commit comments

Comments
 (0)