Browse Source
Await save future in integration test to prevent flakiness
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
pull/15058/head
Viacheslav Klimov
7 months ago
Failed to extract signature
1 changed files with
1 additions and
1 deletions
-
dao/src/test/java/org/thingsboard/server/dao/service/timeseries/nosql/TimeseriesServiceNoSqlTest.java
|
|
@ -114,7 +114,7 @@ public class TimeseriesServiceNoSqlTest extends BaseTimeseriesServiceTest { |
|
|
for (int i = 0; i < 5; i++) { |
|
|
for (int i = 0; i < 5; i++) { |
|
|
entries.add(new BasicTsKvEntry(TimeUnit.MINUTES.toMillis(i + 1), new StringDataEntry("bigKey", value))); |
|
|
entries.add(new BasicTsKvEntry(TimeUnit.MINUTES.toMillis(i + 1), new StringDataEntry("bigKey", value))); |
|
|
} |
|
|
} |
|
|
tsService.save(tenantId, deviceId, entries, 0); |
|
|
tsService.save(tenantId, deviceId, entries, 0).get(MAX_TIMEOUT, TimeUnit.SECONDS); |
|
|
|
|
|
|
|
|
long originalLimit = (long) ReflectionTestUtils.getField(cassandraBaseTimeseriesDao, "maxResultSetSizeBytes"); |
|
|
long originalLimit = (long) ReflectionTestUtils.getField(cassandraBaseTimeseriesDao, "maxResultSetSizeBytes"); |
|
|
try { |
|
|
try { |
|
|
|
