Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion go/cmd/vtcombo/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ var (
mysqlPort = flag.Int("mysql_port", 3306, "mysql port")
externalTopoServer = flag.Bool("external_topo_server", false, "Should vtcombo use an external topology server instead of starting its own in-memory topology server. "+
"If true, vtcombo will use the flags defined in topo/server.go to open topo server")
plannerVersion = flag.String("planner-version", "gen4", "Sets the default planner to use when the session has not changed it. Valid values are: V3, Gen4, Gen4Greedy and Gen4Fallback. Gen4Fallback tries the gen4 planner and falls back to the V3 planner if the gen4 fails.")
plannerVersion = flag.String("planner-version", "", "Sets the default planner to use when the session has not changed it. Valid values are: V3, Gen4, Gen4Greedy and Gen4Fallback. Gen4Fallback tries the gen4 planner and falls back to the V3 planner if the gen4 fails.")
plannerVersionDeprecated = flag.String("planner_version", "", "Deprecated flag. Use planner-version instead")

tpb vttestpb.VTTestTopology
Expand Down
22 changes: 11 additions & 11 deletions go/cmd/vtexplain/vtexplain.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ var (
normalize = flag.Bool("normalize", false, "Whether to enable vtgate normalization")
outputMode = flag.String("output-mode", "text", "Output in human-friendly text or json")
dbName = flag.String("dbname", "", "Optional database target to override normal routing")
plannerVersionStr = flag.String("planner-version", "gen4", "Sets the query planner version to use when generating the explain output. Valid values are V3 and Gen4")
plannerVersionStr = flag.String("planner-version", "", "Sets the query planner version to use when generating the explain output. Valid values are V3 and Gen4")
badPlannerVersion = flag.String("planner_version", "", "Deprecated flag. Use planner-version instead")

// vtexplainFlags lists all the flags that should show in usage
Expand Down Expand Up @@ -129,34 +129,34 @@ func main() {
}

func parseAndRun() error {
sql, err := getFileParam(*sqlFlag, *sqlFileFlag, "sql", true)
verStr, err := env.CheckPlannerVersionFlag(plannerVersionStr, badPlannerVersion)
if err != nil {
return err
}

schema, err := getFileParam(*schemaFlag, *schemaFileFlag, "schema", true)
if err != nil {
return err
plannerVersion, _ := plancontext.PlannerNameToVersion(verStr)
if plannerVersion != querypb.ExecuteOptions_V3 && plannerVersion != querypb.ExecuteOptions_Gen4 {
return fmt.Errorf("invalid value specified for planner-version of '%s' -- valid values are V3 and Gen4", *plannerVersionStr)
}

vschema, err := getFileParam(*vschemaFlag, *vschemaFileFlag, "vschema", true)
sql, err := getFileParam(*sqlFlag, *sqlFileFlag, "sql", true)
if err != nil {
return err
}

ksShardMap, err := getFileParam(*ksShardMapFlag, *ksShardMapFileFlag, "ks-shard-map", false)
schema, err := getFileParam(*schemaFlag, *schemaFileFlag, "schema", true)
if err != nil {
return err
}

verStr, err := env.CheckPlannerVersionFlag(plannerVersionStr, badPlannerVersion)
vschema, err := getFileParam(*vschemaFlag, *vschemaFileFlag, "vschema", true)
if err != nil {
return err
}

plannerVersion, _ := plancontext.PlannerNameToVersion(verStr)
if plannerVersion != querypb.ExecuteOptions_V3 && plannerVersion != querypb.ExecuteOptions_Gen4 {
return fmt.Errorf("invalid value specified for planner-version of '%s' -- valid values are V3 and Gen4", *plannerVersionStr)
ksShardMap, err := getFileParam(*ksShardMapFlag, *ksShardMapFileFlag, "ks-shard-map", false)
if err != nil {
return err
}

opts := &vtexplain.Options{
Expand Down
2 changes: 1 addition & 1 deletion go/cmd/vtgate/vtgate.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ import (
var (
cell = flag.String("cell", "test_nj", "cell to use")
tabletTypesToWait = flag.String("tablet_types_to_wait", "", "wait till connected for specified tablet types during Gateway initialization")
plannerVersion = flag.String("planner-version", "gen4", "Sets the default planner to use when the session has not changed it. Valid values are: V3, Gen4, Gen4Greedy and Gen4Fallback. Gen4Fallback tries the gen4 planner and falls back to the V3 planner if the gen4 fails.")
plannerVersion = flag.String("planner-version", "", "Sets the default planner to use when the session has not changed it. Valid values are: V3, Gen4, Gen4Greedy and Gen4Fallback. Gen4Fallback tries the gen4 planner and falls back to the V3 planner if the gen4 fails.")
plannerVersionDeprecated = flag.String("planner_version", "", "Deprecated flag. Use planner-version instead")
)

Expand Down
2 changes: 1 addition & 1 deletion go/cmd/vttestserver/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,7 @@ func init() {

flag.StringVar(&config.Charset, "charset", "utf8mb4", "MySQL charset")

flag.StringVar(&config.PlannerVersion, "planner-version", "gen4", "Sets the default planner to use when the session has not changed it. Valid values are: V3, Gen4, Gen4Greedy and Gen4Fallback. Gen4Fallback tries the new gen4 planner and falls back to the V3 planner if the gen4 fails.")
flag.StringVar(&config.PlannerVersion, "planner-version", "", "Sets the default planner to use when the session has not changed it. Valid values are: V3, Gen4, Gen4Greedy and Gen4Fallback. Gen4Fallback tries the new gen4 planner and falls back to the V3 planner if the gen4 fails.")
flag.StringVar(&config.PlannerVersionDeprecated, "planner_version", "", "planner_version is deprecated. Please use planner-version instead")

flag.StringVar(&config.SnapshotFile, "snapshot_file", "",
Expand Down
Loading