diff --git a/internal/pkg/config/monitor.go b/internal/pkg/config/monitor.go index e88e8e09a..d93837878 100644 --- a/internal/pkg/config/monitor.go +++ b/internal/pkg/config/monitor.go @@ -8,7 +8,7 @@ import "time" const ( defaultFetchSize = 1000 - defaultPollTimeout = 5 * time.Minute + defaultPollTimeout = 4 * time.Minute ) type Monitor struct { diff --git a/internal/pkg/monitor/monitor.go b/internal/pkg/monitor/monitor.go index e109f83ee..8bd4ee27c 100644 --- a/internal/pkg/monitor/monitor.go +++ b/internal/pkg/monitor/monitor.go @@ -24,7 +24,7 @@ import ( ) const ( - defaultPollTimeout = 5 * time.Minute // default long poll timeout + defaultPollTimeout = 4 * time.Minute // default long poll timeout defaultSeqNo = int64(-1) // the _seq_no in elasticsearch start with 0 defaultWithExpiration = false @@ -244,7 +244,7 @@ func (m *simpleMonitorT) Run(ctx context.Context) (err error) { continue } else { // Log the error and keep trying - m.log.Error().Err(err).Msg("failed on waiting for global checkpoints advance") + m.log.Info().Err(err).Msg("failed on waiting for global checkpoints advance") } // Delay next attempt