external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

some more

pull/7626/head
paragjain 2024-06-14 04:35:58 +00:00 committed by Teja Mupparti
parent 493140287a
commit 06e9c29950
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/backend/distributed/planner/merge_planner.c
View File

@ -1123,6 +1123,7 @@ DeferErrorIfRoutableMergeNotSupported(Query *query, List *rangeTableList,
* However, before proceeding with this delegation, we need to confirm that the user is utilizing * However, before proceeding with this delegation, we need to confirm that the user is utilizing
* the distribution column of the source table in the Insert variable. * the distribution column of the source table in the Insert variable.
* If this is not the case, we should refrain from pushing down the query. * If this is not the case, we should refrain from pushing down the query.
* This is just a deffered error which will be handle by caller.
*/ */
Var *insertVar = Var *insertVar =
@ -1131,10 +1132,10 @@ DeferErrorIfRoutableMergeNotSupported(Query *query, List *rangeTableList,
!IsDistributionColumnInMergeSource((Expr *) insertVar, query, true)) !IsDistributionColumnInMergeSource((Expr *) insertVar, query, true))
{ {
ereport(DEBUG1, (errmsg( ereport(DEBUG1, (errmsg(
"MERGE INSERT must use the source table distribution column value, try repartitioning"))); "MERGE INSERT must use the source table distribution column value for push down to workers. Otherwise, repartitioning will be applied")));
return DeferredError(ERRCODE_FEATURE_NOT_SUPPORTED, return DeferredError(ERRCODE_FEATURE_NOT_SUPPORTED,
"MERGE INSERT must use the source table " "MERGE INSERT must use the source table distribution column value for push down to workers. Otherwise, repartitioning will be applied",
"distribution column value", NULL, NULL); NULL, NULL);
} }
return NULL; return NULL;
} }