adding some changes

pull/7643/head
paragjain 2024-07-04 10:21:23 +00:00
parent e3c64011d9
commit 9ff2fbdfb3
1 changed files with 2 additions and 3 deletions

View File

@ -1271,7 +1271,6 @@ ValidateAndReturnVarIfSupported(Node *entryExpr)
* ON clause and verifies if there is a join, either left or right, with * ON clause and verifies if there is a join, either left or right, with
* the distribution column of the given target. Once a match is found, it * the distribution column of the given target. Once a match is found, it
* returns the index of that match in the source's target list. * returns the index of that match in the source's target list.
*
*/ */
static int static int
SourceResultPartitionColumnIndex(Query *mergeQuery, List *sourceTargetList, SourceResultPartitionColumnIndex(Query *mergeQuery, List *sourceTargetList,
@ -1280,8 +1279,8 @@ SourceResultPartitionColumnIndex(Query *mergeQuery, List *sourceTargetList,
if (IsCitusTableType(targetRelation->relationId, SINGLE_SHARD_DISTRIBUTED)) if (IsCitusTableType(targetRelation->relationId, SINGLE_SHARD_DISTRIBUTED))
{ {
ereport(ERROR, (errmsg("MERGE operation across distributed schemas " ereport(ERROR, (errmsg("MERGE operation across distributed schemas "
"or with a row-based distributed table is " "or with a row-based distributed table is "
"not yet supported"))); "not yet supported")));
} }
/* Get all the Join conditions from the ON clause */ /* Get all the Join conditions from the ON clause */