Commit e15fb63b53b052e2bc269e8f0307efc43dd58797

Authored by Viacheslav Kukhtyn
2 parents fb098e1b c1675db1

Merge remote-tracking branch 'upstream/master'

... ... @@ -135,7 +135,7 @@ cassandra:
135 135 write_consistency_level: "${CASSANDRA_WRITE_CONSISTENCY_LEVEL:ONE}"
136 136 default_fetch_size: "${CASSANDRA_DEFAULT_FETCH_SIZE:2000}"
137 137 # Specify partitioning size for timestamp key-value storage. Example MINUTES, HOURS, DAYS, MONTHS,INDEFINITE
138   - ts_key_value_partitioning: "${TS_KV_PARTITIONING:INDEFINITE}"
  138 + ts_key_value_partitioning: "${TS_KV_PARTITIONING:MONTHS}"
139 139 ts_key_value_ttl: "${TS_KV_TTL:0}"
140 140 buffer_size: "${CASSANDRA_QUERY_BUFFER_SIZE:200000}"
141 141 concurrent_limit: "${CASSANDRA_QUERY_CONCURRENT_LIMIT:1000}"
... ...
... ... @@ -329,9 +329,11 @@ public abstract class BaseEntityViewControllerTest extends AbstractControllerTes
329 329 Set<String> expectedActualAttributesSet =
330 330 new HashSet<>(Arrays.asList("caKey1", "caKey2", "caKey3", "caKey4"));
331 331 assertTrue(actualAttributesSet.containsAll(expectedActualAttributesSet));
332   - Thread.sleep(1000);
333 332
334 333 EntityView savedView = getNewSavedEntityView("Test entity view");
  334 +
  335 + Thread.sleep(1000);
  336 +
335 337 List<Map<String, Object>> values = doGetAsync("/api/plugins/telemetry/ENTITY_VIEW/" + savedView.getId().getId().toString() +
336 338 "/values/attributes?keys=" + String.join(",", actualAttributesSet), List.class);
337 339
... ... @@ -348,7 +350,6 @@ public abstract class BaseEntityViewControllerTest extends AbstractControllerTes
348 350
349 351 Set<String> expectedActualAttributesSet = new HashSet<>(Arrays.asList("caKey1", "caKey2", "caKey3", "caKey4"));
350 352 assertTrue(actualAttributesSet.containsAll(expectedActualAttributesSet));
351   - Thread.sleep(1000);
352 353
353 354 List<Map<String, Object>> valueTelemetryOfDevices = doGetAsync("/api/plugins/telemetry/DEVICE/" + testDevice.getId().getId().toString() +
354 355 "/values/attributes?keys=" + String.join(",", actualAttributesSet), List.class);
... ... @@ -363,6 +364,8 @@ public abstract class BaseEntityViewControllerTest extends AbstractControllerTes
363 364 view.setEndTimeMs((long) getValue(valueTelemetryOfDevices, "lastActivityTime") / 10);
364 365 EntityView savedView = doPost("/api/entityView", view, EntityView.class);
365 366
  367 + Thread.sleep(1000);
  368 +
366 369 List<Map<String, Object>> values = doGetAsync("/api/plugins/telemetry/ENTITY_VIEW/" + savedView.getId().getId().toString() +
367 370 "/values/attributes?keys=" + String.join(",", actualAttributesSet), List.class);
368 371 assertEquals(0, values.size());
... ...
... ... @@ -37,7 +37,7 @@
37 37 <pkg.name>tb-coap-transport</pkg.name>
38 38 <docker.name>tb-coap-transport</docker.name>
39 39 <pkg.user>thingsboard</pkg.user>
40   - <pkg.unixLogFolder>/var/log/${pkg.name}</pkg.unixLogFolder>
  40 + <pkg.logFolder>/var/log/${pkg.name}</pkg.logFolder>
41 41 <pkg.installFolder>/usr/share/${pkg.name}</pkg.installFolder>
42 42 </properties>
43 43
... ...
... ... @@ -37,7 +37,7 @@
37 37 <pkg.name>tb-http-transport</pkg.name>
38 38 <docker.name>tb-http-transport</docker.name>
39 39 <pkg.user>thingsboard</pkg.user>
40   - <pkg.unixLogFolder>/var/log/${pkg.name}</pkg.unixLogFolder>
  40 + <pkg.logFolder>/var/log/${pkg.name}</pkg.logFolder>
41 41 <pkg.installFolder>/usr/share/${pkg.name}</pkg.installFolder>
42 42 </properties>
43 43
... ...
... ... @@ -37,7 +37,7 @@
37 37 <pkg.name>tb-mqtt-transport</pkg.name>
38 38 <docker.name>tb-mqtt-transport</docker.name>
39 39 <pkg.user>thingsboard</pkg.user>
40   - <pkg.unixLogFolder>/var/log/${pkg.name}</pkg.unixLogFolder>
  40 + <pkg.logFolder>/var/log/${pkg.name}</pkg.logFolder>
41 41 <pkg.installFolder>/usr/share/${pkg.name}</pkg.installFolder>
42 42 </properties>
43 43
... ...