Merge branch 'release-4.2502.x' of https://github.com/actiontech/sqle into release-4.2502.x

Author: actions-user

sqle/driver/plugin_manager.go

@@ -192,6 +192,7 @@ func (pm *pluginManager) Start(pluginDir string, pluginConfigList []config.Plugi
 		log.NewEntry().Warnf("stop residual plugin file path walk error: %v", err)
 	}
 	wg.Wait()
+	jdkPath := getJdkPath()
 
 	// register plugin
 	for _, p := range plugins {
@@ -205,9 +206,8 @@ func (pm *pluginManager) Start(pluginDir string, pluginConfigList []config.Plugi
 				break
 			}
 		}
-
 		if len(cmdArgs) == 0 && strings.HasSuffix(p.Name(), ".jar") {
-			javaPluginCmd := fmt.Sprintf("$SQLE_JAVA_HOME/bin/java -jar %s", cmdBase)
+			javaPluginCmd := fmt.Sprintf("%s/bin/java -jar %s", jdkPath, cmdBase)
 			cmdBase = "sh"
 			cmdArgs = append(cmdArgs, "-c", javaPluginCmd)
 		}
@@ -242,6 +242,16 @@ func (pm *pluginManager) Start(pluginDir string, pluginConfigList []config.Plugi
 	return nil
 }
 
+func getJdkPath() string {
+	nowDir, err := os.Getwd()
+	if err != nil {
+		log.NewEntry().Errorf("failed to get directory: %v", err)
+		return ""
+	}
+	jdkPath := filepath.Join(nowDir, "jdk")
+	return jdkPath
+}
+
 func (pm *pluginManager) Stop() {
 	for name, pp := range pm.pluginProcessors {
 		err := pp.Stop()