From 0e29d3c8cb4d113a3f9276ceefcecc8bef8b3f10 Mon Sep 17 00:00:00 2001 From: Jun Wang Date: Wed, 20 Nov 2024 17:24:30 -0800 Subject: [PATCH] add flags in ./go/flags/endtoend/vttablet.txt Signed-off-by: Jun Wang --- go/flags/endtoend/vttablet.txt | 1 + go/vt/vttablet/tabletserver/tabletenv/config.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/go/flags/endtoend/vttablet.txt b/go/flags/endtoend/vttablet.txt index 8be7b620469..836023121a7 100644 --- a/go/flags/endtoend/vttablet.txt +++ b/go/flags/endtoend/vttablet.txt @@ -88,6 +88,7 @@ Flags: --config-type string Config file type (omit to infer config type from file extension). --consolidator-stream-query-size int Configure the stream consolidator query size in bytes. Setting to 0 disables the stream consolidator. (default 2097152) --consolidator-stream-total-size int Configure the stream consolidator total size in bytes. Setting to 0 disables the stream consolidator. (default 134217728) + --consolidator-max-query-wait int Configure the max wait size per query for consolidator. --consul_auth_static_file string JSON File to read the topos/tokens from. --datadog-agent-host string host to send spans to. if empty, no tracing will be done --datadog-agent-port string port to send spans to. if empty, no tracing will be done diff --git a/go/vt/vttablet/tabletserver/tabletenv/config.go b/go/vt/vttablet/tabletserver/tabletenv/config.go index 67792cfa5c1..e5dbab29e2b 100644 --- a/go/vt/vttablet/tabletserver/tabletenv/config.go +++ b/go/vt/vttablet/tabletserver/tabletenv/config.go @@ -190,7 +190,7 @@ func registerTabletEnvFlags(fs *pflag.FlagSet) { flagutil.DualFormatBoolVar(fs, &enableConsolidatorReplicas, "enable_consolidator_replicas", false, "This option enables the query consolidator only on replicas.") fs.Int64Var(¤tConfig.ConsolidatorStreamQuerySize, "consolidator-stream-query-size", defaultConfig.ConsolidatorStreamQuerySize, "Configure the stream consolidator query size in bytes. Setting to 0 disables the stream consolidator.") fs.Int64Var(¤tConfig.ConsolidatorStreamTotalSize, "consolidator-stream-total-size", defaultConfig.ConsolidatorStreamTotalSize, "Configure the stream consolidator total size in bytes. Setting to 0 disables the stream consolidator.") - fs.Int64Var(¤tConfig.ConsolidatorMaxQueryWait, "consolidator-max-query-wait", defaultConfig.ConsolidatorMaxQueryWait, "Configure the max wait size per query of consolidator.") + fs.Int64Var(¤tConfig.ConsolidatorMaxQueryWait, "consolidator-max-query-wait", defaultConfig.ConsolidatorMaxQueryWait, "Configure the max wait size per query for consolidator.") fs.DurationVar(&healthCheckInterval, "health_check_interval", defaultConfig.Healthcheck.Interval, "Interval between health checks") fs.DurationVar(°radedThreshold, "degraded_threshold", defaultConfig.Healthcheck.DegradedThreshold, "replication lag after which a replica is considered degraded")