From 6f889ce80cb86d76b385055c920abd6a841e18ae Mon Sep 17 00:00:00 2001 From: totaj Date: Thu, 16 Mar 2023 20:37:40 +0800 Subject: [PATCH] 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 f8fdc985d..1cc9aafb2 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 =