You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by ji...@apache.org on 2022/06/16 07:34:00 UTC
[incubator-pegasus] 05/25: update
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 <js...@live.com>
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: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org