fix code review

WeDataSphere · Sep 19, 2023 · 3df68f3 · 3df68f3
1 parent 67756f4
commit 3df68f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala b/.../main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala
@@ -245,7 +245,7 @@ class FlinkEngineConnFactory extends MultiExecutorEngineConnFactory with Logging
   protected def getExtractJavaOpts(envJavaOpts: String): String = {
     var defaultJavaOpts = ""
     val yamlFilePath = FLINK_CONF_DIR.getValue
-    val yamlFile = yamlFilePath + FLINK_CONF_YAML.getHotValue()
+    val yamlFile = yamlFilePath + "/" + FLINK_CONF_YAML.getHotValue()
     if (new File(yamlFile).exists()) {
       val source = Source.fromFile(yamlFile)
       try {