From eea877ce4e27e1550db72bfff27588fa3c122a6e Mon Sep 17 00:00:00 2001 From: Metin Doslu Date: Thu, 24 Mar 2016 22:21:48 -0700 Subject: [PATCH] Remove unnecessary hash search --- src/backend/distributed/commands/multi_copy.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/backend/distributed/commands/multi_copy.c b/src/backend/distributed/commands/multi_copy.c index 4f18d806c..0c0e889bf 100644 --- a/src/backend/distributed/commands/multi_copy.c +++ b/src/backend/distributed/commands/multi_copy.c @@ -380,14 +380,15 @@ CitusCopyFrom(CopyStmt *copyStatement, char *completionTag) shardConnections = (ShardConnections *) hash_seq_search(&status); while (shardConnections != NULL) { + List *shardConnectionsList = list_copy(shardConnections->connectionList); + connectionList = list_concat(connectionList, shardConnectionsList); + BuildCopyBinaryFooters(copyOutState); SendCopyDataToPlacements(copyOutState->fe_msgbuf, shardConnections); shardConnections = (ShardConnections *) hash_seq_search(&status); } - connectionList = ConnectionList(shardConnectionHash); - EndRemoteCopy(connectionList, true); if (CopyTransactionManager == TRANSACTION_MANAGER_2PC)