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

Use EnsureCompatibleLocalExecutionState instead (#5640)

pull/5630/head
Onur Tirtir 2022-01-21 17:37:59 +03:00 committed by GitHub
parent a2b05f0d28
commit 4dc38e9e3d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1028,12 +1028,7 @@ ExecuteTaskListExtended(ExecutionParams *executionParams)
* then we should error out as it would cause inconsistencies across the
* remote connection and local execution.
*/
List *remoteTaskList = execution->remoteTaskList;
if (GetCurrentLocalExecutionStatus() == LOCAL_EXECUTION_REQUIRED &&
AnyTaskAccessesLocalNode(remoteTaskList))
{
ErrorIfTransactionAccessedPlacementsLocally();
}
EnsureCompatibleLocalExecutionState(execution->remoteTaskList);
/* run the remote execution */
StartDistributedExecution(execution);

3
src/backend/distributed/executor/repartition_join_execution.c
View File

@ -50,7 +50,6 @@ static void TraverseJobTree(Job *curJob, List **jobs);
static char * GenerateCreateSchemasCommand(List *jobIds, char *schemaOwner);
static char * GenerateJobCommands(List *jobIds, char *templateCommand);
static char * GenerateDeleteJobsCommand(List *jobIds);
static void EnsureCompatibleLocalExecutionState(List *taskList);
/*
@ -79,7 +78,7 @@ ExecuteDependentTasks(List *topLevelTasks, Job *topLevelJob)
* EnsureCompatibleLocalExecutionState makes sure that the tasks won't have
* any visibility problems because of local execution.
*/
static void
void
EnsureCompatibleLocalExecutionState(List *taskList)
{
/*

1
src/include/distributed/repartition_join_execution.h
View File

@ -13,6 +13,7 @@
#include "nodes/pg_list.h"
extern List * ExecuteDependentTasks(List *taskList, Job *topLevelJob);
extern void EnsureCompatibleLocalExecutionState(List *taskList);
extern void DoRepartitionCleanup(List *jobIds);