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 <[email protected]> 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());
