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

w

remote_prepared_txes_imp
Onder Kalaci 2022-11-18 09:37:03 +01:00
parent 3f2f37daba
commit f449209398
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/executor/adaptive_executor.c
View File

@ -852,8 +852,8 @@ AdaptiveExecutor(CitusScanState *scanState)
*/ */
if (paramListInfo && !paramListInfo->paramFetch) if (paramListInfo && !paramListInfo->paramFetch)
{ {
paramListInfo = copyParamList(paramListInfo); //paramListInfo = copyParamList(paramListInfo);
MarkUnreferencedExternParams((Node *) job->jobQuery, paramListInfo); //MarkUnreferencedExternParams((Node *) job->jobQuery, paramListInfo);
} }
DistributedExecution *execution = CreateDistributedExecution( DistributedExecution *execution = CreateDistributedExecution(

2
src/backend/distributed/executor/citus_custom_scan.c
View File

@ -333,7 +333,7 @@ CitusBeginReadOnlyScan(CustomScanState *node, EState *estate, int eflags)
SetTaskQueryString(task, fastPathPlanCache->queryString); SetTaskQueryString(task, fastPathPlanCache->queryString);
/* TODO: we have this due to MarkUnreferencedExternParams. Can we find another way? */ /* TODO: we have this due to MarkUnreferencedExternParams. Can we find another way? */
workerJob->jobQuery = copyObject(originalDistributedPlan->workerJob->jobQuery); //workerJob->jobQuery = copyObject(originalDistributedPlan->workerJob->jobQuery);
} }
} }