File tree Expand file tree Collapse file tree
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -93,11 +93,15 @@ public void start() {
9393 init ();
9494 int statInterval = Configuration .getInstance ().get (KEY_SOURCE_DB_STAT_INTERVAL ,
9595 DEFAULT_SOURCE_DB_STAT_INTERVAL );
96+
97+ int offset = Configuration .getInstance ().get (KEY_STAT_BACK_INITIAL_OFFSET ,
98+ DEFAULT_STAT_BACK_INITIAL_OFFSET );
99+
96100 if (sourceConfig .getAuditCycle () == DAY ) {
97101 statInterval = HOUR .getValue ();
102+ offset = 0 ;
98103 }
99- int offset = Configuration .getInstance ().get (KEY_STAT_BACK_INITIAL_OFFSET ,
100- DEFAULT_STAT_BACK_INITIAL_OFFSET );
104+
101105 for (int statBackTime = 0 ; statBackTime < sourceConfig .getStatBackTimes (); statBackTime ++) {
102106 ScheduledExecutorService timer =
103107 statTimers .computeIfAbsent (statBackTime , k -> Executors .newSingleThreadScheduledExecutor ());
You can’t perform that action at this time.
0 commit comments