From ec6c44733d03d84c2ab812ecff64e41b1626bac8 Mon Sep 17 00:00:00 2001 From: 08fly <79070936+08fly@users.noreply.github.com> Date: Mon, 8 Apr 2024 14:38:42 +0800 Subject: [PATCH] Fix: insert registry when existAckOffset is zero (#671) Co-authored-by: tianyafei --- pkg/source/file/watch.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/source/file/watch.go b/pkg/source/file/watch.go index 6e8fe5b3b..f7c5007df 100644 --- 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