zhuangchong
f1aefae5e2
[maven-release-plugin] prepare release 3.1.2
2 years ago
Kerwin
f27db04a8b
[Bug-12994] [Worker] Fix kill process does not take effect ( #12995 )
2 years ago
simsicon
fc67fab006
cherry-pick Upgrade clickhouse jdbc driver #12639
2 years ago
zhuangchong
48ad9ff412
[maven-release-plugin] prepare for next development iteration
2 years ago
zhuangchong
efc0367999
[maven-release-plugin] prepare release 3.1.1
2 years ago
zhuangchong
145c5ac8cb
[maven-release-plugin] prepare for next development iteration
2 years ago
zhuangchong
525a6846ac
[maven-release-plugin] prepare release 3.1.1
2 years ago
Kerwin
b446b260f4
Modify shell env to bash ( #12742 )
2 years ago
Wenjun Ruan
a8113f05ee
cherry-pick Change command file permission to 755
2 years ago
Kerwin
2c93dc6041
cherry-pick ( #12608 )
...
[improvement-#12416] Use CollectionUtils.isEmpty judge the collection isEmpty to avoid NPE
#12449
Co-authored-by: fuchanghai <33984497+fuchanghai@users.noreply.github.com>
2 years ago
Kerwin
94ef02e9de
cherry-pick [Improvement] Merge spi.utils into common.utils ( #12607 )
...
#12502
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
2 years ago
kezhenxu94
eb7b48596c
cherry-pick Reorganize some classes in common module, remove duplicate classes
...
#12321
2 years ago
zhuangchong
7ca4438682
Resolve AbstractTask code conflicts
2 years ago
Kerwin
f3277277f0
cherry-pick Refactor LogServiceClient Singleton to avoid repeat creation of NettyClient #11777 ( #12542 )
...
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
2 years ago
Kerwin
344293102d
[3.1.1-prepare][cherry-pick][Improvement] Add remote task model #11767 ( #12541 )
2 years ago
insist777
3a14fd07b3
[Fix][Task] Fix dependent task can not predicate the status of the corresponding task correctly ( #12253 )
...
* [Fix][Task] dependent task can not predicate the status of the corresponding task correctly
2 years ago
Kerwin
f0ad67f992
cherry-pick source is not available in sh ( #12413 )
...
Co-authored-by: simsicon <simsicon@gmail.com>
2 years ago
rickchengx
5cfe6a96b4
[Improvement-12372][k8s] Update the deprecated k8s api ( #12373 )
2 years ago
Kerwin
771dd67b2e
cherry-pick [Improvement-12391][API] Workflow definitions that contain logical task nodes support the copy function
2 years ago
caishunfeng
7e39396a76
[maven-release-plugin] prepare for next development iteration
2 years ago
caishunfeng
ae33ba5947
[maven-release-plugin] prepare release 3.1.0
2 years ago
Eric Gao
e7b12bf205
[Cherry-Pick][3.1.0-prepare] Cherry-Pick OssOperator for Resource Center to 3.1.0 ( #12094 )
...
* Cherry OssOperator for Resource Center to 3.1.0
* Fix doc dead link
2 years ago
kezhenxu94
fcc75ef1c6
Bump up dependencies to fix cves ( #11765 )
2 years ago
caishunfeng
8d1c2d3eeb
cherry-pick [Bug] Fix procedure task param pass #11919 ( #11926 )
2 years ago
caishunfeng
f95cdd350a
reduce task dependencies ( #11731 )
2 years ago
Wenjun Ruan
03e1e6fe45
[Bug] [Worker] Optimize the getAppId method to avoid worker OOM when kill task ( #11701 )
...
* Fix kill job may cause worker oom
2 years ago
Wenjun Ruan
1b120e3a59
Refactor worker execute task process ( #11540 )
...
* Refactor worker execute task process
2 years ago
Wenjun Ruan
b96d69701a
[Improvement-#11613] Add spi priority factory ( #11614 )
...
* Add spi priority factory
* Add doc
* Add override log
* Use lombok
* Add comment
2 years ago
Wenjun Ruan
a41c6824fc
Add dependent task instance log ( #11541 )
...
* Add dependent task instance log
* Optimize log
* Fix dependent task initialize failed will throw exception
2 years ago
kezhenxu94
13e4720aa2
Upgrade spring boot and swagger ( #11574 )
2 years ago
kezhenxu94
f6ef628030
Support reading application properties from kubernetes config map ( #11402 )
2 years ago
Kerwin
b79bad19e5
[Fix-11051][Task]Fix the process exitValue exception when the process times out and th… ( #11099 )
2 years ago
Wenjun Ruan
5fa3e7b1ed
Add pause to task instance status ( #11390 )
2 years ago
Stalary
6345a13cdc
[Fix-10392][SqlTask]: Fix list param error when use sql task ( #11285 )
...
* FIX: fix list param in.
* FIX: code bug
* FIX: fix one value
* FIX: header
* FIX: ci
* FIX: fix ci
* MOD: for review
* MOD: for review
2 years ago
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>
2 years ago
Wenjun Ruan
8774415197
Split ExecutionStatus to WorkflowExecutionStatus and TaskExecutionStatus ( #11340 )
2 years ago
microeastcowboy
9a53c6ac34
fix work oom when task logs's size is very large ( #11224 )
2 years ago
xuhhui
bfff3a7c5d
fix error ( #11206 )
2 years ago
caishunfeng
818648df7d
[Bug-11071] fix local params ( #11184 )
...
* fix local params
* add CI case
2 years ago
Wenjun Ruan
052ceaacd0
Add is success in loop task status ( #11169 )
2 years ago
Wenjun Ruan
c7789bf049
Add base loop task execotor and http template parser ( #11137 )
...
* Add base loop task execotor and http template parser
* Add JsonPathUtils
2 years ago
Wenjun Ruan
5e9c7dad23
Add dolphinscheduler-bom to manage the dependency version ( #11025 )
2 years ago
Eric Gao
a38fa34d43
[Feature][Task Plugin] Enable users to switch endpoints in zeppelin tasks ( #10925 )
...
* [Feature][Task Plugin] Enable users to switch endpoints in zeppelin tasks (#9814 )
2 years ago
chuxing
427c58546c
[fix][plugin]: fix spark sql use custom parma. ( #10821 )
...
* [fix][plugin]: fix spark sql use custom parma.
* [fix][plugin] roll back part of the code
Co-authored-by: huaangcg <huangcg@getui.com>
2 years ago
WangJPLeo
8f621ff98b
[Optimization] Calculate global parameter and local parameter at master. ( #10704 )
...
* Global parameter and local parameter calculation external expansion.
* k8s task ut fix.
* TimePlaceholderUtils import DateUtils fix
* follow the review comments to fix.
* follow the review comments to fix.
* e2e rerun
2 years ago
Wenjun Ruan
66624c5c86
[Bug] [Master] Worker failover will cause task cannot be failover ( #10631 )
...
* fix worker failover may lose event
2 years ago
Wenjun Ruan
db595b3eff
Optimize master log, use MDC to inject workflow instance id and task instance id in log ( #10516 )
...
* Optimize master log, add workflow instance id and task instance id in log
* Use MDC to set the workflow info in log4j
* Add workflowInstanceId and taskInstanceId in MDC
2 years ago
guodong
2c227ab384
[Feature-10363][server] S3 Resource center supports bucket customization ( #10433 )
...
* [Feature-10363][server] S3 Resource center supports bucket customization
* Modify the configuration. Sort out HDFS and S3 configurations to distinguish them
* Modify the configuration comment to clarify the configuration meaning
* Modify official documents to add missing configuration descriptions and clarify configuration meanings and usage
* Modify the configuration file in e2E to the correct definition, dolphinscheduler-e2e/dolphinscheduler-e2e-case/src/test/resources/docker/file-manage/common.properties
* Modified code to support bucket customization
* Check that the bucket on personal permission, Otherwise, the startup fails
* S3 increase support resource. Storage. Upload. Base. The base path path
* Change S3Utils implementation style to be consistent with HadoopUtils
* [Feature-10363][server] S3 Resource center supports bucket customization
* Modify code review comments
2 years ago
xiangzihao
bbba20d39a
change to common lang3 and fix checkstyle ( #10380 )
2 years ago
xiangzihao
b1fb17119b
[Feature-6758][Task] Add limit resource usage for tasks base on cgroup ( #10373 )
2 years ago