adding some changes

pull/7643/head
paragjain 2024-07-04 10:16:57 +00:00
parent a9dcd729e7
commit 315af1ddcb
1 changed files with 3 additions and 1 deletions

View File

@ -1281,7 +1281,9 @@ SourceResultPartitionColumnIndex(Query *mergeQuery, List *sourceTargetList,
{ {
if (IsCitusTableType(targetRelation->relationId, SINGLE_SHARD_DISTRIBUTED)) if (IsCitusTableType(targetRelation->relationId, SINGLE_SHARD_DISTRIBUTED))
{ {
return -1; ereport(ERROR, (errmsg("MERGE operation across distributed schemas "
"or with a row-based distributed table is "
"not yet supported")));
} }
/* Get all the Join conditions from the ON clause */ /* Get all the Join conditions from the ON clause */