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 2023/11/07 10:18:43 UTC
(incubator-streampark) branch build created (now 6069e55e7)
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch build
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
at 6069e55e7 [Improve] release job bug fixed
This branch includes the following new commits:
new 6069e55e7 [Improve] release job bug fixed
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] release job bug fixed
Posted by be...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch build
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit 6069e55e7fc2e1f9822dc6235130152f89f27a20
Author: benjobs <be...@gmail.com>
AuthorDate: Tue Nov 7 18:18:30 2023 +0800
[Improve] release job bug fixed
---
.../console/core/service/impl/ApplicationServiceImpl.java | 11 +----------
1 file changed, 1 insertion(+), 10 deletions(-)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
index e23c12564..4587fc73d 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -704,16 +704,7 @@ public class ApplicationServiceImpl extends ServiceImpl<ApplicationMapper, Appli
ApiAlertException.throwIfNull(
appParam.getTeamId(), "The teamId can't be null. Create application failed.");
- if (appParam.isFlinkSqlJob()) {
- appParam.setBuild(true);
- } else {
- if (appParam.isUploadJob()) {
- appParam.setBuild(!appParam.getDependencyObject().isEmpty());
- } else {
- appParam.setBuild(false);
- }
- }
-
+ appParam.setBuild(true);
appParam.setUserId(commonService.getUserId());
appParam.setState(FlinkAppState.ADDED.getValue());
appParam.setRelease(ReleaseState.NEED_RELEASE.get());