Browse Source
Merge pull request #8357 from volodymyr-babak/fix-edge-event-cleanup
Typo - fixed startup of edge event clean up service
pull/8369/head
Andrew Shvayka
3 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with
4 additions and
4 deletions
-
application/src/main/java/org/thingsboard/server/service/ttl/EdgeEventsCleanUpService.java
-
dao/src/main/java/org/thingsboard/server/dao/sql/edge/JpaBaseEdgeEventDao.java
|
|
|
@ -32,7 +32,7 @@ import static org.thingsboard.server.dao.model.ModelConstants.EDGE_EVENT_COLUMN_ |
|
|
|
@TbCoreComponent |
|
|
|
@Slf4j |
|
|
|
@Service |
|
|
|
@ConditionalOnExpression("${sql.ttl.edge_events.enabled:true} && ${sql.ttl.edge_events.edge_event_ttl:0} > 0") |
|
|
|
@ConditionalOnExpression("${sql.ttl.edge_events.enabled:true} && ${sql.ttl.edge_events.edge_events_ttl:0} > 0") |
|
|
|
public class EdgeEventsCleanUpService extends AbstractCleanUpService { |
|
|
|
|
|
|
|
public static final String RANDOM_DELAY_INTERVAL_MS_EXPRESSION = |
|
|
|
|
|
|
|
@ -80,11 +80,11 @@ public class JpaBaseEdgeEventDao extends JpaAbstractSearchTextDao<EdgeEventEntit |
|
|
|
@Value("${sql.edge_events.stats_print_interval_ms:10000}") |
|
|
|
private long statsPrintIntervalMs; |
|
|
|
|
|
|
|
@Value("${sql.edge_events.partitions_size:168}") |
|
|
|
@Value("${sql.edge_events.partition_size:168}") |
|
|
|
private int partitionSizeInHours; |
|
|
|
|
|
|
|
@Value("${sql.ttl.edge_events.edge_events_ttl:2628000}") |
|
|
|
private long edge_events_ttl; |
|
|
|
private long edgeEventsTtl; |
|
|
|
|
|
|
|
private static final String TABLE_NAME = ModelConstants.EDGE_EVENT_COLUMN_FAMILY_NAME; |
|
|
|
|
|
|
|
@ -203,7 +203,7 @@ public class JpaBaseEdgeEventDao extends JpaAbstractSearchTextDao<EdgeEventEntit |
|
|
|
|
|
|
|
@Override |
|
|
|
public void migrateEdgeEvents() { |
|
|
|
long startTime = edge_events_ttl > 0 ? System.currentTimeMillis() - TimeUnit.SECONDS.toMillis(edge_events_ttl) : 1629158400000L; |
|
|
|
long startTime = edgeEventsTtl > 0 ? System.currentTimeMillis() - TimeUnit.SECONDS.toMillis(edgeEventsTtl) : 1629158400000L; |
|
|
|
|
|
|
|
long currentTime = System.currentTimeMillis(); |
|
|
|
var partitionStepInMs = TimeUnit.HOURS.toMillis(partitionSizeInHours); |
|
|
|
|