JohnHuang
a7245189a8
[Improvement][Flink] Change Flink command into FLINK_HOME ( #16004 )
5 months ago
旺阳
e93ed78c0f
[Fix] Fix audit log parma typo ( #16077 )
5 months ago
Wenjun Ruan
e6c57430e3
[DSIP-44] Set a delay time to TaskExecuteRunnable if it dispatched failed ( #16069 )
5 months ago
Wenjun Ruan
f754611509
[DSIP-42] Add dolphinscheduler-aws-authentication module ( #16043 )
5 months ago
yinxiaolog
baa252a0ed
[DS-16046][fix] Set PreparedStatement parameter type ( #16050 )
...
Fix the PreparedStatement parameter is TIME, set it to java.sql.Time
Co-authored-by: Aaron Wang <wangweirao16@gmail.com>
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
5 months ago
小可耐
0fc2fe971a
[DSIP-39][parameter] Improvement startup parameters/global parameters/project parameters data type ( #15967 )
...
* [Improvement][parameter] New data types and type filtering
* [Improvement][parameter] Improvement startup parameters/global parameters data type
* fix api interfaces compatible
* add project parameter data type default value
* [Improvement][parameter] New data types and type filtering
* [Improvement][parameter] Improvement startup parameters/global parameters data type
* fix api interfaces compatible
* add project parameter data type default value
* improvement project code
* remove useless imports
* remove method onClearSearchTaskType
* add parameter doc
* optimisation logic
* code conflict resolution
* code conflict resolution
* [Improvement][Monitor] Show master && worker Busy Or Normal Status and Show Commands table list (#15978 )
* update
* test
* add monitor enhance ui
* update
* update
* update doc
* fix spotless
* update
* update
* Update dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/DataAnalysisController.java
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* Update dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/DataAnalysisController.java
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* Update dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.java
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* Update dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* Update dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/CommandMapper.java
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* Update dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* update
* fix spotless
* update
---------
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
* [Improvement][Monitor] Add UT for montor (#15998 )
* formatting Code
5 months ago
Wenjun Ruan
61915a2d5d
Fix workflow instance restart failed due to duplicate key in varpool ( #16001 )
6 months ago
Eric Gao
dc306bfa1d
[Improvement] Use safe constructor with snake yaml ( #15758 )
6 months ago
Wenjun Ruan
3446fd8ab1
EMR task support replace params placeholder ( #15975 )
...
Co-authored-by: Eric Gao <ericgao.apache@gmail.com>
6 months ago
cntiger
60b019b729
[Improvement] Fix the git url command injection in pytorch task( #15873 ) ( #15950 )
...
* fix the git url command injection danger(#15873 )
* [Improvement] Fix the git url command injection in pytorch,format code style task(#15873 )
---------
Co-authored-by: cntigers <Xiaohu4321@>
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
6 months ago
Zzih96
5c569b705c
[fix-15907] Fix get remote shell exit code is incorrect ( #15911 )
...
* ./mvnw spotless:apply
* Update dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
---------
Co-authored-by: 詹子恒 <ziheng.zhan@longbridge.sg>
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
6 months ago
Wenjun Ruan
0a11cd21bd
Fix jar path is not correct in java task ( #15906 )
6 months ago
John Huang
6c78c8ec9a
[Improvement][Spark] Support Local Spark Cluster ( #15589 )
...
* [Improvement][Spark] Support Local Spark Cluster
* remote default local from deploy mode
---------
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
6 months ago
Wenjun Ruan
285c5a8eb5
[DSIP-28] Donnot scan whole bean under classpath ( #15874 )
7 months ago
XinXing
3fe9fd45b1
[Fix-15706] Seatunnel improvement ( #15852 )
...
* fix_seatunnel_15706
* CodeFormat
* Change to use JSONUtils
* Constants moved to constant code
* Delete empty lines
* Delete empty lines
7 months ago
Wenjun Ruan
9437d276e7
Change ssh heartbeat type to IGNORE ( #15858 )
7 months ago
sleo
f93b27e121
[Worker] Fix will not kill the subprocess in remote when stop a remote-shell task #15570 ( #15629 )
...
* fix cannot kill the subprocess when stop a remote-shell task
* move parse pid logic into ProcessUtils
* extract common logic
---------
Co-authored-by: 旺阳 <wang@lqwang.net>
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
7 months ago
Wenjun Ruan
3b1de41acb
Remove dolphinscheduler-data-quality from dolphinscheduler-task-dataquality ( #15791 )
7 months ago
Tq
cd63069317
[Improvement-15692][task-datasync] rewrite the mockito test file for DatasyncTaskTest. ( #15693 )
...
* 15692 rewrite the mockito test file for DatasyncTaskTest.
* fix format
8 months ago
lch
e3fdb1a3ff
[Fix-15639] parameterPassing is null case NPE ( #15678 )
...
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
8 months ago
Gallardot
3fda980006
[Task][Remoteshell] fix maven dependency warn ( #15635 )
...
Signed-off-by: Gallardot <gallardot@apache.org>
8 months ago
王渔
00008515c0
Update SeatunnelTask.java ( #15621 )
...
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
Co-authored-by: xiangzihao <460888207@qq.com>
8 months ago
Wenjun Ruan
24ff70dc88
Fix out parameter may loss ( #15617 )
8 months ago
Jay Chung
91d56f4860
fix: data quality may fail in docker mode ( #15563 )
9 months ago
dada Sun
4d6af516b9
[Bug][Task Api] fix 'MACPATTERN' in ProcessUtils and cover all cases on MacOS in ProcessUtilsTest ( #15480 ) ( #15529 )
...
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
9 months ago
Jay Chung
8efaa9fa1f
fix: data quality can not use ( #15551 )
...
* fix: data quality can not use
fix : #15468 , #15249 , #14858
---------
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
Co-authored-by: Eric Gao <ericgao.apache@gmail.com>
9 months ago
Wenjun Ruan
4d15932ede
Fix createFile with permission will not work ( #15556 )
9 months ago
Gallardot
3640a28348
[Improvement][HTTP] support custom rendering of http body ( #15531 )
...
Signed-off-by: Gallardot <gallardot@apache.org>
Co-authored-by: Eric Gao <ericgao.apache@gmail.com>
9 months ago
zhihuasu
d80a29c48c
[BUG] #15013 Fix retryInterval in RetryPolicy will never be used in RetryUtils ( #15014 )
...
* Update RetryUtils.java
assigned
* UT
* Update RetryUtilsTest.java
---------
Co-authored-by: xiangzihao <460888207@qq.com>
Co-authored-by: Rick Cheng <rickchengx@gmail.com>
9 months ago
Wenjun Ruan
5a7deb28f7
Throw IllegalArgumentException if parse time placeholder error ( #15514 )
...
(cherry picked from commit 5fa31e036d77698f3732a42664bfac3e7edcb8e4)
9 months ago
Wenjun Ruan
64e1e67581
Use DefaultUncaughtExceptionHandler to log the uncached exception ( #15496 )
...
Co-authored-by: fuchanghai <changhaifu@apache.org>
10 months ago
Gallardot
c7a11ce6ed
[Improvement][K8S]Optimize MDC for K8S tasks ( #15390 )
...
Signed-off-by: Gallardot <gallardot@apache.org>
Co-authored-by: fuchanghai <changhaifu@apache.org>
10 months ago
aiwenmo
ace0860d3d
[Feature-15475][DinkyTask] DinkyTask supports Dinky-1.0.0 and common sql ( #15479 )
10 months ago
lizhenglei
bd48c99178
[BUG][Task] fix java task classpath ( #15470 )
...
* fix javatask bug
* cover
---------
Co-authored-by: 80597928 <673421862@qq.com>
Co-authored-by: fuchanghai <changhaifu@apache.org>
10 months ago
Wenjun Ruan
bf2cdc5300
Use Druid to split sql ( #15367 )
10 months ago
Gallardot
93ea5f64c3
[Improvement][K8S] Custom label of a K8S task can be passed to the pod ( #15369 )
...
Signed-off-by: Gallardot <gallardot@apache.org>
10 months ago
Wenjun Ruan
d6dea4633c
Optimize server startup log ( #15362 )
10 months ago
Wenjun Ruan
5523a62825
Remove taskQueue and looper in worker ( #15292 )
10 months ago
Wenjun Ruan
921253109a
[Bug] Close SSH session after remote shell finish ( #15348 )
...
* Close SSH session after remote shell finish
---------
Co-authored-by: David Zollo <davidzollo365@gmail.com>
10 months ago
Wenjun Ruan
5b6b0ceb31
Fix resource file usage(Delete Resource/ResourceUser which is deprecated) ( #15355 )
10 months ago
Wenjun Ruan
f921457a55
Set maxRows in SqlTask ( #15342 )
...
(cherry picked from commit b6b88e3e62d8245e08408fb60c48d23c0bd0bb46)
11 months ago
chenrj
ce11674668
Fix k8sTaskExecutionContext setting configYaml ( #15116 )
...
* fixed the issue of obtaining kubeConfig of k8s tasks
* removed excess files
* removed excess files
* formatted the code
---------
Co-authored-by: xiangzihao <460888207@qq.com>
Co-authored-by: Aaron Wang <wangweirao16@gmail.com>
11 months ago
xujiaqiang
159179ac95
[Feature-15146][dolphinscheduler-task-sqoop] add sqoop source/target type ( #15146 )
...
* task list: sgoop node params optimize
* security.ts add alarm_instance params
* 1 add SqoopTask params
2 add alert plugin aliyun-voice
* add license header
* commit sqhoop optimize
* pnpm-locl.yaml supplement annotation
* remove irrelevent commit.
* Code specification optimization
* optimize sqoop task ui
* Merge Code
* add the license header to pnpm-locl.yaml
* format the code
* format the code
* Fix sqoop task echo error
---------
Co-authored-by: xujiaqiang <xujiaqiang@aimatech.com>
Co-authored-by: xujiaqiang <“xujiaqiangwz@163.com”>
Co-authored-by: David Zollo <dailidong66@gmail.com>
11 months ago
Dyqer
0bb48f3429
fail-fast for dependent check ( #15197 )
...
Co-authored-by: Leoric Yue <leoric.yue@zoom.us>
Co-authored-by: caishunfeng <caishunfeng2021@gmail.com>
11 months ago
Wenjun Ruan
2119e41800
[Improvement] Move delay calculation to Master ( #15278 )
11 months ago
Wenjun Ruan
db3d84b73d
[HotFix] Fix TaskOutputParameterParser might OOM if meed a bad output param expression ( #15264 )
11 months ago
Wenjun Ruan
ef2e9c9b67
Set the tenant as the owner in final stage ( #15256 )
11 months ago
Wenjun Ruan
71ee1f0c3d
Support parse task output params under multiple log ( #15244 )
11 months ago
Wenjun Ruan
df656a7671
Fix home page workflow instance miss status ( #15193 )
12 months ago
旺阳
5afd94136c
[Fix][Data Quality] Change t_ds_dq_rule_input_entry field name fix PostgreSQL not support value issue ( #14992 )
...
* change data quality field name
* fix-dao
* fix-dao
* fix-dao
* fix-dao
* update
* test
* update
* update
12 months ago