summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/backend/access/transam/parallel.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/backend/access/transam/parallel.c b/src/backend/access/transam/parallel.c
index a47eba647b..3c0da2e1e0 100644
--- a/src/backend/access/transam/parallel.c
+++ b/src/backend/access/transam/parallel.c
@@ -1008,6 +1008,11 @@ ParallelWorkerMain(Datum main_arg)
BackgroundWorkerInitializeConnectionByOid(fps->database_id,
fps->authenticated_user_id);
+ StartTransactionCommand();
+ /* Initialize XL executor. This must be done inside a transaction block. */
+ InitMultinodeExecutor(false);
+ CommitTransactionCommand();
+
/*
* Set the client encoding to the database encoding, since that is what
* the leader will expect.