diff --git a/ctl/import.go b/ctl/import.go index 4a744fbf1..5d2b2546f 100644 --- a/ctl/import.go +++ b/ctl/import.go @@ -114,8 +114,10 @@ func (cmd *ImportCommand) Run(ctx context.Context) error { if field.Name == cmd.Field { useRowKeys = field.Options.Keys fieldType = field.Options.Type + break } } + break } } diff --git a/http/client.go b/http/client.go index 5889f0589..e5c270cbb 100644 --- a/http/client.go +++ b/http/client.go @@ -352,7 +352,7 @@ func (c *InternalClient) ImportK(ctx context.Context, index, field string, bits } coord := getCoordinatorNode(nodes) if coord == nil { - return fmt.Errorf("could not find coordinator node") + return fmt.Errorf("could not find the coordinator node") } // Import to node.