[DSIP-68] Unify the table structure and table fields in backend and frontend ui sections#16544
[DSIP-68] Unify the table structure and table fields in backend and frontend ui sections#16544SbloodyS merged 36 commits intoapache:devfrom
Conversation
...er-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessServiceImpl.java
Fixed
Show fixed
Hide fixed
| * @return | ||
| */ | ||
| String timeFunctionExtension(Integer processInstanceId, String timeZone, String placeholderName); | ||
| String timeFunctionExtension(Integer workflowInstanceId, String timeZone, String placeholderName); |
Check notice
Code scanning / CodeQL
Useless parameter
| * @return | ||
| */ | ||
| String timeFunctionExtension(Integer processInstanceId, String timeZone, String placeholderName); | ||
| String timeFunctionExtension(Integer workflowInstanceId, String timeZone, String placeholderName); |
Check notice
Code scanning / CodeQL
Useless parameter
| * @return | ||
| */ | ||
| String timeFunctionExtension(Integer processInstanceId, String timeZone, String placeholderName); | ||
| String timeFunctionExtension(Integer workflowInstanceId, String timeZone, String placeholderName); |
Check notice
Code scanning / CodeQL
Useless parameter
1d68dba to
7ffe0ef
Compare
| for (String strProcessInstanceId : processInstanceIdArray) { | ||
| int processInstanceId = Integer.parseInt(strProcessInstanceId); | ||
| for (String strWorkflowInstanceId : workflowInstanceIdArray) { | ||
| int workflowInstanceId = Integer.parseInt(strWorkflowInstanceId); |
Check notice
Code scanning / CodeQL
Missing catch of NumberFormatException
| execService.controlWorkflowInstance(loginUser, processInstanceId, executeType); | ||
| log.info("Success do action {} on workflowInstance: {}", executeType, processInstanceId); | ||
| execService.controlWorkflowInstance(loginUser, workflowInstanceId, executeType); | ||
| log.info("Success do action {} on workflowInstance: {}", executeType, workflowInstanceId); |
Check failure
Code scanning / CodeQL
Log Injection
| errorMessage.add("Failed do action " + executeType + " on workflowInstance: " + workflowInstanceId | ||
| + "reason: " + e.getMessage()); | ||
| log.error("Failed do action {} on workflowInstance: {}, error: {}", executeType, processInstanceId, e); | ||
| log.error("Failed do action {} on workflowInstance: {}, error: {}", executeType, workflowInstanceId, e); |
Check failure
Code scanning / CodeQL
Log Injection
| for (String strProcessInstanceId : processInstanceIdArray) { | ||
| int processInstanceId = Integer.parseInt(strProcessInstanceId); | ||
| for (String strWorkflowInstanceId : workflowInstanceIdArray) { | ||
| int workflowInstanceId = Integer.parseInt(strWorkflowInstanceId); |
Check notice
Code scanning / CodeQL
Missing catch of NumberFormatException
| workflowInstanceService.deleteWorkflowInstanceById(loginUser, workflowInstanceId); | ||
| } catch (Exception e) { | ||
| log.error("Delete workflow instance: {} error", strProcessInstanceId, e); | ||
| log.error("Delete workflow instance: {} error", strWorkflowInstanceId, e); |
Check failure
Code scanning / CodeQL
Log Injection
| import lombok.Data; | ||
| import lombok.EqualsAndHashCode; | ||
|
|
||
| @EqualsAndHashCode(callSuper = true) |
Check notice
Code scanning / CodeQL
Missing Override annotation
| /** | ||
| * task instance request | ||
| */ | ||
| @EqualsAndHashCode(callSuper = true) |
Check notice
Code scanning / CodeQL
Missing Override annotation
8686e31 to
6b50d70
Compare
zhongjiajie
left a comment
There was a problem hiding this comment.
Great 👍 , only have one issue I am not sure
|
|
||
| UPDATE t_ds_task_definition SET task_type = 'SUB_WORKFLOW' WHERE task_type = 'SUB_PROCESS'; | ||
| UPDATE t_ds_task_definition_log SET task_type = 'SUB_WORKFLOW' WHERE task_type = 'SUB_PROCESS'; | ||
| UPDATE t_ds_task_definition SET task_params = replace(task_params, 'processDefinitionCode', 'workflowDefinitionCode') where task_type = 'SUB_WORKFLOW'; |
There was a problem hiding this comment.
Also need to upgrade t_ds_task_definition_log.
And Dynamic task need to upgrade too.
|
|
||
| UPDATE t_ds_task_definition SET task_type = 'SUB_WORKFLOW' WHERE task_type = 'SUB_PROCESS'; | ||
| UPDATE t_ds_task_definition_log SET task_type = 'SUB_WORKFLOW' WHERE task_type = 'SUB_PROCESS'; | ||
| UPDATE t_ds_task_definition SET task_params = replace(task_params, 'processDefinitionCode', 'workflowDefinitionCode') where task_type = 'SUB_WORKFLOW'; |
|


Purpose of the pull request
Brief change log
close #16515
close #16525
@DisableIfTestFailsannotation toe2e-testandapi-testto the test class, all tests after the first failed one are disabled for better debugging. JunitVerify this pull request
This pull request is code cleanup without any test coverage.
(or)
This pull request is already covered by existing tests, such as (please describe tests).
(or)
This change added tests and can be verified as follows:
(or)
Pull Request Notice
Pull Request Notice
If your pull request contain incompatible change, you should also add it to
docs/docs/en/guide/upgrede/incompatible.md