This is an automated email from the ASF dual-hosted git repository. jiashuo pushed a commit to branch add-table-migrator in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
commit de077099aa3a0981e716684207720a72fc2c1077 Author: jiashuo <[email protected]> AuthorDate: Wed Jun 15 19:09:22 2022 +0800 update --- admin-cli/cmd/duplication.go | 4 ++-- admin-cli/executor/duplication.go | 4 ++-- admin-cli/executor/toolkits/tablemigrator/migrator.go | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/admin-cli/cmd/duplication.go b/admin-cli/cmd/duplication.go index 253ff863..91a17d43 100644 --- a/admin-cli/cmd/duplication.go +++ b/admin-cli/cmd/duplication.go @@ -49,11 +49,11 @@ func init() { if c.Flags.String("cluster") == "" { return fmt.Errorf("cluster cannot be empty") } - return executor.AddDuplication(pegasusClient, c.UseTable, c.Flags.String("cluster"), c.Flags.Bool("freezed")) + return executor.AddDuplication(pegasusClient, c.UseTable, c.Flags.String("cluster"), c.Flags.Bool("sst")) }), Flags: func(f *grumble.Flags) { f.String("c", "cluster", "", "the destination where the source data is duplicated") - f.Bool("f", "freezed", false, "whether to freeze replica GC when duplication created") + f.Bool("s", "sst", false, "whether to duplicate sst file") }, }) rootCmd.AddCommand(&grumble.Command{ diff --git a/admin-cli/executor/duplication.go b/admin-cli/executor/duplication.go index e6ccc4e2..619caa44 100644 --- a/admin-cli/executor/duplication.go +++ b/admin-cli/executor/duplication.go @@ -39,8 +39,8 @@ func QueryDuplication(c *Client, tableName string) error { } // AddDuplication command -func AddDuplication(c *Client, tableName string, remoteCluster string, freezed bool) error { - resp, err := c.Meta.AddDuplication(tableName, remoteCluster, freezed) +func AddDuplication(c *Client, tableName string, remoteCluster string, sst bool) error { + resp, err := c.Meta.AddDuplication(tableName, remoteCluster, sst) if err != nil { return err } diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go index 33e39fbe..ab7e5039 100644 --- a/admin-cli/executor/toolkits/tablemigrator/migrator.go +++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go @@ -22,7 +22,7 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string } //2. create table duplication - err = executor.AddDuplication(client, table, targetCluster, false) + err = executor.AddDuplication(client, table, targetCluster, true) if err != nil { return err } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
