Fix: insert registry when existAckOffset is zero (#671)

Co-authored-by: tianyafei <tianyafei@corp.netease.com>
loggie-io · Apr 8, 2024 · ec6c447 · ec6c447
1 parent 31bec67
commit ec6c447
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/source/file/watch.go b/pkg/source/file/watch.go
@@ -319,8 +319,10 @@ func (w *Watcher) eventBus(e jobEvent) {
 			}
 		}
 		// Pre-allocation offset
-		if e.job.task.config.ReadFromTail {
-			existAckOffset = fileSize
+		if existAckOffset == 0 || e.job.task.config.ReadFromTail {
+			if e.job.task.config.ReadFromTail {
+				existAckOffset = fileSize
+			}
 			w.preAllocationOffset(existAckOffset, job)
 		}
 		// set ack offset