address comments

Signed-off-by: Neil Shen <overvenus@gmail.com>
pingcap · Jan 26, 2022 · 56a504a · 56a504a
1 parent dde4fbc
commit 56a504a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cdc/sink/mysql_params.go b/cdc/sink/mysql_params.go
@@ -119,7 +119,7 @@ func parseSinkURIToParams(ctx context.Context, sinkURI *url.URL, opts map[string
 		}
 		if c <= 0 {
 			return nil, cerror.WrapError(cerror.ErrMySQLInvalidConfig,
-				fmt.Errorf("invalid worker-count %d", c))
+				fmt.Errorf("invalid worker-count %d, which must be greater than 0", c))
 		}
 		if c > maxWorkerCount {
 			log.Warn("worker-count too large",
@@ -136,7 +136,7 @@ func parseSinkURIToParams(ctx context.Context, sinkURI *url.URL, opts map[string
 		}
 		if c <= 0 {
 			return nil, cerror.WrapError(cerror.ErrMySQLInvalidConfig,
-				fmt.Errorf("invalid max-txn-row %d", c))
+				fmt.Errorf("invalid max-txn-row %d, which must be greater than 0", c))
 		}
 		if c > maxMaxTxnRow {
 			log.Warn("max-txn-row too large",