diff --git a/src/backend/distributed/executor/multi_client_executor.c b/src/backend/distributed/executor/multi_client_executor.c index c3cb4edea..76c53de1e 100644 --- a/src/backend/distributed/executor/multi_client_executor.c +++ b/src/backend/distributed/executor/multi_client_executor.c @@ -140,7 +140,7 @@ MultiClientConnect(const char *nodeName, uint32 nodePort, const char *nodeDataba } else { - ReportRemoteError(connection, NULL); + ReportRemoteError(connection, NULL); PQfinish(connection); connectionId = INVALID_CONNECTION_ID; @@ -678,7 +678,7 @@ MultiClientCopyData(int32 connectionId, int32 fileDescriptor) /* received an error */ copyStatus = CLIENT_COPY_FAILED; - ReportRemoteError(connection, NULL); + ReportRemoteError(connection, NULL); } /* if copy out completed, make sure we drain all results from libpq */ diff --git a/src/backend/distributed/master/master_modify_multiple_shards.c b/src/backend/distributed/master/master_modify_multiple_shards.c index e4144e6b1..65aef5aa8 100644 --- a/src/backend/distributed/master/master_modify_multiple_shards.c +++ b/src/backend/distributed/master/master_modify_multiple_shards.c @@ -64,8 +64,8 @@ PG_FUNCTION_INFO_V1(master_modify_multiple_shards); /* - * master_modify_multiple_shards takes in a DELETE or UPDATE query string and - * pushes the query to shards. It finds shards that match the criteria defined + * master_modify_multiple_shards takes in a DELETE or UPDATE query string and + * pushes the query to shards. It finds shards that match the criteria defined * in the delete command, generates the same delete query string for each of the * found shards with distributed table name replaced with the shard name and * sends the queries to the workers. It uses one-phase or two-phase commit