From 4e49b82ff9169a959a8a8b2af7594a31252e0480 Mon Sep 17 00:00:00 2001 From: David Chen Date: Thu, 29 Mar 2018 16:52:39 +0800 Subject: [PATCH] add missing pd_addr for ImportRequest (#20) --- ingest/kv/kv-deliver.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ingest/kv/kv-deliver.go b/ingest/kv/kv-deliver.go index 0e57f866c3012..699362b230524 100644 --- a/ingest/kv/kv-deliver.go +++ b/ingest/kv/kv-deliver.go @@ -770,7 +770,7 @@ func (c *KVDeliverClient) callClose() error { func (c *KVDeliverClient) callImport() error { // TODO ... no matter what, to enusure available to import, call close first ! log.Infof("call import ...") - req := &importpb.ImportRequest{Uuid: c.txn.uuid.Bytes()} + req := &importpb.ImportRequest{Uuid: c.txn.uuid.Bytes(), PdAddr: c.pdAddr} _, err := c.cli.Import(c.ctx, req) log.Infof("finish call import !")