Fix selectForUpdate bug

pull/2606/head
Onder Kalaci 2019-02-21 18:21:41 +03:00
parent f144bb4911
commit 407d0e30f5
1 changed files with 3 additions and 7 deletions

View File

@ -213,14 +213,10 @@ FastPathRouterQuery(Query *query)
* hasForUpdate is tricky because Citus does support only when
* replication = 1 or reference tables.
*/
if (query->hasForUpdate)
if (query->hasForUpdate &&
!(cacheEntry->partitionMethod == DISTRIBUTE_BY_NONE ||
SingleReplicatedTable(distributedTableId)))
{
if (cacheEntry->partitionMethod == DISTRIBUTE_BY_NONE ||
SingleReplicatedTable(distributedTableId))
{
return true;
}
return false;
}