You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/07/15 10:29:44 UTC

(incubator-streampark) branch docker created (now a110fe5b3)

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

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


      at a110fe5b3 [Improve] docker setting improvements

This branch includes the following new commits:

     new a110fe5b3 [Improve] docker setting improvements

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



(incubator-streampark) 01/01: [Improve] docker setting improvements

Posted by be...@apache.org.
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 <be...@gmail.com>
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(),