@@ -192,6 +192,7 @@ func (pm *pluginManager) Start(pluginDir string, pluginConfigList []config.Plugi
192
192
log .NewEntry ().Warnf ("stop residual plugin file path walk error: %v" , err )
193
193
}
194
194
wg .Wait ()
195
+ jdkPath := getJdkPath ()
195
196
196
197
// register plugin
197
198
for _ , p := range plugins {
@@ -205,9 +206,8 @@ func (pm *pluginManager) Start(pluginDir string, pluginConfigList []config.Plugi
205
206
break
206
207
}
207
208
}
208
-
209
209
if len (cmdArgs ) == 0 && strings .HasSuffix (p .Name (), ".jar" ) {
210
- javaPluginCmd := fmt .Sprintf ("$SQLE_JAVA_HOME /bin/java -jar %s" , cmdBase )
210
+ javaPluginCmd := fmt .Sprintf ("%s /bin/java -jar %s" , jdkPath , cmdBase )
211
211
cmdBase = "sh"
212
212
cmdArgs = append (cmdArgs , "-c" , javaPluginCmd )
213
213
}
@@ -242,6 +242,16 @@ func (pm *pluginManager) Start(pluginDir string, pluginConfigList []config.Plugi
242
242
return nil
243
243
}
244
244
245
+ func getJdkPath () string {
246
+ nowDir , err := os .Getwd ()
247
+ if err != nil {
248
+ log .NewEntry ().Errorf ("failed to get directory: %v" , err )
249
+ return ""
250
+ }
251
+ jdkPath := filepath .Join (nowDir , "jdk" )
252
+ return jdkPath
253
+ }
254
+
245
255
func (pm * pluginManager ) Stop () {
246
256
for name , pp := range pm .pluginProcessors {
247
257
err := pp .Stop ()
0 commit comments