diff --git a/server/ingester/ckissu/ckissu.go b/server/ingester/ckissu/ckissu.go index 275c9619d5a..2bcec8d97d7 100644 --- a/server/ingester/ckissu/ckissu.go +++ b/server/ingester/ckissu/ckissu.go @@ -892,7 +892,7 @@ func Query(connect *sql.DB, sql string) (*sql.Rows, error) { retryTimes := RETRY_COUNT for err != nil && retryTimes > 0 { log.Warningf("Query SQL (%s) failed: %s, will retry", sql, err) - time.Sleep(200 * time.Millisecond) + time.Sleep(100 * time.Millisecond) rows, err = connect.Query(sql) if err == nil { log.Infof("Retry query SQL (%s) success", sql) @@ -908,7 +908,7 @@ func Exec(connect *sql.DB, sql string) (sql.Result, error) { retryTimes := RETRY_COUNT for err != nil && retryTimes > 0 { log.Warningf("Exec SQL (%s) failed: %s, will retry", sql, err) - time.Sleep(time.Second) + time.Sleep(100 * time.Millisecond) result, err = connect.Exec(sql) if err == nil { log.Infof("Retry exec SQL (%s) success", sql)