From 2127be9a9af956ae8fe566e4fc326d1723d2699e Mon Sep 17 00:00:00 2001 From: Wei Fu Date: Tue, 2 Apr 2024 02:49:52 +0000 Subject: [PATCH 1/2] contrib: use total to align with ekswarmup Signed-off-by: Wei Fu --- contrib/cmd/runkperf/commands/bench/node100_job1_pod3k.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/contrib/cmd/runkperf/commands/bench/node100_job1_pod3k.go b/contrib/cmd/runkperf/commands/bench/node100_job1_pod3k.go index 0482933..e2d5bd0 100644 --- a/contrib/cmd/runkperf/commands/bench/node100_job1_pod3k.go +++ b/contrib/cmd/runkperf/commands/bench/node100_job1_pod3k.go @@ -25,7 +25,7 @@ that nodes. It repeats to create and delete job. The load profile is fixed. `, Flags: []cli.Flag{ cli.IntFlag{ - Name: "total-requests", + Name: "total", Usage: "Total requests per runner (There are 10 runners totally and runner's rate is 10)", Value: 36000, }, @@ -46,7 +46,7 @@ func benchNode100Job1Pod3KCaseRun(cliCtx *cli.Context) (*internaltypes.Benchmark rgCfgFile, rgCfgFileDone, err := utils.NewLoadProfileFromEmbed( "loadprofile/node100_job1_pod3k.yaml", func(spec *types.RunnerGroupSpec) error { - reqs := cliCtx.Int("total-requests") + reqs := cliCtx.Int("total") if reqs < 0 { return fmt.Errorf("invalid total-requests value: %v", reqs) } From 3bb0df2fb0c7160080da0406df6408a81ce9b7dd Mon Sep 17 00:00:00 2001 From: Wei Fu Date: Tue, 2 Apr 2024 03:12:09 +0000 Subject: [PATCH 2/2] contrib: should use host instead of host:port for fqdn Signed-off-by: Wei Fu --- contrib/internal/utils/kubectl_cmd.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/contrib/internal/utils/kubectl_cmd.go b/contrib/internal/utils/kubectl_cmd.go index d7e8eaf..612dee1 100644 --- a/contrib/internal/utils/kubectl_cmd.go +++ b/contrib/internal/utils/kubectl_cmd.go @@ -50,7 +50,8 @@ func (kr *KubectlRunner) FQDN(ctx context.Context, timeout time.Duration) (strin if err != nil { return "", err } - return strings.ToLower(fqdn.Host), nil + host := strings.Split(fqdn.Host, ":")[0] + return strings.ToLower(host), nil } // Metrics returns the metrics for a specific kube-apiserver.