hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Load dolphin for stream worker and apply worker.

Browse Source
This commit is contained in:
totaj
2023-03-16 20:37:40 +08:00
parent f836ac4165
commit 6f889ce80c
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/common/backend/utils/init/postinit.cpp
View File

@ -2238,6 +2238,10 @@ void PostgresInitializer::InitStreamSession()
InitExtensionVariable(); InitExtensionVariable();
FinishInit(); FinishInit();
#if (!defined(ENABLE_MULTIPLE_NODES)) && (!defined(ENABLE_PRIVATEGAUSS))
LoadSqlPlugin();
#endif
} }
void PostgresInitializer::InitSysCache() void PostgresInitializer::InitSysCache()

3
src/gausskernel/storage/replication/logical/worker.cpp
View File

@ -1511,6 +1511,9 @@ void ApplyWorkerMain()
t_thrd.proc_cxt.PostInit->InitApplyWorker(); t_thrd.proc_cxt.PostInit->InitApplyWorker();
pgstat_report_appname("ApplyWorker"); pgstat_report_appname("ApplyWorker");
pgstat_report_activity(STATE_IDLE, NULL); pgstat_report_activity(STATE_IDLE, NULL);
#if (!defined(ENABLE_MULTIPLE_NODES)) && (!defined(ENABLE_PRIVATEGAUSS))
LoadSqlPlugin();
#endif
/* Load the subscription into persistent memory context. */ /* Load the subscription into persistent memory context. */
t_thrd.applyworker_cxt.applyContext = t_thrd.applyworker_cxt.applyContext =