sandiegoe
21ca8ddf03
[fix-13734] Fix taskExecuteType field of task definition was not set correctly ( #13735 )
...
Co-authored-by: shenzhaoquan <shenzhaoquan@shenqingtech.com>
2023-03-27 10:50:01 +08:00
Wenjun Ruan
0bfd7d66d9
db: Modify name len to 255 ( #13788 )
2023-03-24 09:40:09 +08:00
Aaron Wang
8895921d87
[Improvement-13651] Remove useless resources_task ( #13721 )
2023-03-23 22:52:23 +08:00
陈家名
c2d5774790
[Improvement] SQL optimization queryTheHighestPriorityTasks ( #13671 )
...
Co-authored-by: chenjiaming <chenjiaming@kezaihui.com>
2023-03-05 22:35:24 +08:00
Wenjun Ruan
4351a25f2a
Add execute function to handle the workflow instance operation ( #13610 )
2023-02-24 13:47:41 +08:00
fuchanghai
c406f81e9c
[improve-#13597] fix the method name ( #13599 )
2023-02-22 10:53:51 +08:00
Wenjun Ruan
133d1733eb
Alter title in t_ds_alert to 512 ( #13535 )
2023-02-09 09:41:07 +08:00
seedscoder
8d12dc0702
[Improvement-13491] Use lombok @Slf4j annotation to generate logger ( #13509 )
2023-02-07 20:32:53 +08:00
Stalary
b9ef4a7177
FIX: qrtz table use uppercase ( #13494 )
...
* FIX: use uppercase
2023-02-02 11:25:27 +08:00
Stalary
5fb6035f0d
fix: 3.1.1_schema mysql ddl sql error ( #13485 )
2023-02-01 21:11:05 +08:00
Wenjun Ruan
af9091a98a
Use convert to set the exist column collate to utf8_bin ( #13479 )
2023-02-01 18:40:18 +08:00
Wenjun Ruan
d10eaa8d81
Change mysql COLLATE to utf8_bin ( #13469 )
2023-02-01 14:08:31 +08:00
Wenjun Ruan
713fdbc444
Split the upgrade code ( #13436 )
...
1. Split the upgrade code into different version
2. Log the dml/ddl sql in origin friendly format
3. Fix ddl of 3.0.0 and 3.1.0
4. Fix search resource regular expression injection
2023-01-20 20:48:07 +08:00
qianli2022
8be32d4145
[Feature][Api] When use api to run a process we want get processInstanceId ( #13184 )
...
* add sql
* add mapper
* add dao
* add excutor
Co-authored-by: qianl4 <qianl4@cicso.com>
2023-01-18 17:58:32 +08:00
jackfanwan
8439b5dc69
[fix-12721] Fix cannot modify the upstream task in task definition page. ( #12722 )
2023-01-15 19:58:47 +08:00
Wenjun Ruan
483330273d
Remove entity in QueryWrapper constructor ( #13396 )
2023-01-14 20:57:03 +08:00
Wenjun Ruan
98dfd64444
Clear the task group data when delete a project/workflowInstance ( #13383 )
2023-01-12 21:51:51 +08:00
calvin
4f73fe1bd8
fix this issue with missing a comma in the TaskInstanceMapper.xml ( #13359 )
2023-01-09 14:43:34 +08:00
Kerwin
fde2c8073e
Fix that when the timing data is not configured with environmental information, the timing management does not display the data. ( #13339 )
2023-01-05 12:15:02 +08:00
Wenjun Ruan
a074f7e2e6
Delete workflow will delete workflow instance ( #13336 )
2023-01-04 22:22:03 +08:00
Aaron Wang
ccad56e88e
[Improvement][Master] Validate same content of input file when using task cache ( #13298 )
...
* support file content checksum
* fix inject null storageOperate bug
2023-01-03 11:38:13 +08:00
Wenjun Ruan
8a479927f3
Add projectCode in t_ds_process_instance and t_ds_task_instance to remove join ( #13284 )
2023-01-03 09:52:28 +08:00
陈家名
5077fa6aae
[Improvement][dao] Optimized countInstanceStateByProjectCodes ( #13273 )
2022-12-28 14:31:21 +08:00
Jay Chung
6627c38be5
[fix][dml] Also query workflow without tenant by given name ( #13075 )
...
before this, once remove user tenant, all users workflow
can not be found anymore, this patch fix this problem, make
this entrypoint can query workflow without tenant to its
users
2022-12-28 14:14:29 +08:00
Wenjun Ruan
fd3afd84ad
Remove alert when delete workflow instance ( #13281 )
2022-12-28 11:40:12 +08:00
XCL
a75a69f3ec
[Improvement][api]Start the downstream workflow when it is online ( #13257 )
...
Start the downstream workflow when it is online
2022-12-26 11:58:37 +08:00
Wenjun Ruan
04785dc799
Add mybatis in mysql registry module ( #13275 )
2022-12-26 11:09:25 +08:00
陈家名
8870464c02
[Improvement][api] Optimize batch query in process-list interface ( #13222 )
...
Co-authored-by: chenjiaming <chenjiaming@kezaihui.com>
2022-12-23 23:33:42 +08:00
calvin
a98cae7065
[Fix-13260][API] Ironed out the issue with lacking the value of user's name when querying the list of workflow definitions. ( #13261 )
...
* fix the issue with lacking user name
2022-12-23 19:22:08 +08:00
calvin
a235d3cd6a
[Improvement][UI] Support to display extra columns such as 'Worker Group' and 'Environment Name' on the page of cron manage. ( #13267 )
2022-12-23 15:24:59 +08:00
calvin
915bdf481d
fix the issue with throwing the sql exception ( #13231 )
2022-12-20 17:54:47 +08:00
陈家名
7643d2840a
[Improvement][api-sql] Optimize the sql for paging query project ( #13172 )
...
* Optimizing sql
* add version join condition
Co-authored-by: chenjiaming <chenjiaming@kezaihui.com>
2022-12-19 08:51:21 +08:00
JieguangZhou
66e20271ad
[Feature][Master] Add task caching mechanism to improve the running speed of repetitive tasks ( #13194 )
...
* Supports task instance cache operation
* add task plugin cache
* use SHA-256 to generate key
* Update dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql
Co-authored-by: Jay Chung <zhongjiajie955@gmail.com>
* Update dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
Co-authored-by: Jay Chung <zhongjiajie955@gmail.com>
* Optimizing database Scripts
* Optimize clear cache operation
Co-authored-by: Jay Chung <zhongjiajie955@gmail.com>
2022-12-18 18:17:09 +08:00
insist777
631e3a81d1
[Feature][API] New restful API for taskInstance ( #13070 )
2022-12-14 14:47:36 +08:00
JieguangZhou
e4b9b67255
Allow execute task in workflow instance ( #13103 )
2022-12-13 16:43:44 +08:00
Wenjun Ruan
f5801a0e1c
Fix task group might be rob by multiple task ( #13115 )
2022-12-11 22:58:21 +08:00
Yann Ann
6ef74073cc
[Improve-13001]migrate commons-collections -> commons-collections4 ( #13002 )
2022-12-10 23:50:19 +08:00
Wenjun Ruan
66b8a81ad8
Revert "Update dolphinscheduler_ddl.sql ( #13081 )" ( #13117 )
...
This reverts commit fa3e2a5e1a .
2022-12-07 10:14:28 +08:00
jackfanwan
cb8d125e0f
[Improvement] optimization task definition & fix in the task definition list, if one task have more pre task, the task list can't show all task ( #13106 )
...
* fix in the task definition list, if one task have more pre task, the task list can't show all task
* modify code style
* in the task definition, delete search workflow name filter, and fix in the task definition list, if one task have more pre task, the task list can't show all task
* modify code style
* modify code style
* delete useless select sql
* add annotation
Co-authored-by: fanwanlong <fanwanlong@kezaihui.com>
2022-12-07 09:52:53 +08:00
Eric Gao
d9f43adafd
Prevent default alert group from binding alert plugin instances with id 1 and 2 automatically ( #13114 )
2022-12-06 23:10:48 +08:00
Wenjun Ruan
8a152aebc7
Fix task log file might not be clear ( #13102 )
2022-12-06 11:23:20 +08:00
Wenjun Ruan
fed1e85fb8
Fix the invalidate task instance never be deleted ( #13091 )
2022-12-04 18:38:54 +08:00
darkz
fa3e2a5e1a
Update dolphinscheduler_ddl.sql ( #13081 )
...
https://github.com/apache/dolphinscheduler/pull/12826
for this pr
2022-12-03 22:11:08 +08:00
Jay Chung
f5a59982b3
[fix] Python gateway can not upload to resource center ( #13042 )
...
in #12076 we refactor our resource center, remove the resource table,
it is a good refactor but it failed python api upload, this patch try
to fix python api upload function
ref: #12076
2022-12-02 10:11:57 +08:00
insist777
1064680ded
[feat][API] New restful API for workflow state ( #13031 )
2022-12-01 14:21:01 +08:00
insist777
a0eb45b9e4
[Feature][API] New restful API for workflowInstance ( #12990 )
2022-11-28 12:58:46 +08:00
Kerwin
f9a0ecbc81
[Bug-12997][API] Fix that the end time is not reset when the workflow instance reruns. ( #12998 )
...
* Fix that the end time is not reset when the workflow instance reruns.
2022-11-27 15:08:30 +08:00
rickchengx
43719f7c15
[Improvement-12763][UT] Improve testListAuthorizedProjects() in ProjectMapperTest ( #12768 )
2022-11-27 13:15:38 +08:00
rickchengx
7336afaa65
[Fix-12916] Add permission check when query or download log ( #12917 )
2022-11-25 17:59:28 +08:00
Kerwin
31021730ec
The task instance list is sorted by submission time ( #12974 )
2022-11-24 18:59:53 +08:00
Wenjun Ruan
d99ba29b66
Fix master cluster may loop command unbalanced ( #12891 )
...
(cherry picked from commit 3b2b86661be76b7c1404a910c865d78b7936313d)
2022-11-16 10:20:22 +08:00
Guanhua Li
83f9588eb0
[Improvement-12856][UT] Refactor duplicated code fragment in UdfFuncMapperTest ( #12857 )
2022-11-15 22:59:11 +08:00
Kerwin
713046b043
Modify the table t_ds_worker_group to add a description field in the postgresql upgrade script ( #12883 )
2022-11-15 17:26:41 +08:00
rickchengx
7c711e622f
[Improvement-12850][UT] Improve the ut of DataSourceMapperTest ( #12851 )
2022-11-12 23:57:40 +08:00
jackfanwan
f249f2b257
[fix-12675]edit workflow related task, workflow's task version change ( #12692 )
...
* edit workflow related task, workflow's task version change
* Update dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/enums/Status.java
Co-authored-by: fanwanlong <fanwanlong@kezaihui.com>
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2022-11-06 20:49:07 +08:00
jackfanwan
913525343e
modify sql error ( #12717 )
2022-11-05 21:44:01 +08:00
jackfanwan
7d0e2cbbb9
when delete workflow, delete related task ( #12681 )
...
* when delete workflow, delete related task
Co-authored-by: fanwanlong <fanwanlong@kezaihui.com>
2022-11-04 14:40:15 +08:00
ZhenjiLiu
7cdb926a5f
[Improvement][Batch Query] Batch query ProcessDefinitions belongs to need failover ProcessInstance. ( #12506 )
2022-11-03 09:15:19 +08:00
Yiming Guo
dc8d18cf87
[Feature-12040][api][ui] Add authorization management of read and write permissions for project center ( #12048 )
...
[Feature-12040][api][ui] Add authorization management of read and write permissions for project center
2022-10-27 18:01:51 +08:00
Tq
4b4d0b92a3
[FIX][DAO-12277] change t_ds_fav_task column task_name to task_type and related code ( #12276 )
...
* change t_ds_fav_task column task_name to task_type and related code
* change task_name to task_type
* change FavTask taskName to taskType, taskType to taskCategory
Co-authored-by: labbomb <739955946@qq.com>
2022-10-27 09:36:26 +08:00
HanayoZz
489e7fe4e2
[Feature-10495][Resource Center] Resource Center Refactor ( #12076 )
...
* resource center refactor - S3 services connection
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2022-10-26 13:53:44 +08:00
Hengdong Gong
3030419ee1
[fix](dolphinscheduler-dao) fix upgrade to 3.1.0 sql missing field ( #12314 ) ( #12315 )
2022-10-26 12:32:05 +08:00
Yann Ann
04aa125ba2
[Refactor]migrate some task dao functions from ProcessServiceImpl to dao modules. ( #12505 )
...
* migrate some task DAO to dao modules.
* Update dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/repository/impl/ProcessInstanceMapDaoImpl.java
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2022-10-26 11:51:58 +08:00
陈家名
97a0771f21
[fix][sql] Add unique key to process_definition_log avoid TooManyResultExpection ( #12503 )
...
* Add unique key to t_ds_process_definition_log
2022-10-25 14:20:37 +08:00
caishunfeng
dedff70f90
[Improvement] Merge spi.utils into common.utils ( #12502 )
...
* improve JSONUtil
* merge spi.utils into common.utils
* split constants && remove some copy utils method
* remove StringUtils
2022-10-23 21:23:54 +08:00
Wenjun Ruan
b5193ee4e5
Remove equals in User to fix UT ( #12487 )
2022-10-22 08:59:10 +08:00
Kerwin
1436ad65fc
[Bug-12410] [API]Fix the worker list result in workflow definition only has default ( #12411 )
...
* Fix the worker list result in workflow definition only has default
* Fix tenant, k8s namespace similar permission issues.
* code clean in the k8s namespace mapper
* delete redundant sql method
2022-10-21 13:54:28 +08:00
Eric Gao
d46e4659d9
[Improvement][Style] Fix remaining style errors and wildcard imports ( #12412 )
...
* Fix remaining style errors and wildcard imports
* Upgrade spotless to the latest stable version, exclude .github folder from spotless check and fix dead link
* Fix spotless matching scope of markdown files
2022-10-19 11:08:04 +08:00
Kerwin
c02e08bb3d
[BUG-12396][Schedule] Fixed that the workflow definition scheduling that has been online after the version upgrade does not execute ( #12397 )
...
* Fixed that the workflow definition scheduling that has been online after the version upgrade does not execute.
2022-10-17 19:45:39 +08:00
fuchanghai
22103f975e
[improvement] Migrate all UT cases from jUnit4 to jUnit5 in dao module ( #12328 )
...
* [improvement] Migrate all UT cases from jUnit4 to jUnit5 in dao module
Co-authored-by: Jackie <‘2875334588@qq.com’>
2022-10-13 15:26:39 +08:00
kezhenxu94
db1d319159
Reorganize some classes in common module, remove duplicate classes ( #12321 )
2022-10-13 10:23:27 +08:00
Yann Ann
17cd644506
[Fix-#11669][Workflow Instance Page] Fix the duration in Workflow Instance page. ( #12264 )
...
* fix process duration issue
* use processInstance.getState().isFinished() replace new isFinish function
* add WorkflowUtils
2022-10-13 09:50:31 +08:00
Jiajie Zhong
0e1c8d8153
[Feature][API] New restful API task and task relation ( #12116 )
2022-10-13 09:41:03 +08:00
jegger
04e1b88c1c
[fix] Fix error problem on h2 startup data quality rule management page ( #12108 )
...
Co-authored-by: jegger <zhangbq3306@163.com>
2022-10-11 16:52:35 +08:00
Ivan
98a8b5383e
[ fix : #11590 ][upgrade] Fix the bugs when I upgrade ds from v1.3.9 to v3.0.0 ,such as file cannot be found or column not found etc ( #11619 )
...
* fix the bugs which upgrade ds metabase from v1.3.9 to v3.0.0 with mysql
* [Fix-11590][upgrade] Fix the bugs when I upgrade ds from v1.3.9 to v3.0.0 ,such as file cannot be found or column not found etc
* fix : #11590 add process_instance_code_state_index with table t_ds_process_instance to improve query efficiency for the method of findLastProcessInterval
* Fix the bug that cannot find the files when upgrade ds version with postgresql
Co-authored-by: fan.wang <fan.wang@jiduauto.com>
2022-10-11 10:20:05 +08:00
Yann Ann
60c43d5d32
just add WorkerGroupMapper UT ( #12242 )
2022-10-06 20:10:48 +08:00
Yann Ann
3c4f9380d1
just correct wrong word ( #12174 )
2022-10-05 17:08:48 +08:00
fuchanghai
e27c79974d
[fix-#11753] send alert error alert data id ( #11774 )
...
* [fix-#11753] send alert error alert data id
Co-authored-by: fuchanghai <changhai.fu@marketingforce.com>
2022-09-29 15:34:40 +08:00
caishunfeng
151c2d2c70
fix upgrade sql ( #12141 )
2022-09-26 15:21:52 +08:00
labbomb
64f4cb4f3e
refactor: dag-menu refactor ( #11965 )
...
* refactor: dag-menu refactor
* feat: add i18n support for the dag-menu
* feat: add e2e class
Co-authored-by: devosend <devosend@gmail.com>
Co-authored-by: Tq <tianqitobethefirst@gmail.com>
2022-09-26 11:06:39 +08:00
Jiajie Zhong
82ddd72e4a
[Feature][API] New restful API for workflow and schedule ( #11912 )
...
* [feat] New restful API for workflow and schedule
CURD for workflow and schedule, different with exists
API, this new restful api only operate single resource
in each request, and return the latest. For example,
previous workflow should also need to post tasks definition
and tasks relation definition, but this patch will allow
you to create workflow without task relate information
* use checkProjectAndAuthThrowException, and fix CI error
* Update dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/ScheduleV2Controller.java
* change method name
from createProcessDefinitionV2 to createSingleProcessDefinition
from updateProcessDefinitionV2 to updateSingleProcessDefinition
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2022-09-23 22:25:19 +08:00
rickchengx
08a4c7981f
[improve] Remove the spark version of spark task ( #11860 )
2022-09-21 20:27:28 +08:00
limaiwang
ed1d1e8856
add(dependent node's add unprivileged project list): dependent node's add unprivileged project list ( #12073 )
2022-09-21 09:28:22 +08:00
juzimao
c8884e4f2f
and task instance date range search ( #11963 )
2022-09-19 17:50:24 +08:00
insist777
5b384f3fab
[Feature-11473][Task]Support test task ( #11670 )
...
* [improve] support test tasks
* [improve] support test tasks
* [improve] support test tasks
* [improve] support test tasks
* [improve] support test tasks
* Update TaskExecuteThread.java
* try solve e2e q
* try solve e2e q
* try solve e2e q
* try solve e2e q
* try solve e2e q
* try solve e2e q
* try solve e2e q
* try solve e2e q
* try solve e2e q
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* Update DataSource.java
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* Update messages_zh_CN.properties
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* Update messages.properties
* Update messages_en_US.properties
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
* [Feature] support test tasks
2022-09-17 13:40:56 +08:00
Wenjun Ruan
864a90820d
Fix insertOrUpdate plugin may failed due to concurrent operation ( #11471 )
2022-09-16 15:39:04 +08:00
Wenjun Ruan
d833a28b2e
Fix cannot save processDefinition ( #11931 )
2022-09-16 13:54:18 +08:00
Wenjun Ruan
4ad34483a5
Fix alert_send_status may throw duplicate key exception and add limit for query alert ( #11953 )
2022-09-16 13:26:33 +08:00
caishunfeng
925e2fa551
[Bug][Workflow Definition] fix ordinary users can not create depend task ( #11961 )
2022-09-16 09:12:33 +08:00
wendongdi
e70c501f9a
[Fix][db] fix init&upgrade mysql-meta-schema bugs ( #11887 )
2022-09-14 18:03:07 +08:00
juzimao
b1068e27ba
Optimize date range condition ( #11911 )
2022-09-14 16:55:10 +08:00
Wenjun Ruan
8a47785f42
Fix listing processDefinition the schedulerReleaseState will never be null ( #11888 )
2022-09-13 10:07:12 +08:00
Yann Ann
e20f17a7b7
[Improvement-#11768][Monitor] Support monitor h2 database in monitor page ( #11813 )
2022-09-09 09:43:56 +08:00
Stalary
37325b4c34
[Bug](dependent) Dependent downstream trigger error when schedule cycle not day. ( #11734 )
...
* FIX: dependent
* FIX: version
* MOD: for review
2022-09-08 15:08:10 +08:00
caishunfeng
2e61c76c22
[Improvement] Add remote task model ( #11767 )
2022-09-08 13:41:36 +08:00
kezhenxu94
efedc9a53c
Bump up dependencies to fix cves ( #11765 )
2022-09-08 09:05:05 +08:00
fuchanghai
7c0c1f4b78
Update dolphinscheduler_ddl.sql fix alert t_ds_user add time_zone is not correct ( #11795 )
2022-09-06 23:14:41 +08:00
Tq
4283cfd7a1
[fix][API]fix task types sequence ( #11775 )
...
* fix task types sequence
* fix mapper table name t_ds_fav_task
* fix sequence
2022-09-05 20:29:03 +08:00
caishunfeng
f8d46a26c1
[Feature-11530] add state history for process instance ( #11757 )
...
* [Feature] add state history for process instance (#97 )
* add state history for process instance
* upsertProcessInstance
* remove unuse method
* fix UT
Co-authored-by: caishunfeng <534328519@qq.com>
2022-09-03 10:14:05 +08:00
Tq
b3cc8a55b9
[feature][API]feature: add task type list and enable user to add task type to fav ( #11727 )
...
* feature: add task type list and enable user to add task type to fav
* make DependentExecute.java variable protected
* add standalone server fileSet
2022-09-02 11:40:23 +08:00
juzimao
d0f5e7edf3
optimize the process instance query, change the date time range ( #11719 )
2022-08-31 19:53:41 +08:00
seedscoder
145e441afb
[Fix-11633] The data type of the PostgreSQL database column is wrong. ( #11633 ) ( #11634 )
2022-08-29 16:33:16 +08:00
SongTao Zhuang
6a5367fd57
[Improvement-11662][dao] fix foreach null items in mapper.xml
2022-08-28 20:58:12 +08:00
JiPeng Wang
961e67f524
[Improvement][User] Query all users filter un enabled. ( #11504 )
...
* user query all filter un enabled
* restore permissions
2022-08-24 11:55:18 +08:00
longtb
4893bef5a7
[Improvement][TaskInstance] reduce database queries ( #11522 )
...
* [Improvement][TaskInstance] reduce database queries
* Update dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.java
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
* [Improvement][TaskInstance] queryByInstanceIdsAndCodes -> queryByProcessInstanceIdsAndTaskCodes
Co-authored-by: zhangshunmin <zhangshunmin@kezaihui.com>
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2022-08-23 14:27:26 +08:00
insist777
abfef1a929
[improvement] Add two parameters in workergroup, and support the application of description display and other parameters ( #11542 )
...
* [Improvement] Improvement default worker group
* [Improvement] Improvement default worker group
* [Improvement] Improvement default worker group
* [Improvement] Improvement default worker group
* [Improvement] Improvement default worker group
* [improvement] The default worker grouping supports editing
* [improvement] The default worker grouping supports editing
* Update WorkerGroupServiceImpl.java
* Update WorkerGroupServiceImpl.java
* The default worker grouping supports editing
* update sql file
* update
* update
* update
* update
2022-08-23 10:54:17 +08:00
kezhenxu94
0b82755796
Fix some resource leak ( #11576 )
2022-08-21 01:19:16 +08:00
Wenjun Ruan
2862f5b67c
Set process instance and task priority default value as 2 ( #11539 )
2022-08-18 16:21:12 +08:00
Jiajie Zhong
5983e41f4b
[fix] Database change not sync ( #11258 )
...
* [fix] Database change not sync
* Make del sql upgrade same as release version
* Correct data quality dml sql
* Upgrade database DDL to avoid log path too long error
* Add missing if exists
2022-08-17 10:50:34 +08:00
juzimao
f3d28112ce
optimize sorting priority for workflow define ( #11462 )
2022-08-13 13:28:35 +08:00
insist777
8217784044
[Fix-1360]: Fix Description length check ( #11371 )
...
* [Fix-1360]: Fix Description length check
* Update dolphinscheduler_h2.sql
h2 Increase the length of some fields
* Update dolphinscheduler_ddl.sql
2022-08-11 13:26:50 +08:00
caishunfeng
0464123c2b
[Feature-11223] support stream task ( #11350 )
...
* add task execute type
* update task definition list paging
* update task instance list paging
* stream task start
* [Feature][UI] Some changes to execute task.
* Set the connection edge to dashed line.
* Add FLINK_STREAM task.
* add stream task
* flink savepoint and cancel
* fix query bug
* add stream task definition
* add task instance for stream task
* delete stream task definition state
* update api for stream task definition edit
* modify search for stream task instance
* add language
* delete task type search for stream task definition
* change task type search for stream task instance
* add jump button
* add savepoint
* add down log for stream task instance
* ui test
* stream task start
* run DAG
* [Fix][UI] Fix the stream task edgs not to be dashed when filling back.
* [Feature][UI] Remove some fields for FLINK_STREAM.
* add start modal
* add dryRun column for stream task instance
* fix duration
* fix pon
* fix build error
* Add success tip
* add auto sync for stream task instance
* remove forgien key for task instance
* license header
* UT fix
* modify locales
* recover common config
* fix UT
* add doc
Co-authored-by: Amy <amywang0104@163.com>
Co-authored-by: devosend <devosend@gmail.com>
2022-08-10 21:44:43 +08:00
Wenjun Ruan
8774415197
Split ExecutionStatus to WorkflowExecutionStatus and TaskExecutionStatus ( #11340 )
2022-08-10 11:00:23 +08:00
Wenjun Ruan
acd3d3fab1
Fix TaskGroup cannot work and will cause master dead loop ( #11254 )
...
* Fix TaskGroup cannot work and will cause master dead loop
* Remove acquireTaskGroupAgain in ProcessServiceImpl
2022-08-04 14:43:45 +08:00
Wenjun Ruan
8e21c38c00
Write alert result into db ( #11221 )
2022-08-01 13:04:27 +08:00
zhuxt2015
4d9db3451e
[Bug] [API] If the single log length is long, it will causes the View Log page to hang ( #10612 )
2022-07-26 10:14:45 +08:00
jackfanwan
ccb7641468
修改数据质量查询的权限判断 ( #10977 )
...
Co-authored-by: fanwanlong <fanwanlong@kezaihui.com>
2022-07-25 09:35:53 +08:00
WangJPLeo
fd59f0bb32
[Fix-11031] AccessToken can only be used by the creator. ( #11032 )
...
* AccessToken can only be used by the creator.
* supplement ut
* checkstyle fix
2022-07-20 16:32:03 +08:00
Wenjun Ruan
5e9c7dad23
Add dolphinscheduler-bom to manage the dependency version ( #11025 )
2022-07-20 10:37:31 +08:00
Jiajie Zhong
81930e5420
[python] Fix tasks with multiple upstream and workflow query error ( #10941 )
...
* when task with more than one upstreams, mapper
TaskDefinitionMapper method queryByName will return
more than one record, and failed the mybatis result
type, so we have to add `limit 1` to it to
* add multiple runs of example in integrate test
* Change from subprocess.Popen to subprocess.call_check
in integrating test which will raise an error when failed
2022-07-14 22:06:07 +08:00
Assert
4ff8eaa996
[Fix-10595][api] Fix Dependent Node Only View Projects Created By Self ( #10834 )
...
* [Fix-10595][api] Fix Dependent Node Only View Projects Created By Self
2022-07-14 19:03:34 +08:00
SongTao Zhuang
99a134febb
fix: typo task definition. ( #10958 )
2022-07-14 11:40:46 +08:00
WangJPLeo
9f34a837b8
[Fix-10909] Returns executionStatus for each process instance status and access token module support. ( #10922 )
...
* Returns executionStatus for each process instance status and access token module support
2022-07-13 20:45:52 +08:00
Jiajie Zhong
0db9bbd538
[fix] delete workflow or task used by other tasks ( #10873 )
...
currently, users can delete process definitions used
in other sub-process tasks or in other dependent tasks.
but this change will break the dependence of those task
and failed DAG, this patch add validation of those
delete behavior to avoid this error
2022-07-12 21:22:06 +08:00
Jiajie Zhong
a6154220dc
[fix] update queue and tenant with same code error ( #10877 )
...
in ae6aa53f I use the same logic test to create or update
tenant and queue which failed create with the same value,
this patch will fix it. and also I use the constructor to reduce
the new object logic here
2022-07-11 11:06:30 +08:00
Wenjun Ruan
f639a2eed4
[Fix-10854] Fix database restart may lost task instance status ( #10866 )
...
* Fix database update error doesn't rollback the task instance status
* Fix database error may cause workflow dead with running status
2022-07-11 09:57:00 +08:00
WangJPLeo
3756a233d8
[Fix-10863] Command execution result data statistics remove userId condition. ( #10864 )
...
* Command execution result data statistics remove userId condition.
* e2e rerun
2022-07-10 17:17:35 +08:00
Jiajie Zhong
ae6aa53f96
[python] Fix submit and run error ( #10792 )
...
because we add permission, so it failed out
createQueue method. this patch fix it and
do some refactor of our tenant and queue
validator code
2022-07-08 10:54:41 +08:00
qianli2022
1e48bbc5c6
[Feature-10629][Improvement] Support multi cluster environments - namespace use cluster ( #10650 )
...
* server code
* namespace ui
* fix dao test
* fix test
* fix
* docs and image update
Co-authored-by: qianl4 <qianl4@cicso.com>
2022-07-07 16:05:52 +08:00
WangJPLeo
b8a90d801e
[Improvement] Resource authority module database table unique index increased. ( #10807 )
...
* Resource authority module database table unique index increased.
* add unique in sql file
* rerun
* ut fix
* e2e rerun
* dao un fix
2022-07-07 14:35:50 +08:00
WangJPLeo
d2fe16d252
[Optimization] Config module resource relation fix. ( #10718 )
...
* Config module resource relation fix.
* Boolean judge fix
* e2e rerun
* e2e rerun
* e2e rerun
* ArrayList fix
* change variable name.
* Add transaction processing on create data resource method
2022-07-05 15:51:23 +08:00
Wenjun Ruan
1b86394d3c
Optimize sql script use insert ignore ( #10700 )
2022-06-30 19:04:57 +08:00
WangJPLeo
bc4ceda4cf
TaskGroup remove query func permission check. ( #10557 )
2022-06-23 10:00:31 +08:00
WangJPLeo
20348578a2
[Feature] [Permission]Data permission module added and Query class api remove verification. ( #10504 )
...
* Data permission module added
* ut fix.
* queueController ut fix.
* queue service ut fix.
* e2e rerun
2022-06-22 15:53:36 +08:00
chuxing
0dd6f4008e
[fix][master]: fix condition npe ( #10478 )
...
* [fix][master]: fix condition npe
* [fix][master]: fix condition npe
Co-authored-by: huaangcg <huangcg@getui.com>
2022-06-17 13:40:11 +08:00
Wenjun Ruan
ad2646ff1f
Fix TaskProcessorFactory#getTaskProcessor get common processor is not thread safe ( #10479 )
...
* Fix TaskProcessorFactory#getTaskProcessor get common processor is not thread safe
2022-06-16 21:46:18 +08:00
SmallProgrammer
7aa9fa4965
[imporve] Add index to table t_ds_relation_process_instance ( #10461 )
2022-06-16 15:24:05 +08:00
qianli2022
ff065d8e5b
[Feature][Improvement] Support multi cluster environments - k8s type ( #10096 )
...
* service code
* [Feature][UI] Add front-end for cluster manage
* fix e2e
* remove comment on cluster controller
* doc
* img
* setting e2e.yaml
* test
* rerun e2e
* fix bug from comment
* Update index.tsx
use Nspace instead of css.
* Update index.tsx
Remove the style.
* Delete index.module.scss
Remove the useless file.
Co-authored-by: qianl4 <qianl4@cicso.com>
Co-authored-by: William Tong <weitong@cisco.com>
Co-authored-by: Amy0104 <97265214+Amy0104@users.noreply.github.com>
2022-06-15 13:39:20 +08:00
陈家名
b86dc53ad1
[fix][Python] Support same task name in project defferent process definition ( #10428 )
...
close : #10431
2022-06-14 13:53:18 +08:00
WangJPLeo
9782fe4e7c
[Fix-10367] Permission check related key adjustment. ( #10368 )
...
* Permission check related key adjustment.
* resource create or upload fix.
* Analysis Permission fix.
* Ut coverage add.
* rerun
* source permission fix.
* ut coverage is achieved
* Reference permission package path modification
* k8s path bug fix.
* k8s path bug fix.
* Corrected controller method name and rerun.
2022-06-09 19:10:34 +08:00
xiangzihao
b1fb17119b
[Feature-6758][Task] Add limit resource usage for tasks base on cgroup ( #10373 )
2022-06-08 19:42:05 +08:00
WangJPLeo
e3e39cbdea
[Fix] Privilege Reconstruction Data Query Fix & Resource Creation Post Oper… ( #10313 )
...
* Privilege Reconstruction Data Query Fix & Resource Creation Post Operations.
* Resource Retry
* e2e retry
* create project log add
* project list query log add
* clean project log
* delete delay
* delete delay
* remove post handle
* project e2e
* browser refresh
* browser refresh
* e2e fix
* e2e browser refresh
* rowk flow e2e fix
* mapper deduplication
* udf e2e
* e2e
2022-06-01 20:29:10 +08:00
kezhenxu94
d80cf21456
Clean up unused dependencies and packaging issues ( #9944 )
2022-05-31 15:22:41 +08:00
Wenjun Ruan
3a9e67325e
Fix database initialize late in standalone. ( #10296 )
2022-05-31 11:52:00 +08:00
WangJPLeo
a4948f58e6
[Feature][Permission] Reconstruction of permissions of resource center and monitoring center. ( #10307 )
...
* Reconstruction of permissions of resource center and monitoring center.
* clear local logs.
* resource query fix
2022-05-31 08:14:45 +08:00
hstdream
53ab6f7b92
[Feature][API] Modify the permissions of project management, security center, data source center and data quality module. ( #10289 )
...
* Resource userName is null
* [Fix-10082]Resource userName is null and udf function manager add a username
* [Fix-10082]Resource userName is null and udf function manager add a username
* [Fix-10082]Resource userName is null and udf function manager add a username
* [Feature][API] Modify the permissions of project management, security center, data source center and data quality module.
* [Feature][API] Modify the permissions of project management, security center, data source center and data quality module.
* [Feature][API] Modify the permissions of project management, security center, data source center and data quality module.
Co-authored-by: houshitao <shitaohou@163.com>
2022-05-30 23:32:25 +08:00
WangJPLeo
7ac8ea493c
[Feature][Permission] Project management module authority control refactoring, authority abstract interface setting. ( #10261 )
...
* Create process definition with task group and task group priority cannot be save into db
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* [Feature][API] Permission control of project
* The result of the assertion cannot be changed. The only difference is the judgment condition.
* test recovery.
* controller test fix.
* ProjectE2ETest fix.
* WebElement import.
* Prioritize problem solving.
* Judging the length of the set fix
Co-authored-by: houshitao <shitaohou@163.com>
Co-authored-by: hstdream <33045461+hstdream@users.noreply.github.com>
2022-05-29 16:14:16 +08:00
Jiajie Zhong
d8db2b57d2
[fix] Task group queue query all list error ( #10237 )
...
Add support query all task queue by not given specific groupId
close : #10102
2022-05-25 16:33:23 +08:00
longtb
bd34e66b8a
[Fix-10076] queryUserByToken use server timezone ( #10177 )
...
* [Fix-10076] queryUserByToken use server timezone
* [Fix-10076] queryUserByToken use server timezone
2022-05-23 09:54:11 +08:00
BaoLiang
ee2b855ced
[BUG][TaskGroup] Task group does not take effect ( #10093 )
...
* fix 10092: Task group does not take effect
* fix 10092: Task group does not take effect
* fix 10092: Task group does not take effect
2022-05-18 18:40:36 +08:00