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 =