Skip to content
This repository was archived by the owner on Dec 9, 2024. It is now read-only.

Commit 2725790

Browse files
authored
extend the tiflash sync wait time (#232)
Signed-off-by: yeya24 <yb532204897@gmail.com>
1 parent 9958038 commit 2725790

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/pocket/executor/common.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ func (e *Executor) createTiFlashTableReplica(table string) error {
136136
func (e *Executor) WaitTiFlashTableSync(table string) error {
137137
sql := fmt.Sprintf("SELECT AVAILABLE FROM information_schema.tiflash_replica WHERE TABLE_SCHEMA = '%s' and TABLE_NAME = '%s'",
138138
e.dbname, table)
139-
if err := wait.Poll(1*time.Second, 10*time.Second, func() (bool, error) {
139+
if err := wait.Poll(1*time.Second, 30*time.Second, func() (bool, error) {
140140
res, err := e.GetConn().Select(sql)
141141
if err != nil {
142142
return false, err

0 commit comments

Comments
 (0)