68660ec96b
Refactor remote command ( #13809 )
...
* Refactor remote command
* Rename Command to Message
2 years ago
d1b6e6f02c
Take over task instance in master failover ( #13798 )
2 years ago
d91bdeff37
Fix retry task instance will loss varpool ( #13791 )
2 years ago
1f365819a6
Ignore unknown VM options in start.sh ( #13719 )
2 years ago
394805b2c7
[Feature][Metrics] Tag workflow related metrics with process definition code (workflow id) ( #13640 )
...
* Tag workflow related metrics with process definition code (workflow id)
* Clean up related metrics when deleting workflow definition
* Add license headers
* Update related UT cases
* Add an example in grafana-demo
* Add related docs
2 years ago
c9066e8de9
Use MDC to filter task instance log ( #13673 )
...
* Use MDC to collect task instance log
* Use MDCAutoClosableContext to remove the MDC key
2 years ago
7bf3e3cdd6
[improve-#13201] update pid during running ( #13206 )
2 years ago
047fa2f65e
[Feature-13511] Submit Spark task directly on Kubernetes ( #13550 )
2 years ago
701d67c831
[improve-#13045] after a submit failure, stop the processInstance to avoid an endless loop ( #13051 )
...
* [improve-#13045] add max submit number of workflow
* [fix-13405] remove max times
* Update dolphinscheduler-master/src/main/resources/application.yaml
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
---------
Co-authored-by: fuchanghai <‘2875334588@qq.com’>
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
2 years ago
e8b20def54
Fix task instance will generate multiple times when retry interval is 0/s ( #13571 )
2 years ago
2bd65fb2df
[Feature][Remote Logging] Add support for writing task logs to OSS ( #13332 )
2 years ago
8d12dc0702
[Improvement-13491] Use lombok @Slf4j annotation to generate logger ( #13509 )
2 years ago
12dd60fa46
Fix task wake up failed will block the event ( #13466 )
2 years ago
385d781ebc
Fix minor spelling and punctuation errors ( #13452 )
2 years ago
ce34e21960
Task instance failure when worker group doesn't exist ( #13448 )
2 years ago
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>
2 years ago
3b980cb06a
[fix][worker][bug] master/worker crash when registry recover from SUSPENDED to RECONNECTED ( #13328 )
2 years ago
ccad56e88e
[Improvement][Master] Validate same content of input file when using task cache ( #13298 )
...
* support file content checksum
* fix inject null storageOperate bug
2 years ago
8a479927f3
Add projectCode in t_ds_process_instance and t_ds_task_instance to remove join ( #13284 )
2 years ago
52134277a3
Fix task group cannot release when kill task ( #13314 )
2 years ago
2e95a020ab
fix dag.getPreviousNodes miss upstream node ( #13255 )
2 years ago
14ec4a2398
Remove dao module in worker ( #13242 )
2 years ago
5fe25c995f
Fix spelling ( #13237 )
2 years ago
d13cd55281
fix spell error and move comment to correct describe location ( #13233 )
2 years ago
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>
2 years ago
7a0a2c2a46
Solve the deadlock problem caused by queuing ( #13191 )
...
* Solve the deadlock problem caused by queuing
* Solve the deadlock problem caused by queuing
* Solve the deadlock problem caused by queuing
* Solve the deadlock problem caused by queuing,move the event to the tail by throwing a exception
Co-authored-by: wfs <wangfushun@cdqcp.cpm>
2 years ago
be81b222d4
Optimize event loop ( #13193 )
2 years ago
e4b9b67255
Allow execute task in workflow instance ( #13103 )
2 years ago
70ccffeee2
Format task parameter as pretty json ( #13173 )
2 years ago
6ef74073cc
[Improve-13001]migrate commons-collections -> commons-collections4 ( #13002 )
2 years ago
a7ecc5a8b3
fix retry task failure ( #13077 )
2 years ago
169168ef34
Add plugin-all module ( #13079 )
2 years ago
12a6138d33
fix issue 13035 ( #13065 )
...
Co-authored-by: shenk-b <shenk-b@glodon.com>
2 years ago
ffc9fb280a
Add gc timestampt ( #13059 )
2 years ago
1a8811cb41
Set max loop times when consume StateEvent to avoid dead loop influence the thread. ( #13007 )
2 years ago
3106054ea7
[Improvement-12907] Change heartbeat log level to debug ( #12980 )
2 years ago
50779ea1e6
[Bug-12963] [Master] Fix dependent task node null pointer exception ( #12965 )
...
* Fix that there are both manual and scheduled workflow instances in dependent nodes, and one of them will report a null pointer exception during execution.
2 years ago
38b876733c
[Feature-10498] Mask the password in the log of sqoop task ( #11589 )
2 years ago
3747029cc0
[fix-#12932] when subprocess's processInstance is fail,not notify parent processInstance ( #12933 )
2 years ago
27c37b8828
Fix grammar and spelling ( #12937 )
2 years ago
c916c60853
fix NPE while retry task ( #12903 )
2 years ago
d99ba29b66
Fix master cluster may loop command unbalanced ( #12891 )
...
(cherry picked from commit 3b2b86661be76b7c1404a910c865d78b7936313d)
2 years ago
229c554912
[feature][task] Add Kubeflow task plugin for MLOps scenario ( #12843 )
2 years ago
7cdb926a5f
[Improvement][Batch Query] Batch query ProcessDefinitions belongs to need failover ProcessInstance. ( #12506 )
2 years ago
9e0c9af1a5
Fix the waiting strategy cannot recovery if the serverstate is already in running ( #12651 )
2 years ago
08335b1032
[Improvement][Task] Improved way to collect yarn job's appIds ( #12197 )
...
* Provide aop way as an optional way to collect yarn job's applicationId, and import new module `dolphinscheduler-aop` to place the aop code.
* Add user property `appId.collect` for user to decide how to collect applicationId.
* Add new environment configuration for each type of yarn tasks to support aop in `dolphinscheduler_env.sh`
* Update docs to declare how to use aop way.
* Update `LogUtils` to support fetch applicationId in different ways based on the user property.
Co-authored-by: gabrywu <gabrywu@apache.com>
2 years ago
e6da1ccf81
Add worker-group-refresh-interval in master config ( #12601 )
...
* Add worker-group-refresh-interval in master config
* Set interval cannot smaller than 10s
* Update dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/config/MasterConfig.java
Co-authored-by: kezhenxu94 <kezhenxu94@apache.org>
2 years ago
065d5caccc
Only expose necessary actuator endpoints ( #12571 )
2 years ago
489e7fe4e2
[Feature-10495][Resource Center] Resource Center Refactor ( #12076 )
...
* resource center refactor - S3 services connection
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2 years ago
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>
2 years ago
Wenjun Ruan
Eric Gao
fuchanghai
Aaron Wang
Rick Cheng
seedscoder
qianli2022
hokie-chan
JieguangZhou
John Bampton
ZhongJinHacker
sssqhai
Yann Ann
Kevin.Shin
Kerwin
ZhenjiLiu
kezhenxu94
HanayoZz