diff --git a/pkg/server/events.go b/pkg/server/events.go
index ba83db384..80d221a45 100644
--- a/pkg/server/events.go
+++ b/pkg/server/events.go
@@ -58,10 +58,11 @@ func (c *criContainerdService) startEventMonitor() {
 			b.Reset()
 			// TODO(random-liu): Relist to recover state, should prevent other operations
 			// until state is fully recovered.
-			if err := c.handleEventStream(events); err != nil {
-				glog.Errorf("Failed to handle event stream: %v", err)
-				time.Sleep(b.Duration())
-				continue
+			for {
+				if err := c.handleEventStream(events); err != nil {
+					glog.Errorf("Failed to handle event stream: %v", err)
+					break
+				}
 			}
 		}
 	}()