diff --git a/inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source/JdbcSource.java b/inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source/JdbcSource.java index 72492031e63..2e51d5fef35 100644 --- a/inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source/JdbcSource.java +++ b/inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source/JdbcSource.java @@ -93,11 +93,15 @@ public void start() { init(); int statInterval = Configuration.getInstance().get(KEY_SOURCE_DB_STAT_INTERVAL, DEFAULT_SOURCE_DB_STAT_INTERVAL); + + int offset = Configuration.getInstance().get(KEY_STAT_BACK_INITIAL_OFFSET, + DEFAULT_STAT_BACK_INITIAL_OFFSET); + if (sourceConfig.getAuditCycle() == DAY) { statInterval = HOUR.getValue(); + offset = 0; } - int offset = Configuration.getInstance().get(KEY_STAT_BACK_INITIAL_OFFSET, - DEFAULT_STAT_BACK_INITIAL_OFFSET); + for (int statBackTime = 0; statBackTime < sourceConfig.getStatBackTimes(); statBackTime++) { ScheduledExecutorService timer = statTimers.computeIfAbsent(statBackTime, k -> Executors.newSingleThreadScheduledExecutor());