From f27deed2e87517e3863c716345460044ad79e728 Mon Sep 17 00:00:00 2001
From: Tony Li <lyt1999131@163.com>
Date: Tue, 7 Sep 2021 01:12:28 +0800
Subject: [PATCH] remove timestamp when requeuing Element (#7440)

Signed-off-by: xiayu.lyt <xiayu.lyt@alibaba-inc.com>
---
 internal/task/queue.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/task/queue.go b/internal/task/queue.go
index 3c6788409..ff6b20f62 100644
--- a/internal/task/queue.go
+++ b/internal/task/queue.go
@@ -118,7 +118,7 @@ func (t *Queue) worker() {
 		ts := time.Now().UnixNano()
 
 		item := key.(Element)
-		if t.lastSync > item.Timestamp {
+		if item.Timestamp != 0 && t.lastSync > item.Timestamp {
 			klog.V(3).InfoS("skipping sync", "key", item.Key, "last", t.lastSync, "now", item.Timestamp)
 			t.queue.Forget(key)
 			t.queue.Done(key)
@@ -130,7 +130,7 @@ func (t *Queue) worker() {
 			klog.ErrorS(err, "requeuing", "key", item.Key)
 			t.queue.AddRateLimited(Element{
 				Key:       item.Key,
-				Timestamp: time.Now().UnixNano(),
+				Timestamp: 0,
 			})
 		} else {
 			t.queue.Forget(key)