Skip to content

Commit

Permalink
Reduce the monitor long poll timeout to 4 minutes by default (#306) (#…
Browse files Browse the repository at this point in the history
…307)

(cherry picked from commit e19463d)

Co-authored-by: Aleksandr Maus <[email protected]>
  • Loading branch information
mergify[bot] and aleksmaus authored Apr 30, 2021
1 parent eb0e26a commit 994dd6b
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion internal/pkg/config/monitor.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import "time"

const (
defaultFetchSize = 1000
defaultPollTimeout = 5 * time.Minute
defaultPollTimeout = 4 * time.Minute
)

type Monitor struct {
Expand Down
4 changes: 2 additions & 2 deletions internal/pkg/monitor/monitor.go
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 994dd6b

Please sign in to comment.