|
@ -41,7 +41,7 @@ func (c *commandEcDecode) Do(args []string, commandEnv *CommandEnv, writer io.Wr |
|
|
encodeCommand := flag.NewFlagSet(c.Name(), flag.ContinueOnError) |
|
|
encodeCommand := flag.NewFlagSet(c.Name(), flag.ContinueOnError) |
|
|
volumeId := encodeCommand.Int("volumeId", 0, "the volume id") |
|
|
volumeId := encodeCommand.Int("volumeId", 0, "the volume id") |
|
|
collection := encodeCommand.String("collection", "", "the collection name") |
|
|
collection := encodeCommand.String("collection", "", "the collection name") |
|
|
applyChanges := encodeCommand.Bool("force", false, "force the encoding even if the cluster has less than recommended 4 nodes") |
|
|
|
|
|
|
|
|
forceChanges := encodeCommand.Bool("force", false, "force the encoding even if the cluster has less than recommended 4 nodes") |
|
|
if err = encodeCommand.Parse(args); err != nil { |
|
|
if err = encodeCommand.Parse(args); err != nil { |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
@ -58,7 +58,7 @@ func (c *commandEcDecode) Do(args []string, commandEnv *CommandEnv, writer io.Wr |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
if !*applyChanges { |
|
|
|
|
|
|
|
|
if !*forceChanges { |
|
|
var nodeCount int |
|
|
var nodeCount int |
|
|
eachDataNode(topologyInfo, func(dc string, rack RackId, dn *master_pb.DataNodeInfo) { |
|
|
eachDataNode(topologyInfo, func(dc string, rack RackId, dn *master_pb.DataNodeInfo) { |
|
|
nodeCount++ |
|
|
nodeCount++ |
|
|