perf: speed up the update of ClickHouse table structure

deepflowio · Aug 8, 2024 · 67bc401 · 67bc401
1 parent d3a3df2
commit 67bc401
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)