Skip to content

Commit

Permalink
Keep config names constant across (#101)
Browse files Browse the repository at this point in the history
  • Loading branch information
lrao100 authored Sep 16, 2019
1 parent 3ef97cb commit 013789b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/controller/flink/client/error_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ type RetryHandlerInterface interface {
// A Retryer that has methods to determine if an error is retryable and also does exponential backoff
type RetryHandler struct {
baseBackOffDuration time.Duration
maxErrWaitDuration time.Duration
maxErrDuration time.Duration
maxBackOffMillisDuration time.Duration
}

Expand Down Expand Up @@ -95,7 +95,7 @@ func (r RetryHandler) IsRetryRemaining(err error, retryCount int32) bool {

func (r RetryHandler) WaitOnError(clock clock.Clock, lastUpdatedTime time.Time) (time.Duration, bool) {
elapsedTime := clock.Since(lastUpdatedTime)
return elapsedTime, elapsedTime <= r.maxErrWaitDuration
return elapsedTime, elapsedTime <= r.maxErrDuration

}
func (r RetryHandler) GetRetryDelay(retryCount int32) time.Duration {
Expand Down

0 comments on commit 013789b

Please sign in to comment.