From be77d3304f930208aaa342bddce6bf9660eebdeb Mon Sep 17 00:00:00 2001 From: Marco Slot Date: Mon, 3 Feb 2020 11:59:55 +0100 Subject: [PATCH] Fixup --- src/backend/distributed/connection/placement_connection.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/backend/distributed/connection/placement_connection.c b/src/backend/distributed/connection/placement_connection.c index 2a6f59683..f92a93831 100644 --- a/src/backend/distributed/connection/placement_connection.c +++ b/src/backend/distributed/connection/placement_connection.c @@ -593,11 +593,12 @@ FindPlacementListConnection(int flags, List *placementAccessList, const char *us } } else if (accessType == PLACEMENT_ACCESS_SELECT && - placementEntry->hasSecondaryConnections) + placementEntry->hasSecondaryConnections && + !placementConnection->hadDDL && !placementConnection->hadDML) { /* - * Two separate connections have already selected from this placements. - * There is no benefit to using this connection. + * Two separate connections have already selected from this placement + * and it was not modified. There is no benefit to using this connection. */ } else if (CanUseExistingConnection(flags, userName, placementConnection))