This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch docker
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git

commit a110fe5b3e3b459f037559c98e95146320808ecf
Author: benjobs <[email protected]>
AuthorDate: Mon Jul 15 18:29:31 2024 +0800

    [Improve] docker setting improvements
---
 .../streampark/console/core/service/impl/AppBuildPipeServiceImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
index b8c88e3fd..289353511 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/AppBuildPipeServiceImpl.java
@@ -356,7 +356,7 @@ public class AppBuildPipeServiceImpl
         log.info("Submit params to building pipeline : {}", 
k8sSessionBuildRequest);
         return FlinkK8sSessionBuildPipeline.of(k8sSessionBuildRequest);
       case KUBERNETES_NATIVE_APPLICATION:
-        DockerConfig dockerConfig = DockerConfig.fromSetting();
+        DockerConfig dockerConfig = settingService.getDockerConfig();
         FlinkK8sApplicationBuildRequest k8sApplicationBuildRequest =
             new FlinkK8sApplicationBuildRequest(
                 app.getJobName(),

Reply via email to