print plan replayer error instead throw it (#160)

* fix * fix
pingcap · Feb 2, 2023 · ba96e1e · ba96e1e
1 parent 97009c9
commit ba96e1e
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/ch/workload.go b/ch/workload.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"database/sql"
 	"fmt"
+	"os"
 	"sort"
 	"strings"
 	"time"
@@ -219,7 +220,7 @@ func (w *Workloader) Run(ctx context.Context, threadID int) error {
 	if w.cfg.EnablePlanReplayer && w.cfg.Driver == "mysql" {
 		err := w.dumpPlanReplayer(ctx, s, query, queryName)
 		if err != nil {
-			return err
+			fmt.Fprintf(os.Stderr, "dump query %s plan replayer failed %v", queryName, err)
 		}
 	}
 

diff --git a/rawsql/workload.go b/rawsql/workload.go
@@ -106,7 +106,7 @@ func (w *Workloader) Run(ctx context.Context, threadID int) error {
 	if w.cfg.EnablePlanReplayer {
 		err := w.dumpPlanReplayer(ctx, s, query, queryName)
 		if err != nil {
-			return err
+			fmt.Fprintf(os.Stderr, "dump query %s plan replayer failed %v", queryName, err)
 		}
 	}
 

diff --git a/tpch/workload.go b/tpch/workload.go
@@ -234,7 +234,7 @@ func (w *Workloader) Run(ctx context.Context, threadID int) error {
 	if w.cfg.EnablePlanReplayer && w.cfg.Driver == "mysql" {
 		err := w.dumpPlanReplayer(ctx, s, query, queryName)
 		if err != nil {
-			return err
+			fmt.Fprintf(os.Stderr, "dump query %s plan replayer failed %v", queryName, err)
 		}
 	}