Commit Graph

6420 Commits (30a8372505bdc00b58792f1f3761d93b04d046a7)

Author SHA1 Message Date
Eric Gao a5bbf7852d
[Feature][Task-Plugin]Add zeppelin task-plugin to support Apache Zeppelin (#9327) 2022-04-17 22:10:10 +08:00
Tq 1192fb8e12
fix Fault tolerance warning mapper add alert type to insert (#9533) 2022-04-17 10:17:00 +08:00
xiangzihao ec939fcc68
[Bug] [Dev] Fix start/stop/status/init script error (#9514)
* change /bin/sh to /bin/bash

* change /bin/sh to /bin/bash

* remove declear -A to adapt mac
2022-04-16 21:34:53 +08:00
calvin adcc43fd7e
[Improve][API] Allowed the non-root user to create the task group. (#9523)
* create a new branch from dev

* fix this issue

* merge from dev
2022-04-16 21:25:56 +08:00
xiangzihao 7f41a96fc1
[Fix-9525] [Worker] Environment did not work as expected (#9527)
* fix #9525

* change to ${PYTHON_HOME}

* remove import

* fix ut error
2022-04-16 18:57:33 +08:00
songjianet 26726bb887
[Fix][UI Next][V1.0.0-Beta] Fix the resource Center dark mode display exception when viewing the file details. (#9526)
* [Fix][UI Next][V1.0.0-Beta] Fix the resource Center dark mode display exception when viewing the file details.

* [Fix][UI Next][V1.0.0-Beta] Fix the resource Center dark mode display exception when viewing the file details.
2022-04-16 16:09:15 +08:00
songjianet 0972610204
[Feature][UI Next][V1.0.0-Beta] Monaco Editor supports theme switching function. (#9521) 2022-04-15 21:50:15 +08:00
labbomb 7777a6acfd
[Fix][UI Next][V1.0.0-Beta] Added access to the child node function (#9518)
* Added access to the child node function

* Added access to the child node function
2022-04-15 18:50:52 +08:00
WangJPLeo 95ccc0c855
[Fix-9516] [Statistics] Statistics Manager shows data should belongs to current user (#9515) 2022-04-15 18:25:25 +08:00
Jiajie Zhong 1f48601c75
[python] Add task decorator for python function (#9496)
* [python] Add task decorator for python function

* Add decorator `@task`
* Add a tutorial about it
* Change tutorial doc and combine into traditional docs
  * Add sphinx-inline-tab for better view

* revert not need change

* Correct python function indent

* Correct integration test
2022-04-15 15:50:52 +08:00
Jiajie Zhong 59a026d897
[python] Support read config in env variable (#9517)
Add a new method to get config from environment variables
and for now, we have three ways to get config and the
priority is `env-var > custom-config-file > built-in-config-file`.

Environment config setting does not work in CLI, because it will
confuse users when they get config value is `var-env` but value
in the configuration file is `var-in-file`, they may not find
the way how to change it

* Add documentation
* Add it to UPDATING.md

close: #8344
2022-04-15 15:46:44 +08:00
Kerwin 4221ee2433
Add python module dependency in the dist module (#9506) 2022-04-15 13:53:37 +08:00
Paul Zhang 3815a86a3b
[Improvement][Master] Fix typo for MasterTaskExecThreadTest (#9513) 2022-04-15 11:32:22 +08:00
Tq 51d47de6de
[Bug] [ALERT-9487] change email attachment filename to add random string to avoid issues (#9498)
* change email attachment filename to add random string to avoid always use same file

* change email attachment filename to add random string to avoid always use same file
2022-04-15 10:13:13 +08:00
songjianet 46c0c18ec7
[Feature][UI Next][V1.0.0-Beta] Change the css style usage of the blue number flopper in the alarm center to css variables. (#9511) 2022-04-14 22:12:14 +08:00
caishunfeng 66d148872d
[Bug-9501][Worker] fix kill task error before running (#9509) 2022-04-14 21:34:02 +08:00
caishunfeng 7b907b854d
[Improvement][doc] update time zone doc (#9503)
* update time zone doc

* update time zone doc

* update time zone doc
2022-04-14 21:32:00 +08:00
Amy0104 8a2fbd205e
[Fix][Next-UI] Fix the jumping problem of close button on dag page. (#9494) 2022-04-14 14:09:40 +08:00
czeming 706cdb6a8e
[Fix-9174] [Alert] Fix deduplication of alarm information (#9371)
* feat(issue #9174):

Fix-9174
2022-04-14 10:30:25 +08:00
Tq df791a374e
[FIX][WEBSITE-9224]fix wechat doc and wechat form display (#9439)
Co-authored-by: Jiajie Zhong <zhongjiajie955@hotmail.com>
2022-04-13 23:35:05 +08:00
Amy0104 e134c63e68
[Bug][Next UI] Fix the branch flow options of the switch task is not available. (#9481) 2022-04-13 20:51:43 +08:00
Amy0104 e5c66ecc31
[Fix][UI Next] Fix the problem of disabling owned user input during project editing. (#9476) 2022-04-13 18:05:02 +08:00
mazhong 8821b91829
[FIX-9471][Script] fix run install.sh error (#9472) 2022-04-13 17:53:05 +08:00
Eric Gao eb21b6cc52
[Feature][Doc] Switch shell task instruction screenshots to latest (#9434) 2022-04-13 14:13:42 +08:00
Amy0104 099bde0f78
[Fix][Next-UI] Add LIST type to the custom parameter types of task node. (#9468) 2022-04-13 13:45:39 +08:00
Tq 04d4e4e0c4
fix the OUT direct param could pass to the current script (#9463) 2022-04-13 10:43:12 +08:00
labbomb 8440baa5e8
[Bug][UI Next]Fix global variable validation condition for save button in workflow definition. (#9454) 2022-04-12 17:41:46 +08:00
Jiajie Zhong 51c1d8f2aa
[doc] Migrate develop docs from website (#9457)
* [doc] Migrate develop docs from website

developer should also into main repo, because
development setup should follow with the latest
code

* Add missing change from website
2022-04-12 17:23:56 +08:00
Amy0104 ac2e1df2bf
[Fix][UI][2.0.5] Add LIST type to the custom parameter types of task node. (#9455) 2022-04-12 17:04:58 +08:00
xiangzihao d18cf184c6
[CI] Improve CI (#9436)
* test

* test

* test

* test

* test

* test

* test

* test

* test

* improve ci

* improve ci

* improve ci
2022-04-12 14:43:15 +08:00
Tq fb0139e959
[Feature] [ALERT-9406]enrich alert info when insert new row into DB (#9445)
* enrich alert info when insert new row into DB

* fix comments
2022-04-12 14:31:38 +08:00
worry 69923546a1
[DS-9263][Improvement][master]optimize failover (#9281)
- add FailoverService.java
- move failover method  from MasterRegistryClient to FailoverService
- move failover code from FailoverExecuteThread to FailoverService

This closes #9263
2022-04-12 11:53:18 +08:00
Lyle Shaw 9d7223b038
[doc] fix url wrong in zh doc (#9421)
Co-authored-by: xiaoliangyu <xiaoliangyu@bytedance.com>
2022-04-12 09:45:25 +08:00
Jiajie Zhong 3d78859fe5
[python] Recover python release properties (#9444)
This patch recovers the properties `python.sign.skip=false`
when the combined profile `release,python` is used.

also close: #9433
2022-04-12 09:42:59 +08:00
Jiajie Zhong aaf2042ec4
[python] Add missing doc about config and connect remote server (#9443)
which includes `configuration`, `run example`
`how to connect remote server`

close: #9286, #9284, #8917
2022-04-12 09:42:28 +08:00
Jiajie Zhong 62284ae689
[doc] Add some dev missing doc (#9427)
* [doc] Add some dev missing doc

Including general-setting, task-definition, audit-log
and they related img

* Change base on suggestion

Co-authored-by: Tq <tianqitobethefirst@gmail.com>
2022-04-11 21:46:40 +08:00
caishunfeng b285ccf930
[Future-9396]Support output parameters transfer from parent workflow to child work flow (#9410)
* [Future-9396]Support output parameters transfer from parent workflow to child work flow

* fix note
2022-04-11 20:03:16 +08:00
kezhenxu94 14d71d1462
[UI] Migrate NPM to PNPM in CI builds (#9431) 2022-04-11 14:16:23 +08:00
Kerwin 923f3f38e3
[Fix-9316] [Task] Configure DB2 data source SQL script execution report ResultSet has been closed exception in SQL task (#9317)
* fix db2 error in the sql task

* update limit in sql task
2022-04-11 13:19:48 +08:00
nobolity 037692517a
[Fix-9251] [WORKER] reslove the sql task about of add the udf resource failed (#9319)
* feat(resource  manager): extend s3 to the storage of ds

1.fix some spell question
2.extend the type of storage
3.add the s3utils
to manager resource
4.automatic inject the storage in addition to your
config

* fix(resource  manager): update the dependency

* fix(resource  manager): extend s3 to the storage of ds

fix the constant of hadooputils

* fix(resource  manager): extend s3 to the storage of ds

1.fix some spell question
2.delete the import *

* fix(resource  manager):

merge  the unitTest:
1.TenantServiceImpl
2.ResourceServiceImpl
3.UserServiceImpl

* fix(resource  manager): extend s3 to the storage of ds

merge the resourceServiceTest

* fix(resource  manager): test  cancel the test method

createTenant verifyTenant

* fix(resource  manager): merge the code  follow the check-result of sonar

* fix(resource  manager): extend s3 to the storage of ds

fit the spell question

* fix(resource  manager): extend s3 to the storage of ds

revert the common.properties

* fix(resource  manager): extend s3 to the storage of ds

update the storageConfig with None

* fix(resource  manager): extend s3 to the storage of ds

fix the judge of resourceType

* fix(resource  manager): extend s3 to the storage of ds

undo the compile-mysql

* fix(resource  manager): extend s3 to the storage of ds

delete hadoop aws

* fix(resource  manager): extend s3 to the storage of ds

update the know-dependencies to delete aws 1.7.4
update the e2e
file-manager common.properties

* fix(resource  manager): extend s3 to the storage of ds

update the aws-region

* fix(resource  manager): extend s3 to the storage of ds

fix the storageconfig init

* fix(resource  manager): update e2e docker-compose

update e2e docker-compose

* fix(resource  manager): extend s3 to the storage of ds

revent the e2e common.proprites

print the resource type in propertyUtil

* fix(resource  manager): extend s3 to the storage of ds
1.println the properties

* fix(resource  manager): println the s3 info

* fix(resource  manager): extend s3 to the storage of ds

delete the info  and upgrade the s3 info to e2e

* fix(resource  manager): extend s3 to the storage of ds

add the bucket init

* fix(resource  manager): extend s3 to the storage of ds

1.fix some spell question
2.delete the import *

* fix(resource  manager): extend s3 to the storage of ds

upgrade the s3 endpoint

* fix(resource  manager): withPathStyleAccessEnabled(true)

* fix(resource  manager): extend s3 to the storage of ds

1.fix some spell question
2.delete the import *

* fix(resource  manager): upgrade the  s3client builder

* fix(resource  manager): correct  the s3 point to s3client

* fix(resource  manager): update the constant BUCKET_NAME

* fix(resource  manager): e2e  s3 endpoint -> s3:9000

* fix(resource  manager): extend s3 to the storage of ds

1.fix some spell question
2.delete the import *

* style(resource  manager): add info to createBucket

* style(resource  manager): debug the log

* ci(resource  manager): test

test s3

* ci(ci): add INSERT INTO dolphinscheduler.t_ds_tenant (id, tenant_code, description, queue_id, create_time, update_time) VALUES(1, 'root', NULL, 1, NULL, NULL); to h2.sql

* fix(resource  manager): update the h2 sql

* fix(resource  manager): solve to delete the tenant

* style(resource  manager): merge the style end delete the unuse s3 config

* fix(resource  manager): extend s3 to the storage of ds

UPDATE the rename resources when s3

* fix(resource  manager): extend s3 to the storage of ds

1.fix the code style of QuartzImpl

* fix(resource  manager): extend s3 to the storage of ds

1.impoort restore_type to CommonUtils

* fix(resource  manager): update the work thread

* fix(resource  manager): update  the baseTaskProcessor

* fix(resource  manager): upgrade dolphinscheduler-standalone-server.xml

* fix(resource  manager): add  user Info to dolphinscheduler_h2.sql

* fix(resource  manager): merge  the resourceType to NONE

* style(upgrade the log level to info):

* fix(resource  manager): sysnc the h2.sql

* fix(resource  manager): update the merge the user tenant

* fix(resource  manager): merge the resourcesServiceImpl

* fix(resource  manager):

when the storage is s3 ,that the directory can't be renamed

* fix(resource  manager): in s3 ,the directory cannot be renamed

* fix(resource  manager): delete the deleteRenameDirectory in E2E

* fix(resource  manager): check the style and  recoverd the test

* fix(resource  manager): delete the log.print(LoginUser)

* fix(server): fix the  udf serialize

* fix(master  task): update the udfTest to update the json string

* fix(test): update the udfFuncTest

* fix(common): syn the common.properties

* fix(udfTest): upgrade the udfTest

* fix(common): revent the common.properties
2022-04-11 10:49:46 +08:00
BaoLiang fea9ce391b
Update inappropriate characters (#9413) 2022-04-10 21:09:48 +08:00
Tq e2759a8f42
[Feature] [ALERT-9406]add new properties to alert class (#9408)
* add new properties to Alert.java and do minor changes to comments

* fix Integer to int

* fix Integer to int

* fix sql files

* fix not null properties to default null
2022-04-08 23:54:34 +08:00
worry dce3c132ca
[DS-9387][refactor]Remove the lock in the start method of the MasterRegistryClient class (#9389) 2022-04-08 21:06:28 +08:00
Jiajie Zhong 2c49c248f3
[doc] Remove observability (#9402)
SkyWalking v9 is coming soon and there are without
DolphinScheduler menus anymore, So we should remove
the SW agent to avoid confusion.

close: #9242
2022-04-08 15:52:57 +08:00
labbomb 2db4cd4f14
[Bug][UI Next]Modify the display state logic of save buttons under workflow definition (#9403)
* Modifying site Configurations

* Modify the display state logic of save buttons under workflow definition
2022-04-08 14:55:49 +08:00
Eric Gao d23616fcbc
[CI] Enable CI to remove unexpected files in /docs/img dir (#9393) 2022-04-08 13:46:35 +08:00
Jiajie Zhong a8f6bf3831
Add new code owner of docs module (#9388) 2022-04-08 13:04:50 +08:00
Jiajie Zhong c828809b46
[doc] Change get help from dev mail list to slack (#9377)
* Change all get help from dev mailing list to slack, because
  we find out mailing list have many users ask for subscribe
  and they maybe subscribe by accident.
* remove join dev mailing list in faq.md because we already
  have it in https://dolphinscheduler.apache.org/en-us/community/development/subscribe.html
2022-04-08 10:56:35 +08:00
songjianet 72bdf6f03c
[Fix][UI Next][V1.0.0-Alpha] Fix the task instance forced success button multi-language support error. (#9392) 2022-04-08 10:02:48 +08:00
guoshupei ca95d2f928
[Fix-9221] [alert-server] optimization and gracefully close (#9246)
* [Fix-9221] [alert-server] optimization and gracefully close

This closes #9221

* [Fix-9221] [alert-server] remove unused mock data

This closes #9221

* [Fix-9221] [alert-server] remove unused mock data

This closes #9221

* [Fix-9221] [alert-server] remove unnecessary Mockito stubbings

* [Fix-9221] [alert-server] init AlertPluginManager in AlertServer

* [Fix-9221] [alert-server] AlertServerTest add AlertPluginManager installPlugin

* [Fix-9221] [alert-server] replace @Eventlistener with @PostConstruct

* [Fix-9221] [alert-server] sonar check solution

* [Improvement-9221] [alert] update constructor injection and replace IStoppable with Closeable

Co-authored-by: guoshupei <guoshupei@lixiang.com>
2022-04-08 10:02:10 +08:00