From 1a18fa5cb1d199dc554b095add485aeea97abdb7 Mon Sep 17 00:00:00 2001 From: totaj Date: Thu, 16 Mar 2023 20:37:40 +0800 Subject: [PATCH] fixed 6f889ce from https://gitee.com/totaj/openGauss-server/pulls/3169 Load dolphin for stream worker and apply worker. --- src/common/backend/utils/init/postinit.cpp | 4 ++++ src/gausskernel/storage/replication/logical/worker.cpp | 3 +++ 2 files changed, 7 insertions(+) diff --git a/src/common/backend/utils/init/postinit.cpp b/src/common/backend/utils/init/postinit.cpp index 553cc2443..21879be30 100644 --- a/src/common/backend/utils/init/postinit.cpp +++ b/src/common/backend/utils/init/postinit.cpp @@ -2238,6 +2238,10 @@ void PostgresInitializer::InitStreamSession() InitExtensionVariable(); FinishInit(); + +#if (!defined(ENABLE_MULTIPLE_NODES)) && (!defined(ENABLE_PRIVATEGAUSS)) + LoadSqlPlugin(); +#endif } void PostgresInitializer::InitSysCache() diff --git a/src/gausskernel/storage/replication/logical/worker.cpp b/src/gausskernel/storage/replication/logical/worker.cpp index 85118c51b..9e754cf00 100644 --- a/src/gausskernel/storage/replication/logical/worker.cpp +++ b/src/gausskernel/storage/replication/logical/worker.cpp @@ -1511,6 +1511,9 @@ void ApplyWorkerMain() t_thrd.proc_cxt.PostInit->InitApplyWorker(); pgstat_report_appname("ApplyWorker"); pgstat_report_activity(STATE_IDLE, NULL); +#if (!defined(ENABLE_MULTIPLE_NODES)) && (!defined(ENABLE_PRIVATEGAUSS)) + LoadSqlPlugin(); +#endif /* Load the subscription into persistent memory context. */ t_thrd.applyworker_cxt.applyContext =