|
55 | 55 | @SuppressWarnings("unchecked") |
56 | 56 | @ESIntegTestCase.ClusterScope(maxNumDataNodes = 1) |
57 | 57 | public class RandomizedTimeSeriesIT extends AbstractEsqlIntegTestCase { |
58 | | - |
59 | 58 | private static final Long NUM_DOCS = 2000L; |
60 | 59 | private static final Long TIME_RANGE_SECONDS = 3600L; |
61 | 60 | private static final String DATASTREAM_NAME = "tsit_ds"; |
@@ -272,6 +271,8 @@ void putTSDBIndexTemplate(List<String> patterns, @Nullable String mappingString) |
272 | 271 | Settings.Builder settingsBuilder = Settings.builder(); |
273 | 272 | // Ensure it will be a TSDB data stream |
274 | 273 | settingsBuilder.put(IndexSettings.MODE.getKey(), IndexMode.TIME_SERIES); |
| 274 | + settingsBuilder.put(IndexSettings.TIME_SERIES_START_TIME.getKey(), "2025-07-31T00:00:00Z"); |
| 275 | + settingsBuilder.put(IndexSettings.TIME_SERIES_END_TIME.getKey(), "2025-07-31T12:00:00Z"); |
275 | 276 | CompressedXContent mappings = mappingString == null ? null : CompressedXContent.fromJSON(mappingString); |
276 | 277 | TransportPutComposableIndexTemplateAction.Request request = new TransportPutComposableIndexTemplateAction.Request( |
277 | 278 | RandomizedTimeSeriesIT.DATASTREAM_NAME |
@@ -338,9 +339,9 @@ public void testRateGroupBySubset() { |
338 | 339 | try (var resp = run(String.format(Locale.ROOT, """ |
339 | 340 | TS %s |
340 | 341 | | STATS count(rate(metrics.counter_hdd.bytes.read)), |
341 | | - min(rate(metrics.counter_hdd.bytes.read)), |
342 | 342 | max(rate(metrics.counter_hdd.bytes.read)), |
343 | | - avg(rate(metrics.counter_hdd.bytes.read)) |
| 343 | + avg(rate(metrics.counter_hdd.bytes.read)), |
| 344 | + min(rate(metrics.counter_hdd.bytes.read)) |
344 | 345 | BY tbucket=bucket(@timestamp, 1 minute), %s |
345 | 346 | | SORT tbucket |
346 | 347 | | LIMIT 1000 |
|
0 commit comments