From 56c471d0da26ef6540abcb29ef96ce0f2cb3e974 Mon Sep 17 00:00:00 2001 From: jiangpengcheng Date: Wed, 17 Jul 2024 10:27:56 +0800 Subject: [PATCH] Use default tenant and namespace when updating sink without specifying them --- pkg/ctl/sinks/update.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/ctl/sinks/update.go b/pkg/ctl/sinks/update.go index 85ed933e..6109d0bb 100644 --- a/pkg/ctl/sinks/update.go +++ b/pkg/ctl/sinks/update.go @@ -341,7 +341,7 @@ func doUpdateSink(vc *cmdutils.VerbCmd, sinkData *util.SinkData) error { admin := cmdutils.NewPulsarClientWithAPIVersion(config.V3) - latestConfig, err := admin.Sinks().GetSink(sinkData.Tenant, sinkData.Namespace, sinkData.Name) + latestConfig, err := admin.Sinks().GetSink(sinkData.SinkConf.Tenant, sinkData.SinkConf.Namespace, sinkData.Name) if err != nil { return err }