diff --git a/src/backend/distributed/executor/local_executor.c b/src/backend/distributed/executor/local_executor.c index 5b06b415a..0239e179e 100644 --- a/src/backend/distributed/executor/local_executor.c +++ b/src/backend/distributed/executor/local_executor.c @@ -437,6 +437,8 @@ LocallyExecuteUtilityTask(Task *task) PG_END_TRY(); InLocalQueryOnShard = prevInLocalQueryOnShard; + if (InLocalQueryOnShard > 0 ) elog(WARNING, "InLocalQueryOnShard: %d", InLocalQueryOnShard); + } @@ -657,7 +659,7 @@ LocallyExecuteTaskPlan(PlannedStmt *taskPlan, char *queryString, PG_END_TRY(); InLocalQueryOnShard = prevInLocalQueryOnShard; - +if (InLocalQueryOnShard > 0 ) elog(WARNING, "InLocalQueryOnShard: %d", InLocalQueryOnShard); return processedRows; }