From 5aa8de3ff822d96bf6741bbcd1d34b5f5acef376 Mon Sep 17 00:00:00 2001 From: linxiaotao Date: Wed, 17 Sep 2025 08:05:24 +0000 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0=E6=8F=92=E4=BB=B6?= =?UTF-8?q?=E5=81=9C=E6=AD=A2=E6=97=B6=E7=9A=84=E6=97=A5=E5=BF=97=E8=AE=B0?= =?UTF-8?q?=E5=BD=95=E5=8A=9F=E8=83=BD=EF=BC=8C=E4=BE=BF=E4=BA=8E=E8=B0=83?= =?UTF-8?q?=E8=AF=95=E5=92=8C=E7=9B=91=E6=8E=A7=E6=8F=92=E4=BB=B6=E7=8A=B6?= =?UTF-8?q?=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sqle/driver/plugin_adapter_v2.go | 2 ++ sqle/driver/plugin_manager.go | 1 + 2 files changed, 3 insertions(+) diff --git a/sqle/driver/plugin_adapter_v2.go b/sqle/driver/plugin_adapter_v2.go index 2be8592d44..96eafc7dae 100644 --- a/sqle/driver/plugin_adapter_v2.go +++ b/sqle/driver/plugin_adapter_v2.go @@ -167,7 +167,9 @@ func (d *PluginProcessorV2) Open(l *logrus.Entry, cfgV2 *driverV2.Config) (Plugi func (d *PluginProcessorV2) Stop() error { d.Lock() if d.client != nil { + log.NewEntry().Infof("stopping plugin %s", d.meta.PluginName) d.client.Kill() + log.NewEntry().Infof("plugin %s stopped", d.meta.PluginName) } os.Remove(d.pluginPidFilePath) d.Unlock() diff --git a/sqle/driver/plugin_manager.go b/sqle/driver/plugin_manager.go index c238e4fe32..f24f8d0776 100644 --- a/sqle/driver/plugin_manager.go +++ b/sqle/driver/plugin_manager.go @@ -253,6 +253,7 @@ func getJdkPath() string { } func (pm *pluginManager) Stop() { + log.NewEntry().Info("plugin manager is stopping") for name, pp := range pm.pluginProcessors { err := pp.Stop() if err != nil {