add missing pd_addr for ImportRequest (pingcap#20)

YuJuncen · Mar 29, 2018 · 4e49b82 · 4e49b82
1 parent 5def97a
commit 4e49b82
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 !")