diff --git a/internal/pkg/report/reporter.go b/internal/pkg/report/reporter.go
index a386a432..45bc08dd 100644
--- a/internal/pkg/report/reporter.go
+++ b/internal/pkg/report/reporter.go
@@ -310,7 +310,7 @@ func (r *Reporter) ReportLog(noMore bool) error {
 	r.logOffset = ack
 	r.stateMu.Unlock()
 
-	if noMore && ack < r.logOffset+len(rows) {
+	if noMore && len(r.logRows) > 0 {
 		return NewErrRetry(errRetrySendAll, len(r.logRows))
 	}