fix: added missing return after error

tigrisdata-archive · Apr 25, 2022 · f26274a · f26274a
1 parent 46bfd14
commit f26274a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cdc/streamer.go b/cdc/streamer.go
@@ -61,6 +61,7 @@ func (s *Streamer) start() error {
 		for range s.ticker.C {
 			if err := s.read(); err != nil {
 				log.Err(err).Msg("read failed")
+				return
 			}
 		}
 	}()