You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by li...@apache.org on 2020/04/16 11:08:33 UTC
[incubator-dolphinscheduler] branch refactor-worker updated
(b85b593 -> cf08470)
This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a change to branch refactor-worker
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git.
from b85b593 Update HadoopUtils.java
add 9a70e77 1，remove dolphinscheduler-rpc module 2，add dolphinscheduler-remote module 3，add dolphinscheduler-service module 4，refactor LoggerServer module (#1925)
add 29f2b41 Refactor architecture (#1926)
add e0a5a15 dolphinscheduler-common remove spring (#1931)
add e6de6db SpringApplicationContext class title add license (#1932)
add 05abf8b add license (#1934)
add d3f8bb0 Refactor architecture (#1936)
add 69eebe6 Merge branch 'dev' into refactor-architecture
add f005379 LoggerServiceTest remove ProcessDao (#1944)
add a5c2b87 exclude jasper-compiler in case of runtime conflict (#1938)
add 55a5170 Merge remote-tracking branch 'remotes/upstream/refactor-architecture' into dev
add fb5de17 DataAnaylysisServiceTest and ProcessDefinitionService modify
add 3ff7b34 Merge remote-tracking branch 'remotes/upstream/dev' into dev
add 1ac1d58 remote module add comment
add ad00268 OSUtilsTest modify
add 1e812ca add finally block to close channel (#1951)
add 822b9b4 Merge remote-tracking branch 'remotes/upstream/refactor-architecture' into dev
add c1bba46 # Conflicts: # dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/utils/FourLetterWordMain.java
add ba2df29 Merge remote-tracking branch 'remotes/upstream/dev' into dev
add 38a7ad1 1，quartz.properties add conf category 2，dolphinscheduler-daemon.sh modify
add 9dd6979 dolphinscheduler-binary.xml modify
add 5b6ce80 Merge remote-tracking branch 'remotes/upstream/dev' into dev
add b1a68c6 move datasource classes to dao module
add 52c87a6 fix send4LetterWord bug
add d14a108 exclude jasper-compiler in case of runtime conflict
add 0013896 Merge pull request #1 from apache/refactor-architecture
add 94f0af5 Merge pull request #2 from apache/refactor-architecture
add e39d6ba add finally block to close channel
add 8e154ec refactor log client service
add 820b84b add sendSync method
add 43bc566 Merge branch 'refactor-architecture' into refactor-architecture
add b2e0b85 # Conflicts resolve : # dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/NettyRemotingClient.java # dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/ExecuteTaskRequestCommand.java # dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/ExecuteTaskResponseCommand.java # dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/Ping.java # dolphinscheduler-remote/src/m [...]
add ac932ba add sendAsync method (#1962)
add cfa882c Merge remote-tracking branch 'remotes/upstream/refactor-architecture' into dev
add 99b9c10 1，add sendAsync method 2，refactor LoggerClient
add 371a9d1 LogClientService modify
add c2cf8fb test
add 619fb30 #1310 add executor user to the process instance & task instance pages (#1973)
add 34e0a66 Refactor dockerfile (#1978)
add b4f2e5f Add ambari plugin #1469 (#1970)
add 5ecd3b3 fix bug #1996 (#1998)
add 3d6eee5 #203 add sqoop task (#1974)
add 5f3d88e Fix bug #1986. (#1987)
add 7a11d39 docker for e2e
add 5aebdc8 docker github action
add 8a362b5 docker github action
add e2cc538 docker github action
add df0034e Merge pull request #2009 from khadgarmage/docker-compose
add b1624fd update English Readme about image update (#2013)
add 1ce6f35 Update README_zh_CN.md (#2011)
add 205b302 Modify dockerfile build script and add a new README_zh_CN.md file for dockerfile (#2014)
add 5ca4862 remove String.format for org.slf4j.Logger (#2001)
add 1cadb1a Add e2e automated testing (#2005)
add 6b62501 correct repeat images in README (#2017)
add ee3c0ae docker and testcase config for e2e test (#2028)
add f407adc Add e2e to create workflow case (#2027)
add 84409b5 fix taskinstance.isSubprocess misjudgment (#2007)
add 0df7c67 [New Feature] add conditions task #205 (#2003)
add 415d087 Update README.md (#2046)
add 8b2a224 image about monitor screenshot is wrong (#2047)
add c8adf82 Update README.md (#2048)
add 1ea4837 Fixbug i18n #2008 (#2035)
add c9c4402 modify action build
add 099fc64 Merge pull request #2050 from khadgarmage/ci-action-yml
add 3d4acbc fix github action rerun failed #2052
add 7577fab Merge pull request #2053 from Jave-Chen/bcai-dev-fix-bug-20200302-2051
add 8b894de remove submodules for checkout v2
add 46f46ed Merge pull request #2055 from Jave-Chen/bcai-dev-fix-bug-20200302-2051
add fbf05de delete duplicate startLocalZkServer (#2062)
add 3277b90 Change DOM label (#2064)
add 3186545 1. add input cache for datax task (#2034)
add b8014d9 add workflow id, name for email content (#2071)
add 3e5a939 delete unused import (#2066)
add d5c795b fix ugly logger usage (#2063)
add 18d7ff2 action push delete
add d33b883 Merge pull request #2085 from khadgarmage/ci-action-alter
add 6ec8554 fix typo (#2093)
add 4230d5a add embedded database h2 and update embedded zookeeper (#2082)
add 7ed28af Upgrade curator version (#2083)
add 1f92b4c Optimize ParameterUtils.curingGlobalParams() execution efficiency (#2090)
add 6070738 Support worker server to run bat script (#2023)
add 4bb97df fix actions/checkout@v2 problem (#2095)
add 0e1dd8d remove incorrect or unnecessary URL tag (#2099)
add 89b42db Add docker internal server check script (#2092)
add b2268b1 use stringbuilder to append string (#2108)
add 275df85 fix: remove redundant import class (#2110)
add ad381fc move UT class to reasonable package (#2116)
add 450a1f5 Adapting partial code(file name start with E) to the sonar cloud rule (#1999)
add 9224b49 access field handle of FileDescriptor in ProcessImplForWin32 by reflection for portability (#2113)
add ebf7a98 Adapting partial code(file name start with F) to the sonar cloud rule (#2045)
add ce17531 add .asf.yaml file (#2136)
add 1db4ac6 edit README.md modify word from expand to extend (#2138)
add b03e0a0 fix wrong sonar analysis with checkout V2. (#2148)
add ebfacbf docker run failed when docker command was `docker run -d` (#2125)
add e27ba3f use logger to print exception (#2151)
add e3065db fix field access modifier (#2150)
add afb907b fix unequal number of arguments and placeholder (#2149)
add 46e30b1 Add mail server configuration description information (#2143)
add 712a1bc Limit customization file content to no more than 3000 lines(#2128) (#2141)
add 9fda4da fix: The toolbar buttons of Dag disable bug (#2124)
add 7473d5e Adapting partial code(file name start with H) to the sonar cloud rule (#2145)
add 68e4e5c add input cache for sqoop and conditions tasks (#2118)
add 91ecc54 fix bug: data too long for column 'app_link' (#2146)
add 455d8c7 Delete .asf.yaml (#2158)
add 93aa160 Adapting partial code(file name start with I) to the sonar cloud rule (#2155)
add a0088c1 fix rpmbuild and DS Ambari plugin bug (#2144)
add dd2c50a Toolbar of the DAG has not prompt (#2161)
add daad5ef use static method in static class JSON (#2156)
add 205af16 Create .asf.yaml (#2166)
add e98c6f3 Update .asf.yaml (#2167)
add 2e63dc9 Delete .asf.yaml (#2168)
add 80c6ce5 The master and worker server exit exception #2163 (#2176)
add a076ae4 Adapting partial code(file name start with J) to the sonar cloud rule (#2165)
add e0389ae fix: NullPointException in the case of task queuing (#2175)
add 61ebbf2 Adapting partial code(file name start with L) to the sonar cloud rule (#2171)
add fcc5732 Adapting partial code(file name start with M #1) to the sonar cloud rule (#2173)
add e0fc317 Cache HadoopUtils instance with specific days expire time (#2181)
add 1658176 Adapting partial code(file name start with P #1) to the sonar cloud rule (#2171) (#2187)
add f6f29f4 Replace Charset.forName("UTF-8") with StandardCharsets.UTF_8. (#2193)
add a376764 change static field to instance field (#2190)
add f28ba55 fix ResultSet not close and reformat code (#2183)
add 69633a2 fix: Api server startup fail (#2198)
add c5e1c55 Adapting partial code(file name start with M #2) to the sonar cloud rule (#2179)
add 7dd126d Optimize PropertyUtils instantiation. (#2199)
add c82758c e2e add the case of deleting user and tenant (#2210)
add 7789e05 add LoginTest license (#2217)
add 0e5fb86 Adapting partial code(file name start with N) to the sonar cloud rule (#2215)
add 880e995 add repace time when run history job and batch complement job ,not current time (#2196)
add 3c5227a Refactor ConnectionFactory to static inner holder Singleton (#2204)
add 00ff88e support custom datax configuration (#2224)
add 0714971 Optimizing code (#2240)
add f4897b5 fix blocker problem (#2244)
add 74bd333 feat:optimizing code (#2245)
add 4318e86 Adapting partial code(file name start with R) to the sonar cloud rule (#2243)
add ca6872a fix：Depend check bug (#2229)
add 8085e93 Adapting partial code(file name start with Q) to the sonar cloud rule (#2242)
add cddf803 license and checkoutv2 fix (#2261)
add 1fe5b31 Fix checkoutv2 push trigger on dev (#2263)
add 34e2f67 when running windows bat script, the handle is invalid in win7 (#2269)
add 85f55cd fix: No operations allowed after statement closed when running sql task (#2265)
add 3ced3d5 datax add custom and add branch flow node verification (#2218)
add 53b62d4 add ds logs and server status check with e2e test (#2277)
add 0d70e06 Change normalize.scss import method and animation.scss license modification (#2295)
add 5edc2af e2e add project and workflow case (#2309)
add a1b8386 Update test code logger class name (#2303)
add 42f9385 Adapting partial code(file name start with W) to the sonar cloud rule (#2287)
add 74525c2 Decouple DruidDataSource in ConnectionFactory and cache DataSource instance (#2232)
add d83a94a Adapting partial code(file name start with T) to the sonar cloud rule (#2271)
add efde8fd Refactor BaseDataSource and unified handling of JDBC resource releases. (#2184)
add d8cba5f resolve shell task build command nullpointexception (#2267)
add eef8bf4 Adapting partial code(file name start with P #2) to the sonar cloud rule (#2260)
add c52c92e Resource tree code merge (#2322)
add c706b21 taskProps.getScheduleTime() may be null, but there is no check if it … (#2256)
add 48d7612 Adapting partial code(file name start with S #2) to the sonar cloud rule (#2270)
add 38c965d new feature for #404 add resource tree function (#2323)
add a851168 fix：Optimize content returned by interface (#2294)
add d473533 Fix SqlTask kerberos load scope unreasonable. #2178 (#2321)
add f6ca548 Support kubernetes deployment (#2153)
add 6cf7e6c Remove .helmignore file (#2328)
add 526e5c9 Connection mode of adding Sid to Oracle (#2254)
add 152c814 test
add 51925ea Merge remote-tracking branch 'remotes/upstream/refactor-worker' into dev
add f7e89e4 some annotation optimizations (#2333)
add 4440b35 fix #2334 (#2335)
add b5ff3ad Delete ReleaseNotes.md (#2338)
add 2114c8d Modify ans-ui version and timing management style (#2339)
add 2b17435 Supplemental licenses and repair resources cannot be renamed (#2340)
add 718e4b1 Adapting partial code(file name start with O) to the sonar cloud rule (#2259)
add 7cd1f91 test
add 70d6360 startup conflict reslove
add 4db2ac2 Remove invalid code (#2342)
add f60edc8 fix：mail send fail #2345 (#2346)
add db30721 init full_name in dml of version 1.2.2 (#2341)
add 94e8bb1 Merge remote-tracking branch 'remotes/upstream/dev' into dev
add ca096e3 Merge remote-tracking branch 'remotes/upstream/refactor-worker' into dev
add 4bda3cd conflict reslove
add 1f43925 remove ExecuteTaskRequestCommand and ExecuteTaskResponseCommand
add be1494f refactor-worker merge to dev bug fix
add 94713ce refactor-worker merge to dev bug fix
add 433b41d refactor-worker merge to dev bug fix
add b5546dd refactor-worker merge to dev bug fix
add 28f57f8 Change DOM label
add b70e0aa Change name to lowercase
add d7ad1d8 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 84bcdc7 Limit customization file content to no more than 3000 lines
add b90461f Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add e388e34 dd branch flow node verification
add bfcdc17 datax
add ca83fd7 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 9f80430 datax add custom
add 1964d47 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 5c2e94e Change normalize.scss import method and animation.scss license modification
add fd250ff Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 64b28a5 Resource tree code merge
add 7780153 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 2aa4ac8 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 570f8f5 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 3edca14 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 520c40b Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add a56ec7c Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 92d944e Modify ans-ui version and timing management style
add 9ff7b32 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add b7bf172 Supplemental licenses and repair resources cannot be renamed
add becc2de Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 2dde601 Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 70571db Merge branch 'dev' of https://github.com/apache/incubator-dolphinscheduler into dev
add 8561d65 Corrections to historical jar packages and resource data
add 8da2a50 Corrections to historical jar packages and resource data
add 5bff786 Fix the problem of data echo in script edit box
add ef8d64a fix
add 949b8ef Merge pull request #2354 from break60/dev
add 69e000b #2282 fix workflow dependent bug (#2329)
add bd6adf2 Fix the problem of data echo in script edit box (#2366)
add 41d8abd test
add 223bdec refactor-worker merge to dev bug fix
add 2ec668d refactor-worker merge to dev bug fix
add b45e70f refactor-worker merge to dev bug fix
add 1276e0d refactor-worker merge to dev bug fix
add 49944a4 javadoc compile error modify
add 3a066f2 javadoc compile error modify
add b35baa5 Merge remote-tracking branch 'remotes/upstream/refactor-worker' into dev
add d3990df .gitignore remove taskInstance/index.vue(#2300) and no need to findProcessDefineById 2 times(#2373) (#2374)
add 45ea2cc Merge remote-tracking branch 'remotes/upstream/dev' into dev
add 2b0b93b [optimization]：remove duplicate code (#2377)
add 99e0f4f test
add eacc66d mysql and postgresql checkpoint full scale table modify
add ebca4d7 frontend conflict resolve
add 692b7ac datasource.properties modify
add 472723d Fix document errors (#2382)
add 57d4765 Add maven-wrapper support for dolphinscheduler. (#2381)
add 294ec78 Refactor dockerfile (#2384)
add e16a40a Merge remote-tracking branch 'remotes/upstream/dev' into dev
add 7ad7f65 Merge branch 'dev' into dev
add a412859 Merge remote-tracking branch 'origin/dev' into dev
add 18548ad modify datasource.properties postgresql password
add 0afe9a3 modify datasource.properties postgresql password
add f3c8583 mapper add Transactional and rollback
add 2b78010 modify ci_e2e.yml
add d4ad23d postgresql init.sql modify
add af2b318 update pom.xml
add 9dfc93e Exclude .mvn/jvm.config and .mvn/wrapper/maven-wrapper.properties (#2387)
add 6ac5777 Merge remote-tracking branch 'remotes/upstream/dev' into dev
add 43b9906 modify UT
add a1c000e zk properties modify
add f65ab56 UT modify
add 62661f0 init.sql modify
add 46dbace init.sql modify
add 3b56ae2 init.sql modify
add f02e7e8 pom modify
add b581f02 add dao other mapper add in pom.xml
add 4160c21 update UT in pom.xml
add 9de9f18 update UT in pom.xml
add b1a773f update UT in pom.xml
add 66d587c update UT in pom.xml
add b2c92de update UT in pom.xml
add 9d06fe7 update UT in pom.xml
add ff535e7 update UT in pom.xml
add 4c90f04 Merge pull request #2380 from qiaozhanwei/dev
add 733acdf It is necessary to check whether the resource is valid (#2399)
add 320469d Optimize resource tree (#2400)
add 3c9ba0a api server exception management and code optimization (#397) (#2397)
add 5185d28 Change the name of the shell node and modify the parameter transmission method of spark, mr, python, and flink nodes (#2416)
add c881c95 It's to remove `static` of method dataSource,If not remove `static` the transaction will not work. (#2422)
add 0bad7c2 add worker_group field and remove worker_group_id field of the table t_ds_command and t_ds_error_command (#2428)
add 96835eb 1，no worker condition , master will while ture wait for worker startup 2，worker response task status sync wait for result (#2420)
add c4acbdc Repair naming (#2426)
add f218370 Solve the failure to execute non-query sql (#2413)
add 347f05f Update worker_group_id to worker_group (#2433)
add 8b4eb20 fix NPE when grant resource or save process definition (#2434)
add d6798c6 1，task status statistics and process status statistics bug fix (#2357) 2，worker group bug fix (#2430)
add cf08470 Merge branch 'dev' into refactor-worker
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci_backend.yml | 18 +-
.github/workflows/ci_e2e.yml | 75 ++
.github/workflows/ci_frontend.yml | 16 +-
.github/workflows/ci_ut.yml | 3 +-
.gitignore | 1 -
.mvn/jvm.config | 1 +
.mvn/wrapper/MavenWrapperDownloader.java | 117 +++
.mvn/wrapper/maven-wrapper.properties | 2 +
CONTRIBUTING.md | 94 +-
README.md | 30 +-
README_zh_CN.md | 16 +-
ReleaseNotes.md | 55 -
.../common-services/DOLPHIN/1.2.1/alerts.json | 158 +++
.../DOLPHIN/1.2.1/configuration/dolphin-alert.xml | 144 +++
.../configuration/dolphin-application-api.xml | 71 ++
.../1.2.1/configuration/dolphin-application.xml | 467 +++++++++
.../DOLPHIN/1.2.1/configuration/dolphin-common.xml | 232 +++++
.../DOLPHIN/1.2.1/configuration/dolphin-env.xml | 123 +++
.../DOLPHIN/1.2.1/configuration/dolphin-quartz.xml | 131 +++
.../common-services/DOLPHIN/1.2.1/metainfo.xml | 137 +++
.../alerts/alert_dolphin_scheduler_status.py | 124 +++
.../1.2.1/package/scripts/dolphin_alert_service.py | 61 ++
.../1.2.1/package/scripts/dolphin_api_service.py | 70 ++
.../DOLPHIN/1.2.1/package/scripts/dolphin_env.py | 121 +++
.../package/scripts/dolphin_logger_service.py | 61 ++
.../package/scripts/dolphin_master_service.py | 61 ++
.../package/scripts/dolphin_worker_service.py | 60 ++
.../DOLPHIN/1.2.1/package/scripts/params.py | 150 +++
.../DOLPHIN/1.2.1/package/scripts/service_check.py | 31 +
.../DOLPHIN/1.2.1/package/scripts/status_params.py | 23 +
.../1.2.1/package/templates/alert.properties.j2 | 7 +-
.../templates/application-api.properties.j2 | 6 +-
.../package/templates/application.properties.j2 | 6 +-
.../1.2.1/package/templates/common.properties.j2 | 7 +-
.../1.2.1/package/templates/dolphin-daemon.j2 | 41 +-
.../1.2.1/package/templates/quartz.properties.j2 | 7 +-
.../DOLPHIN/1.2.1/quicklinks/quicklinks.json | 26 +
.../DOLPHIN/1.2.1/themes/theme.json | 605 +++++++++++
ambari_plugin/readme.pdf | Bin 0 -> 704750 bytes
ambari_plugin/statcks/DOLPHIN/metainfo.xml | 26 +
charts/README.md | 226 +++++
charts/dolphinscheduler/Chart.yaml | 52 +
charts/dolphinscheduler/README.md | 226 +++++
charts/dolphinscheduler/templates/NOTES.txt | 44 +
charts/dolphinscheduler/templates/_helpers.tpl | 149 +++
.../configmap-dolphinscheduler-alert.yaml | 41 +
.../configmap-dolphinscheduler-master.yaml | 34 +
.../configmap-dolphinscheduler-worker.yaml | 39 +
.../deployment-dolphinscheduler-alert.yaml | 228 +++++
.../templates/deployment-dolphinscheduler-api.yaml | 161 +++
.../deployment-dolphinscheduler-frontend.yaml | 102 ++
charts/dolphinscheduler/templates/ingress.yaml | 43 +
.../templates/pvc-dolphinscheduler-alert.yaml | 24 +-
.../templates/pvc-dolphinscheduler-api.yaml | 24 +-
.../templates/pvc-dolphinscheduler-frontend.yaml | 24 +-
.../templates/secret-external-postgresql.yaml | 18 +-
.../statefulset-dolphinscheduler-master.yaml | 247 +++++
.../statefulset-dolphinscheduler-worker.yaml | 275 +++++
.../templates/svc-dolphinscheduler-api.yaml | 24 +-
.../templates/svc-dolphinscheduler-frontend.yaml | 24 +-
.../svc-dolphinscheduler-master-headless.yaml | 25 +-
.../svc-dolphinscheduler-worker-headless.yaml | 25 +-
charts/dolphinscheduler/values.yaml | 355 +++++++
docker/docker-compose.yml | 15 +
docker/postgres/docker-entrypoint-initdb/init.sql | 39 +-
dockerfile/Dockerfile | 187 ++--
dockerfile/README.md | 333 +++++-
dockerfile/README_zh_CN.md | 328 ++++++
.../env/.dolphinscheduler_env.sh => checkpoint.sh} | 14 +-
.../alert.properties => alert.properties.tpl} | 32 +-
...i.properties => application-api.properties.tpl} | 11 +-
.../conf/dolphinscheduler/common.properties.tpl | 48 +-
.../conf/dolphinscheduler/conf/alert_logback.xml | 49 -
.../dolphinscheduler/conf/apiserver_logback.xml | 60 --
.../conf/application-dao.properties | 103 --
.../dolphinscheduler/conf/combined_logback.xml | 80 --
.../dolphinscheduler/conf/common/common.properties | 59 --
.../conf/common/hadoop/hadoop.properties | 35 -
.../dolphinscheduler/conf/i18n/messages.properties | 252 -----
.../conf/i18n/messages_en_US.properties | 252 -----
.../conf/i18n/messages_zh_CN.properties | 250 -----
.../conf/mail_templates/alert_mail_template.ftl | 17 -
.../conf/dolphinscheduler/conf/master_logback.xml | 52 -
.../dao/mapper/AccessTokenMapper.xml | 33 -
.../dao/mapper/AlertGroupMapper.xml | 47 -
.../dolphinscheduler/dao/mapper/AlertMapper.xml | 26 -
.../dolphinscheduler/dao/mapper/CommandMapper.xml | 43 -
.../dao/mapper/DataSourceMapper.xml | 79 --
.../dao/mapper/DataSourceUserMapper.xml | 30 -
.../dao/mapper/ErrorCommandMapper.xml | 36 -
.../dao/mapper/ProcessDefinitionMapper.xml | 96 --
.../dao/mapper/ProcessInstanceMapMapper.xml | 43 -
.../dao/mapper/ProcessInstanceMapper.xml | 182 ----
.../dolphinscheduler/dao/mapper/ProjectMapper.xml | 68 --
.../dao/mapper/ProjectUserMapper.xml | 36 -
.../dolphinscheduler/dao/mapper/QueueMapper.xml | 42 -
.../dolphinscheduler/dao/mapper/ResourceMapper.xml | 74 --
.../dao/mapper/ResourceUserMapper.xml | 32 -
.../dolphinscheduler/dao/mapper/ScheduleMapper.xml | 58 --
.../dolphinscheduler/dao/mapper/SessionMapper.xml | 32 -
.../dao/mapper/TaskInstanceMapper.xml | 129 ---
.../dolphinscheduler/dao/mapper/TenantMapper.xml | 41 -
.../dolphinscheduler/dao/mapper/UDFUserMapper.xml | 29 -
.../dolphinscheduler/dao/mapper/UdfFuncMapper.xml | 71 --
.../dao/mapper/UserAlertGroupMapper.xml | 31 -
.../dolphinscheduler/dao/mapper/UserMapper.xml | 72 --
.../dao/mapper/WorkerGroupMapper.xml | 40 -
.../dolphinscheduler/conf/zookeeper.properties | 42 -
.../dolphinscheduler/datasource.properties.tpl | 18 +-
.../dolphinscheduler_env.sh} | 13 +-
.../conf/dolphinscheduler/master.properties.tpl | 30 +-
.../quartz.properties => quartz.properties.tpl} | 42 +-
.../conf/dolphinscheduler/worker.properties.tpl | 15 +-
.../conf/dolphinscheduler/zookeeper.properties.tpl | 4 +-
dockerfile/conf/maven/settings.xml | 263 -----
dockerfile/conf/nginx/dolphinscheduler.conf | 4 +-
dockerfile/hooks/build | 31 +-
dockerfile/hooks/build.bat | 56 +
dockerfile/hooks/{build => check} | 25 +-
dockerfile/hooks/push | 2 +-
dockerfile/hooks/push.bat | 23 +
dockerfile/startup-init-conf.sh | 104 ++
dockerfile/startup.sh | 227 ++++-
.../alert/manager/EnterpriseWeChatManager.java | 4 +-
.../alert/template/impl/DefaultHTMLTemplate.java | 1 -
.../alert/utils/EnterpriseWeChatUtils.java | 38 +-
.../dolphinscheduler/alert/utils/ExcelUtils.java | 5 +
.../dolphinscheduler/alert/utils/FuncUtils.java | 2 +-
.../dolphinscheduler/alert/utils/JSONUtils.java | 13 +-
.../dolphinscheduler/alert/utils/MailUtils.java | 49 +-
.../src/main/resources/alert.properties | 1 -
.../alert/utils/EnterpriseWeChatUtilsTest.java | 8 +-
.../alert/utils/ExcelUtilsTest.java | 10 +
.../alert/utils/FuncUtilsTest.java | 2 +-
.../alert/utils/JSONUtilsTest.java | 28 +-
.../alert/utils/MailUtilsTest.java | 8 +-
dolphinscheduler-api/pom.xml | 6 +
.../dolphinscheduler/api/ApiApplicationServer.java | 1 +
.../api/controller/AccessTokenController.java | 129 ++-
.../api/controller/AlertGroupController.java | 24 +-
.../api/controller/DataAnalysisController.java | 4 +-
.../api/controller/DataSourceController.java | 37 +-
.../api/controller/ExecutorController.java | 4 +-
.../api/controller/ProcessInstanceController.java | 10 +-
.../api/controller/ResourcesController.java | 163 ++-
.../api/controller/SchedulerController.java | 4 +-
.../api/controller/TaskInstanceController.java | 8 +-
.../dolphinscheduler/api/dto/ProcessMeta.java | 3 -
.../dolphinscheduler/api/dto/TaskCountDto.java | 36 +-
.../api/dto/resources/Directory.java | 14 +-
.../api/dto/resources/FileLeaf.java | 10 +-
.../api/dto/resources/ResourceComponent.java | 193 ++++
.../api/dto/resources/filter/IFilter.java | 13 +-
.../api/dto/resources/filter/ResourceFilter.java | 100 ++
.../dto/resources/visitor/ResourceTreeVisitor.java | 130 +++
.../api/dto/resources/visitor/Visitor.java | 20 +-
.../apache/dolphinscheduler/api/enums/Status.java | 427 ++++----
.../api/exceptions/ApiException.java | 29 +-
.../api/exceptions/ApiExceptionHandler.java | 52 +-
.../api/interceptor/LoginHandlerInterceptor.java | 11 -
.../api/service/AccessTokenService.java | 3 +
.../api/service/AlertGroupService.java | 43 +-
.../api/service/DataAnalysisService.java | 14 +-
.../api/service/DataSourceService.java | 57 +-
.../api/service/ExecutorService.java | 63 +-
.../api/service/MonitorService.java | 1 -
.../api/service/ProcessDefinitionService.java | 75 +-
.../api/service/ProcessInstanceService.java | 54 +-
.../dolphinscheduler/api/service/QueueService.java | 26 +-
.../api/service/ResourcesService.java | 567 ++++++++---
.../api/service/TaskInstanceService.java | 33 +-
.../api/service/TaskRecordService.java | 4 -
.../api/service/TenantService.java | 4 +-
.../api/service/UdfFuncService.java | 4 +-
.../api/service/UserAlertGroupService.java | 36 +-
.../dolphinscheduler/api/service/UsersService.java | 98 +-
.../api/service/WorkerGroupService.java | 2 +-
.../apache/dolphinscheduler/api/utils/Result.java | 53 +-
.../dolphinscheduler/api/utils/ZooKeeperState.java | 2 +-
.../api/controller/AccessTokenControllerTest.java | 17 +
.../api/controller/DataSourceControllerTest.java | 4 +
.../api/controller/LoginControllerTest.java | 3 +-
.../api/controller/MonitorControllerTest.java | 1 -
.../api/controller/ProjectControllerTest.java | 2 -
.../api/controller/ResourcesControllerTest.java | 25 +-
.../api/controller/TaskRecordControllerTest.java | 7 +-
.../api/controller/UsersControllerTest.java | 2 +-
.../api/controller/WorkerGroupControllerTest.java | 1 -
.../dto/resources/filter/ResourceFilterTest.java | 58 ++
.../resources/visitor/ResourceTreeVisitorTest.java | 82 ++
.../dolphinscheduler/api/enums/StatusTest.java | 14 +-
.../api/exceptions/ApiExceptionHandlerTest.java | 42 +
.../api/service/AlertGroupServiceTest.java | 47 +-
.../api/service/DataAnalysisServiceTest.java | 7 -
.../api/service/ProcessInstanceServiceTest.java | 486 ++++++++-
.../api/service/ResourcesServiceTest.java | 114 ++-
.../api/service/TaskInstanceServiceTest.java | 156 ++-
.../api/service/TenantServiceTest.java | 8 +
.../api/service/UserAlertGroupServiceTest.java | 53 +
.../api/service/UsersServiceTest.java | 52 +-
.../dolphinscheduler/api/utils/CheckUtilsTest.java | 8 +-
.../api/utils/FourLetterWordMainTest.java | 1 -
...keeperMonitorUtilsTest.java => ResultTest.java} | 38 +-
.../api/utils/ZookeeperMonitorUtilsTest.java | 2 +-
dolphinscheduler-common/pom.xml | 2 +-
.../apache/dolphinscheduler/common/Constants.java | 25 +-
.../common/enums/AuthorizationType.java | 12 +-
.../{AuthorizationType.java => DbConnectType.java} | 22 +-
.../enums/{ZKNodeType.java => QueryType.java} | 24 +-
.../common/enums/TaskStateType.java | 2 +-
.../dolphinscheduler/common/enums/TaskType.java | 6 +-
.../dolphinscheduler/common/enums/ZKNodeType.java | 8 +-
.../common/model/DependentItem.java | 10 +
.../dolphinscheduler/common/model/TaskNode.java | 26 +-
.../common/process/ResourceInfo.java | 10 +
.../common/shell/AbstractShell.java | 2 +-
.../common/task/AbstractParameters.java | 3 +-
.../dolphinscheduler/common/task/IParameters.java | 4 +-
.../ConditionsParameters.java} | 42 +-
.../common/task/datax/DataxParameters.java | 49 +-
.../common/task/dependent/DependentParameters.java | 3 +-
.../common/task/flink/FlinkParameters.java | 25 +-
.../common/task/http/HttpParameters.java | 3 +-
.../common/task/mr/MapreduceParameters.java | 16 +-
.../common/task/procedure/ProcedureParameters.java | 3 +-
.../common/task/python/PythonParameters.java | 10 +-
.../common/task/shell/ShellParameters.java | 9 +-
.../common/task/spark/SparkParameters.java | 16 +-
.../common/task/sql/SqlParameters.java | 3 +-
.../common/task/sqoop/SqoopParameters.java | 118 +++
.../sqoop/sources/SourceHdfsParameter.java} | 21 +-
.../task/sqoop/sources/SourceHiveParameter.java | 72 ++
.../task/sqoop/sources/SourceMysqlParameter.java | 136 +++
.../task/sqoop/targets/TargetHdfsParameter.java | 97 ++
.../task/sqoop/targets/TargetHiveParameter.java | 120 +++
.../task/sqoop/targets/TargetMysqlParameter.java | 132 +++
.../task/subprocess/SubProcessParameters.java | 3 +-
.../dolphinscheduler/common/thread/Stopper.java | 2 +-
.../common/thread/ThreadPoolExecutors.java | 36 +-
.../common/thread/ThreadUtils.java | 29 +-
.../common/utils/ConnectionUtils.java | 103 +-
.../dolphinscheduler/common/utils/FileUtils.java | 6 +-
.../dolphinscheduler/common/utils/HttpUtils.java | 12 +-
.../dolphinscheduler/common/utils/IOUtils.java | 19 +-
.../dolphinscheduler/common/utils/IpUtils.java | 5 -
.../dolphinscheduler/common/utils/JSONUtils.java | 25 +-
.../dolphinscheduler/common/utils/LoggerUtils.java | 2 +-
.../dolphinscheduler/common/utils/OSUtils.java | 28 +-
.../common/utils/ParameterUtils.java | 119 ++-
.../common/utils/Preconditions.java | 2 +-
.../common/utils/PropertyUtils.java | 10 +-
.../common/utils/TaskParametersUtils.java | 6 +
.../common/utils/placeholder/PlaceholderUtils.java | 11 +-
.../utils/placeholder/TimePlaceholderUtils.java | 10 +-
.../utils/process/ProcessBuilderForWin32.java | 1071 ++++++++++++++++++++
.../utils/process/ProcessEnvironmentForWin32.java | 292 ++++++
.../common/utils/process/ProcessImplForWin32.java | 787 ++++++++++++++
.../src/main/resources/common.properties | 2 +
.../dolphinscheduler/common/ConstantsTest.java | 26 +-
.../dolphinscheduler/common/os/OSUtilsTest.java | 2 +-
.../common/task/EntityTestUtils.java | 81 ++
.../common/task/FlinkParametersTest.java | 57 ++
.../common/task/SqoopParameterEntityTest.java | 52 +
.../threadutils/ThreadPoolExecutorsTest.java | 2 +-
.../common/utils/FileUtilsTest.java | 17 +-
.../common/utils/HadoopUtilsTest.java | 16 +
.../common/utils/HttpUtilsTest.java | 3 +-
.../dolphinscheduler/common/utils/IpUtilsTest.java | 6 +-
.../common/utils/JSONUtilsTest.java | 22 +-
.../dolphinscheduler/common/utils/OSUtilsTest.java | 24 +-
.../common/utils/ParameterUtilsTest.java | 8 +-
.../common}/utils/PreconditionsTest.java | 3 +-
.../common/utils/SchemaUtilsTest.java | 3 -
.../dolphinscheduler/common/utils/StringTest.java | 6 -
.../common/utils/StringUtilsTest.java | 2 -
.../common/utils/TaskParametersUtilsTest.java | 3 -
.../placeholder/TimePlaceholderUtilsTest.java | 64 +-
.../utils/process/ProcessBuilderForWin32Test.java | 210 ++++
.../process/ProcessEnvironmentForWin32Test.java | 124 +++
.../utils/process/ProcessImplForWin32Test.java | 70 ++
dolphinscheduler-dao/pom.xml | 21 +-
.../org/apache/dolphinscheduler/dao/AlertDao.java | 48 +-
.../apache/dolphinscheduler/dao/MonitorDBDao.java | 12 +-
.../apache/dolphinscheduler/dao/TaskRecordDao.java | 105 +-
.../dao/datasource/BaseDataSource.java | 109 +-
.../dao/datasource/ClickHouseDataSource.java | 47 +-
.../dao/datasource/ConnectionFactory.java | 103 +-
.../dao/datasource/DB2ServerDataSource.java | 45 +-
.../dao/datasource/DataSourceFactory.java | 6 +
.../dao/datasource/HiveDataSource.java | 48 +-
.../dao/datasource/MySQLDataSource.java | 41 +-
.../dao/datasource/OracleDataSource.java | 54 +-
.../dao/datasource/PostgreDataSource.java | 46 +-
.../dao/datasource/SQLServerDataSource.java | 23 +-
.../dao/datasource/SparkDataSource.java | 49 +-
.../dao/datasource/SpringConnectionFactory.java | 5 +-
.../dolphinscheduler/dao/entity/Command.java | 2 +-
.../dolphinscheduler/dao/entity/ErrorCommand.java | 35 +-
.../dao/entity/ProcessDefinition.java | 24 +-
.../dao/entity/ProcessInstance.java | 26 +-
.../dolphinscheduler/dao/entity/Resource.java | 68 +-
.../dolphinscheduler/dao/entity/TaskInstance.java | 77 +-
.../dolphinscheduler/dao/entity/UdfFunc.java | 1 -
.../dao/mapper/ProcessDefinitionMapper.java | 11 +-
.../dao/mapper/ProcessInstanceMapper.java | 15 +
.../dao/mapper/ResourceMapper.java | 66 +-
.../dao/mapper/ResourceUserMapper.java | 9 +
.../dao/mapper/TaskInstanceMapper.java | 6 +-
.../dolphinscheduler/dao/mapper/UdfFuncMapper.java | 20 +-
.../dao/upgrade/MysqlUpgradeDao.java | 28 +-
.../dao/upgrade/PostgresqlUpgradeDao.java | 44 +-
.../dolphinscheduler/dao/upgrade/UpgradeDao.java | 24 +-
.../dao/utils/MysqlPerformance.java | 3 +-
.../dao/utils/PostgrePerformance.java | 3 +-
.../dao/utils/ResourceProcessDefinitionUtils.java | 61 ++
.../src/main/resources/datasource.properties | 8 +-
.../dao/mapper/ProcessDefinitionMapper.xml | 11 +-
.../dao/mapper/ProcessInstanceMapper.xml | 3 +
.../dolphinscheduler/dao/mapper/ResourceMapper.xml | 85 +-
.../dao/mapper/ResourceUserMapper.xml | 13 +
.../dao/mapper/TaskInstanceMapper.xml | 3 +
.../dolphinscheduler/dao/mapper/UdfFuncMapper.xml | 24 +
.../apache/dolphinscheduler/dao/AlertDaoTest.java | 50 +
.../dao/datasource/BaseDataSourceTest.java | 115 +++
.../TaskInstanceTest.java} | 26 +-
.../dao/mapper/CommandMapperTest.java | 25 +-
.../dao/mapper/ConnectionFactoryTest.java | 2 +-
.../dao/mapper/DataSourceUserMapperTest.java | 6 +-
.../dao/mapper/ErrorCommandMapperTest.java | 33 +-
.../dao/mapper/ProcessDefinitionMapperTest.java | 33 +-
.../dao/mapper/ProcessInstanceMapMapperTest.java | 33 +-
.../dao/mapper/ProcessInstanceMapperTest.java | 23 +-
.../dao/mapper/ProjectMapperTest.java | 17 +-
.../dao/mapper/ProjectUserMapperTest.java | 16 +-
.../dao/mapper/QueueMapperTest.java | 15 +-
.../dao/mapper/ResourceMapperTest.java | 117 ++-
.../dao/mapper/ResourceUserMapperTest.java | 40 +-
.../dao/mapper/ScheduleMapperTest.java | 20 +-
.../dao/mapper/SessionMapperTest.java | 9 +-
.../dao/mapper/TaskInstanceMapperTest.java | 9 +-
.../dao/mapper/TenantMapperTest.java | 14 +-
.../dao/mapper/UDFUserMapperTest.java | 14 +-
.../dao/mapper/UdfFuncMapperTest.java | 15 -
.../dao/mapper/UserAlertGroupMapperTest.java | 13 +-
.../dao/mapper/UserMapperTest.java | 96 +-
.../dao/mapper/WorkerGroupMapperTest.java | 135 ---
.../utils/ResourceProcessDefinitionUtilsTest.java | 33 +-
dolphinscheduler-dist/pom.xml | 55 +-
dolphinscheduler-dist/release-docs/LICENSE | 2 +
.../licenses/ui-licenses/LICENSE-normalize | 8 +
.../licenses/ui-licenses/LICENSE-vue-treeselect | 20 +
dolphinscheduler-remote/pom.xml | 18 +-
.../remote/NettyRemotingServer.java | 2 +-
.../dolphinscheduler/remote/command/Ping.java | 5 +-
.../dolphinscheduler/remote/command/Pong.java | 4 +-
.../command/log/GetLogBytesRequestCommand.java | 1 -
.../command/log/RollViewLogRequestCommand.java | 1 -
.../remote/command/log/ViewLogRequestCommand.java | 1 -
.../remote/future/ResponseFuture.java | 8 +-
.../remote/handler/NettyServerHandler.java | 8 +-
.../dolphinscheduler/remote/utils/Constants.java | 3 +-
.../remote/utils/NamedThreadFactory.java | 4 +-
dolphinscheduler-server/pom.xml | 8 +-
.../builder/TaskExecutionContextBuilder.java | 21 +-
.../entity/DependenceTaskExecutionContext.java | 31 +-
.../server/entity/SqoopTaskExecutionContext.java | 116 +++
.../server/entity/TaskExecutionContext.java | 42 +
.../server/log/LoggerRequestProcessor.java | 21 +-
.../server/master/MasterServer.java | 14 +-
.../master/consumer/TaskPriorityQueueConsumer.java | 136 ++-
.../server/master/processor/TaskAckProcessor.java | 26 +-
.../master/processor/TaskResponseProcessor.java | 23 +
.../server/master/runner/MasterExecThread.java | 274 +++--
.../master/runner/MasterSchedulerService.java | 2 +-
.../server/master/runner/MasterTaskExecThread.java | 20 +-
.../master/runner/SubProcessTaskExecThread.java | 6 +-
.../server/monitor/MonitorServer.java | 2 +-
.../server/utils/AlertManager.java | 4 +-
.../server/utils/FlinkArgsUtils.java | 16 +-
.../dolphinscheduler/server/utils/ParamUtils.java | 22 +-
.../server/utils/ProcessUtils.java | 4 +-
.../server/utils/RemoveZKNode.java | 2 +-
.../server/worker/WorkerServer.java | 3 +-
.../worker/processor/TaskCallbackService.java | 13 +-
.../server/worker/runner/TaskExecuteThread.java | 29 +-
.../worker/task/AbstractCommandExecutor.java | 2 +-
.../server/worker/task/AbstractTask.java | 8 +
.../server/worker/task/AbstractYarnTask.java | 5 +
.../server/worker/task/ShellCommandExecutor.java | 40 +-
.../server/worker/task/TaskManager.java | 6 +
.../server/worker/task/TaskProps.java | 2 +-
.../worker/task/conditions/ConditionsTask.java | 152 +++
.../server/worker/task/datax/DataxTask.java | 51 +-
.../worker/task/dependent/DependentExecute.java | 296 ++++++
.../worker/task/dependent/DependentTask.java | 198 ++++
.../server/worker/task/flink/FlinkTask.java | 26 +
.../server/worker/task/http/HttpTask.java | 27 +-
.../server/worker/task/mr/MapReduceTask.java | 44 +-
.../worker/task/processdure/ProcedureTask.java | 23 +-
.../server/worker/task/shell/ShellTask.java | 25 +-
.../server/worker/task/spark/SparkTask.java | 26 +
.../server/worker/task/sql/SqlTask.java | 26 +-
.../server/worker/task/sqoop/SqoopTask.java | 89 ++
.../task/sqoop/generator/CommonGenerator.java | 40 +-
.../task/sqoop/generator/ISourceGenerator.java | 24 +-
.../task/sqoop/generator/ITargetGenerator.java | 24 +-
.../task/sqoop/generator/SqoopJobGenerator.java | 110 ++
.../generator/sources/HdfsSourceGenerator.java | 57 ++
.../generator/sources/HiveSourceGenerator.java | 62 ++
.../generator/sources/MysqlSourceGenerator.java | 119 +++
.../generator/targets/HdfsTargetGenerator.java | 76 ++
.../generator/targets/HiveTargetGenerator.java | 86 ++
.../generator/targets/MysqlTargetGenerator.java | 95 ++
.../dolphinscheduler/server/zk/ZKMasterClient.java | 10 +-
.../src/main/resources/worker.properties | 5 +-
.../server/master/MasterExecThreadTest.java | 5 +-
.../server/utils/FlinkArgsUtilsTest.java | 24 +-
.../server/utils/ProcessUtilsTest.java | 17 +
.../worker/processor/TaskCallbackServiceTest.java | 98 +-
.../server/worker/registry/WorkerRegistryTest.java | 3 +-
.../worker/shell/ShellCommandExecutorTest.java | 4 +-
.../server/worker/sql/SqlExecutorTest.java | 4 +-
.../server/worker/task/datax/DataxTaskTest.java | 43 +-
.../worker/task/dependent/DependentTaskTest.java | 107 +-
.../server/worker/task/shell/ShellTaskTest.java | 240 +++++
.../server/worker/task/spark/SparkTaskTest.java | 2 +-
.../server/worker/task/sqoop/SqoopTaskTest.java | 132 +++
dolphinscheduler-service/pom.xml | 22 +-
.../service/log/LogClientService.java | 8 +-
.../service/permission/PermissionCheck.java | 33 +-
.../service/process/ProcessService.java | 114 ++-
.../service/quartz/QuartzExecutors.java | 9 +-
.../service/zk/AbstractZKClient.java | 4 +-
.../service/zk/DefaultEnsembleProvider.java | 10 +
.../dolphinscheduler/service/zk}/ZKServer.java | 88 +-
.../src/main/resources/zookeeper.properties | 2 +-
.../service/quartz}/cron/CronUtilsTest.java | 3 +-
.../service/zk/DefaultEnsembleProviderTest.java | 65 ++
.../dolphinscheduler/service/zk/ZKServerTest.java | 23 +-
dolphinscheduler-ui/package.json | 6 +-
dolphinscheduler-ui/pom.xml | 55 +
dolphinscheduler-ui/src/js/conf/home/index.js | 1 +
.../src/js/conf/home/pages/dag/_source/config.js | 14 +-
.../src/js/conf/home/pages/dag/_source/dag.scss | 10 +-
.../src/js/conf/home/pages/dag/_source/dag.vue | 134 ++-
.../home/pages/dag/_source/formModel/formModel.vue | 111 +-
.../dag/_source/formModel/tasks/_source/commcon.js | 13 +-
.../_source/formModel/tasks/_source/datasource.vue | 10 +-
.../_source/formModel/tasks/_source/nodeStatus.vue | 227 +++++
.../dag/_source/formModel/tasks/conditions.vue | 275 +++++
.../pages/dag/_source/formModel/tasks/datax.vue | 438 +++++---
.../pages/dag/_source/formModel/tasks/flink.vue | 214 +++-
.../home/pages/dag/_source/formModel/tasks/mr.vue | 219 +++-
.../pages/dag/_source/formModel/tasks/python.vue | 172 +++-
.../pages/dag/_source/formModel/tasks/shell.vue | 171 +++-
.../pages/dag/_source/formModel/tasks/spark.vue | 229 ++++-
.../home/pages/dag/_source/formModel/tasks/sql.vue | 44 +-
.../pages/dag/_source/formModel/tasks/sqoop.vue | 1032 +++++++++++++++++++
.../home/pages/dag/_source/jumpAffirm/index.js | 2 +-
.../home/pages/dag/_source/plugIn/jsPlumbHandle.js | 73 +-
.../js/conf/home/pages/dag/_source/plugIn/util.js | 7 +-
.../js/conf/home/pages/dag/definitionDetails.vue | 4 +-
.../conf/home/pages/dag/img/toobar_CONDITIONS.png | Bin 0 -> 1367 bytes
.../js/conf/home/pages/dag/img/toolbar_SQOOP.png | Bin 0 -> 1157 bytes
.../src/js/conf/home/pages/dag/index.vue | 6 +-
.../pages/list/_source/createDataSource.vue | 24 +-
.../pages/_source/instanceConditions/index.vue | 7 +-
.../pages/definition/pages/list/_source/start.vue | 1 +
.../pages/definition/pages/list/_source/timing.vue | 7 +
.../pages/instance/pages/list/_source/list.vue | 15 +-
.../projects/pages/instance/pages/list/index.vue | 4 +-
.../projects/pages/taskInstance/_source/list.vue | 13 +-
.../pages/projects/pages/taskInstance/index.vue | 6 +-
.../resource/pages/file/pages/_source/common.js | 0
.../resource/pages/file/pages/create/index.vue | 8 +
.../file/pages/{create => createFolder}/index.vue | 93 +-
.../pages/{create => createUdfFolder}/index.vue | 96 +-
.../resource/pages/file/pages/details/index.vue | 2 +-
.../pages/resource/pages/file/pages/edit/index.vue | 40 +-
.../pages/file/pages/list/_source/list.vue | 17 +-
.../pages/file/pages/list/_source/rename.vue | 5 +-
.../pages/resource/pages/file/pages/list/index.vue | 2 +
.../pages/file/pages/{create => subFile}/index.vue | 11 +-
.../file/pages/{create => subFileFolder}/index.vue | 93 +-
.../pages/{list => subdirectory}/_source/list.vue | 26 +-
.../{list => subdirectory}/_source/rename.vue | 3 +-
.../file/pages/{list => subdirectory}/index.vue | 73 +-
.../create => udf/pages/createUdfFolder}/index.vue | 95 +-
.../pages/udf/pages/function/_source/createUdf.vue | 90 +-
.../pages/udf/pages/function/_source/list.vue | 5 +-
.../resource/pages/udf/pages/function/index.vue | 5 +-
.../pages/udf/pages/resource/_source/list.vue | 20 +-
.../pages/udf/pages/resource/_source/rename.vue | 6 +-
.../resource/pages/udf/pages/resource/index.vue | 6 +-
.../{resource => subUdfDirectory}/_source/list.vue | 17 +-
.../_source/rename.vue | 3 +-
.../pages/{resource => subUdfDirectory}/index.vue | 70 +-
.../create => udf/pages/subUdfFolder}/index.vue | 93 +-
.../pages/security/pages/users/_source/list.vue | 63 +-
.../src/js/conf/home/router/index.js | 64 +-
.../src/js/conf/home/store/dag/actions.js | 32 +-
.../src/js/conf/home/store/dag/mutations.js | 2 +
.../src/js/conf/home/store/dag/state.js | 2 +
.../src/js/conf/home/store/resource/actions.js | 21 +
.../src/js/conf/home/store/security/actions.js | 39 +
.../{fileUpdate.vue => fileChildUpdate.vue} | 10 +-
.../js/module/components/fileUpdate/fileUpdate.vue | 6 +-
.../{fileUpdate.vue => resourceChildUpdate.vue} | 10 +-
.../js/module/components/fileUpdate/udfUpdate.vue | 18 +-
.../src/js/module/components/nav/nav.vue | 82 ++
.../components/secondaryMenu/_source/menu.js | 4 +-
.../src/js/module/components/transfer/resource.vue | 134 ++-
.../src/js/module/i18n/locale/en_US.js | 73 +-
.../src/js/module/i18n/locale/zh_CN.js | 75 +-
.../src/js/module/util/routerUtil.js | 6 +-
dolphinscheduler-ui/src/lib/external/config.js | 18 +-
dolphinscheduler-ui/src/lib/external/email.js | 16 +
.../src/sass/common/_animation.scss | 23 +-
.../src/sass/common/_normalize.scss | 303 ------
dolphinscheduler-ui/src/sass/common/index.scss | 3 -
e2e/pom.xml | 153 +++
.../dolphinscheduler/constant/TestConstant.java | 24 +-
.../dolphinscheduler/util/PropertiesReader.java | 49 +
.../apache/dolphinscheduler/util/RedisUtil.java | 204 ++++
.../apache/dolphinscheduler/base/BaseDriver.java | 148 +++
.../org/apache/dolphinscheduler/base/BaseTest.java | 106 ++
.../dolphinscheduler/common/BrowserCommon.java | 390 +++++++
.../apache/dolphinscheduler/common/PageCommon.java | 44 +-
.../apache/dolphinscheduler/data/LoginData.java | 27 +-
.../data/project/CreateProjectData.java | 15 +-
.../data/project/CreateWorkflowData.java | 77 ++
.../data/security/TenantManageData.java | 31 +-
.../data/security/UserManageData.java | 24 +-
.../dolphinscheduler/locator/LoginLocator.java | 22 +-
.../locator/project/CreateProjectLocator.java | 47 +
.../locator/project/CreateWorkflowLocator.java | 183 ++++
.../locator/security/TenantManageLocator.java | 41 +
.../locator/security/UserManageLocator.java | 48 +
.../apache/dolphinscheduler/page/LoginPage.java | 70 ++
.../page/project/CreateProjectPage.java | 74 ++
.../page/project/CreateWorkflowPage.java | 201 ++++
.../page/security/TenantManagePage.java | 79 ++
.../page/security/UserManagePage.java | 72 ++
.../dolphinscheduler/testcase/LoginTest.java | 38 +-
.../testcase/deleteData/DeleteProjectTest.java | 39 +
.../testcase/deleteData/DeleteTenantTest.java | 38 +
.../testcase/deleteData/DeleteUserTest.java | 42 +
.../testcase/deleteData/DeleteWorkflowTest.java | 43 +
.../testcase/project/CreateProjectTest.java | 40 +
.../testcase/project/CreateWorkflowTest.java | 45 +
.../testcase/security/TenantManageTest.java | 34 +-
.../testcase/security/UserManageTest.java | 40 +-
e2e/src/test/resources/config/config.properties | 58 ++
e2e/testng.xml | 44 +
mvnw | 310 ++++++
mvnw.cmd | 182 ++++
pom.xml | 202 ++--
script/dolphinscheduler-daemon.sh | 2 +-
sql/dolphinscheduler-postgre.sql | 38 +-
sql/dolphinscheduler_mysql.sql | 262 +++--
sql/h2.mv.db | Bin 0 -> 110592 bytes
.../1.2.2_schema/mysql/dolphinscheduler_ddl.sql | 210 +++-
.../1.2.2_schema/mysql/dolphinscheduler_dml.sql | 6 +-
.../postgresql/dolphinscheduler_ddl.sql | 211 +++-
.../postgresql/dolphinscheduler_dml.sql | 4 +-
565 files changed, 26221 insertions(+), 8010 deletions(-)
create mode 100644 .github/workflows/ci_e2e.yml
create mode 100644 .mvn/jvm.config
create mode 100644 .mvn/wrapper/MavenWrapperDownloader.java
create mode 100644 .mvn/wrapper/maven-wrapper.properties
delete mode 100644 ReleaseNotes.md
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/alerts.json
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/configuration/dolphin-alert.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/configuration/dolphin-application-api.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/configuration/dolphin-application.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/configuration/dolphin-common.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/configuration/dolphin-env.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/configuration/dolphin-quartz.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/metainfo.xml
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/alerts/alert_dolphin_scheduler_status.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/dolphin_alert_service.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/dolphin_api_service.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/dolphin_env.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/dolphin_logger_service.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/dolphin_master_service.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/dolphin_worker_service.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/params.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/service_check.py
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/package/scripts/status_params.py
copy dockerfile/conf/dolphinscheduler/conf/config/run_config.conf => ambari_plugin/common-services/DOLPHIN/1.2.1/package/templates/alert.properties.j2 (90%)
rename dockerfile/conf/dolphinscheduler/conf/config/install_config.conf => ambari_plugin/common-services/DOLPHIN/1.2.1/package/templates/application-api.properties.j2 (89%)
rename dockerfile/conf/dolphinscheduler/conf/env/.escheduler_env.sh => ambari_plugin/common-services/DOLPHIN/1.2.1/package/templates/application.properties.j2 (85%)
copy dockerfile/conf/dolphinscheduler/conf/config/run_config.conf => ambari_plugin/common-services/DOLPHIN/1.2.1/package/templates/common.properties.j2 (89%)
copy script/dolphinscheduler-daemon.sh => ambari_plugin/common-services/DOLPHIN/1.2.1/package/templates/dolphin-daemon.j2 (62%)
rename dockerfile/conf/dolphinscheduler/conf/config/run_config.conf => ambari_plugin/common-services/DOLPHIN/1.2.1/package/templates/quartz.properties.j2 (89%)
create mode 100755 ambari_plugin/common-services/DOLPHIN/1.2.1/quicklinks/quicklinks.json
create mode 100644 ambari_plugin/common-services/DOLPHIN/1.2.1/themes/theme.json
create mode 100644 ambari_plugin/readme.pdf
create mode 100755 ambari_plugin/statcks/DOLPHIN/metainfo.xml
create mode 100644 charts/README.md
create mode 100644 charts/dolphinscheduler/Chart.yaml
create mode 100644 charts/dolphinscheduler/README.md
create mode 100644 charts/dolphinscheduler/templates/NOTES.txt
create mode 100644 charts/dolphinscheduler/templates/_helpers.tpl
create mode 100644 charts/dolphinscheduler/templates/configmap-dolphinscheduler-alert.yaml
create mode 100644 charts/dolphinscheduler/templates/configmap-dolphinscheduler-master.yaml
create mode 100644 charts/dolphinscheduler/templates/configmap-dolphinscheduler-worker.yaml
create mode 100644 charts/dolphinscheduler/templates/deployment-dolphinscheduler-alert.yaml
create mode 100644 charts/dolphinscheduler/templates/deployment-dolphinscheduler-api.yaml
create mode 100644 charts/dolphinscheduler/templates/deployment-dolphinscheduler-frontend.yaml
create mode 100644 charts/dolphinscheduler/templates/ingress.yaml
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/pvc-dolphinscheduler-alert.yaml (53%)
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/pvc-dolphinscheduler-api.yaml (54%)
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/pvc-dolphinscheduler-frontend.yaml (52%)
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/secret-external-postgresql.yaml (64%)
create mode 100644 charts/dolphinscheduler/templates/statefulset-dolphinscheduler-master.yaml
create mode 100644 charts/dolphinscheduler/templates/statefulset-dolphinscheduler-worker.yaml
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/svc-dolphinscheduler-api.yaml (55%)
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/svc-dolphinscheduler-frontend.yaml (54%)
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/svc-dolphinscheduler-master-headless.yaml (53%)
copy dockerfile/conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => charts/dolphinscheduler/templates/svc-dolphinscheduler-worker-headless.yaml (53%)
create mode 100644 charts/dolphinscheduler/values.yaml
create mode 100644 dockerfile/README_zh_CN.md
copy dockerfile/{conf/dolphinscheduler/conf/env/.dolphinscheduler_env.sh => checkpoint.sh} (81%)
rename dockerfile/conf/dolphinscheduler/{conf/alert.properties => alert.properties.tpl} (68%)
rename dockerfile/conf/dolphinscheduler/{conf/application-api.properties => application-api.properties.tpl} (90%)
copy dolphinscheduler-common/src/main/resources/common.properties => dockerfile/conf/dolphinscheduler/common.properties.tpl (59%)
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/alert_logback.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/apiserver_logback.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/application-dao.properties
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/combined_logback.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/common/common.properties
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/common/hadoop/hadoop.properties
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/i18n/messages.properties
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/i18n/messages_en_US.properties
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/i18n/messages_zh_CN.properties
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/mail_templates/alert_mail_template.ftl
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/master_logback.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/AccessTokenMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/AlertGroupMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/CommandMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/DataSourceMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/DataSourceUserMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ErrorCommandMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ProcessDefinitionMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ProjectMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ProjectUserMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/QueueMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ResourceMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ResourceUserMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/ScheduleMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/SessionMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/TenantMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/UDFUserMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/UdfFuncMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/UserAlertGroupMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/UserMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/org/apache/dolphinscheduler/dao/mapper/WorkerGroupMapper.xml
delete mode 100644 dockerfile/conf/dolphinscheduler/conf/zookeeper.properties
copy dolphinscheduler-dao/src/main/resources/datasource.properties => dockerfile/conf/dolphinscheduler/datasource.properties.tpl (81%)
rename dockerfile/conf/dolphinscheduler/{conf/env/.dolphinscheduler_env.sh => env/dolphinscheduler_env.sh} (65%)
copy dolphinscheduler-server/src/main/resources/worker.properties => dockerfile/conf/dolphinscheduler/master.properties.tpl (52%)
rename dockerfile/conf/dolphinscheduler/{conf/quartz.properties => quartz.properties.tpl} (56%)
copy dolphinscheduler-server/src/main/resources/worker.properties => dockerfile/conf/dolphinscheduler/worker.properties.tpl (76%)
copy dolphinscheduler-service/src/main/resources/zookeeper.properties => dockerfile/conf/dolphinscheduler/zookeeper.properties.tpl (89%)
delete mode 100644 dockerfile/conf/maven/settings.xml
create mode 100644 dockerfile/hooks/build.bat
copy dockerfile/hooks/{build => check} (54%)
create mode 100644 dockerfile/hooks/push.bat
create mode 100644 dockerfile/startup-init-conf.sh
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/_source/common.js => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/Directory.java (80%)
rename dolphinscheduler-ui/src/sass/common/_mixin.scss => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/FileLeaf.java (85%)
create mode 100644 dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/ResourceComponent.java
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/_source/common.js => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/filter/IFilter.java (78%)
create mode 100644 dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/filter/ResourceFilter.java
create mode 100644 dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/visitor/ResourceTreeVisitor.java
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ZKNodeType.java => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/visitor/Visitor.java (75%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/process/ResourceInfo.java => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/exceptions/ApiException.java (66%)
copy dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/threadutils/ThreadPoolExecutorsTest.java => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/exceptions/ApiExceptionHandler.java (50%)
copy dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/DefaultEnsembleProvider.java => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/UserAlertGroupService.java (55%)
create mode 100644 dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/dto/resources/filter/ResourceFilterTest.java
create mode 100644 dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/dto/resources/visitor/ResourceTreeVisitorTest.java
create mode 100644 dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/exceptions/ApiExceptionHandlerTest.java
create mode 100644 dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/UserAlertGroupServiceTest.java
copy dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/utils/{ZookeeperMonitorUtilsTest.java => ResultTest.java} (52%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/{AuthorizationType.java => DbConnectType.java} (80%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/{ZKNodeType.java => QueryType.java} (74%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/{dependent/DependentParameters.java => conditions/ConditionsParameters.java} (57%)
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/sqoop/SqoopParameters.java
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/{enums/ZKNodeType.java => task/sqoop/sources/SourceHdfsParameter.java} (71%)
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/sqoop/sources/SourceHiveParameter.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/sqoop/sources/SourceMysqlParameter.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/sqoop/targets/TargetHdfsParameter.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/sqoop/targets/TargetHiveParameter.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/sqoop/targets/TargetMysqlParameter.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/process/ProcessBuilderForWin32.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/process/ProcessEnvironmentForWin32.java
create mode 100644 dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/process/ProcessImplForWin32.java
copy dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/enums/StatusTest.java => dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/ConstantsTest.java (66%)
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/task/EntityTestUtils.java
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/task/FlinkParametersTest.java
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/task/SqoopParameterEntityTest.java
rename {dolphinscheduler-service/src/test/java => dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common}/utils/PreconditionsTest.java (98%)
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/process/ProcessBuilderForWin32Test.java
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/process/ProcessEnvironmentForWin32Test.java
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/process/ProcessImplForWin32Test.java
create mode 100644 dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtils.java
create mode 100644 dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/AlertDaoTest.java
create mode 100644 dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/datasource/BaseDataSourceTest.java
copy dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/{mapper/ConnectionFactoryTest.java => entity/TaskInstanceTest.java} (65%)
delete mode 100644 dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/mapper/WorkerGroupMapperTest.java
copy dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/utils/ZookeeperMonitorUtilsTest.java => dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtilsTest.java (60%)
create mode 100644 dolphinscheduler-dist/release-docs/licenses/ui-licenses/LICENSE-normalize
create mode 100644 dolphinscheduler-dist/release-docs/licenses/ui-licenses/LICENSE-vue-treeselect
copy dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/DefaultEnsembleProvider.java => dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/entity/DependenceTaskExecutionContext.java (59%)
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/entity/SqoopTaskExecutionContext.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/conditions/ConditionsTask.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/dependent/DependentExecute.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/dependent/DependentTask.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/SqoopTask.java
copy dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/HttpUtilsTest.java => dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/CommonGenerator.java (53%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/IParameters.java => dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/ISourceGenerator.java (60%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/IParameters.java => dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/ITargetGenerator.java (60%)
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/SqoopJobGenerator.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/sources/HdfsSourceGenerator.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/sources/HiveSourceGenerator.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/sources/MysqlSourceGenerator.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/targets/HdfsTargetGenerator.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/targets/HiveTargetGenerator.java
create mode 100644 dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/targets/MysqlTargetGenerator.java
create mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/shell/ShellTaskTest.java
create mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/task/sqoop/SqoopTaskTest.java
rename dolphinscheduler-service/src/{test/java/queue => main/java/org/apache/dolphinscheduler/service/zk}/ZKServer.java (66%)
rename dolphinscheduler-service/src/test/java/{ => org/apache/dolphinscheduler/service/quartz}/cron/CronUtilsTest.java (99%)
create mode 100644 dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/zk/DefaultEnsembleProviderTest.java
copy dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/enums/StatusTest.java => dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/zk/ZKServerTest.java (73%)
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/config.js
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.scss
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/dag.vue
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/commcon.js
create mode 100644 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/_source/nodeStatus.vue
create mode 100644 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/conditions.vue
create mode 100644 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/sqoop.vue
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/plugIn/jsPlumbHandle.js
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/plugIn/util.js
create mode 100644 dolphinscheduler-ui/src/js/conf/home/pages/dag/img/toobar_CONDITIONS.png
create mode 100644 dolphinscheduler-ui/src/js/conf/home/pages/dag/img/toolbar_SQOOP.png
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/_source/common.js
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{create => createFolder}/index.vue (62%)
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{create => createUdfFolder}/index.vue (58%)
mode change 100644 => 100755
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/list/_source/list.vue
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/list/index.vue
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{create => subFile}/index.vue (93%)
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{create => subFileFolder}/index.vue (62%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{list => subdirectory}/_source/list.vue (90%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{list => subdirectory}/_source/rename.vue (96%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/file/pages/{list => subdirectory}/index.vue (61%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/{file/pages/create => udf/pages/createUdfFolder}/index.vue (57%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/udf/pages/{resource => subUdfDirectory}/_source/list.vue (90%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/udf/pages/{resource => subUdfDirectory}/_source/rename.vue (96%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/udf/pages/{resource => subUdfDirectory}/index.vue (63%)
mode change 100644 => 100755
copy dolphinscheduler-ui/src/js/conf/home/pages/resource/pages/{file/pages/create => udf/pages/subUdfFolder}/index.vue (58%)
mode change 100644 => 100755
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/store/dag/mutations.js
mode change 100644 => 100755 dolphinscheduler-ui/src/js/conf/home/store/resource/actions.js
copy dolphinscheduler-ui/src/js/module/components/fileUpdate/{fileUpdate.vue => fileChildUpdate.vue} (96%)
mode change 100644 => 100755 dolphinscheduler-ui/src/js/module/components/fileUpdate/fileUpdate.vue
copy dolphinscheduler-ui/src/js/module/components/fileUpdate/{fileUpdate.vue => resourceChildUpdate.vue} (96%)
mode change 100644 => 100755
mode change 100644 => 100755 dolphinscheduler-ui/src/js/module/i18n/locale/en_US.js
mode change 100644 => 100755 dolphinscheduler-ui/src/js/module/i18n/locale/zh_CN.js
delete mode 100644 dolphinscheduler-ui/src/sass/common/_normalize.scss
create mode 100644 e2e/pom.xml
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ZKNodeType.java => e2e/src/main/java/org/apache/dolphinscheduler/constant/TestConstant.java (73%)
create mode 100644 e2e/src/main/java/org/apache/dolphinscheduler/util/PropertiesReader.java
create mode 100644 e2e/src/main/java/org/apache/dolphinscheduler/util/RedisUtil.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/base/BaseDriver.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/base/BaseTest.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/common/BrowserCommon.java
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/AuthorizationType.java => e2e/src/test/java/org/apache/dolphinscheduler/common/PageCommon.java (54%)
copy dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/utils/Constants.java => e2e/src/test/java/org/apache/dolphinscheduler/data/LoginData.java (61%)
copy dolphinscheduler-ui/src/js/module/util/routerUtil.js => e2e/src/test/java/org/apache/dolphinscheduler/data/project/CreateProjectData.java (67%)
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/data/project/CreateWorkflowData.java
copy dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/utils/Constants.java => e2e/src/test/java/org/apache/dolphinscheduler/data/security/TenantManageData.java (60%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/process/ResourceInfo.java => e2e/src/test/java/org/apache/dolphinscheduler/data/security/UserManageData.java (67%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/process/ResourceInfo.java => e2e/src/test/java/org/apache/dolphinscheduler/locator/LoginLocator.java (61%)
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/locator/project/CreateProjectLocator.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/locator/project/CreateWorkflowLocator.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/locator/security/TenantManageLocator.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/locator/security/UserManageLocator.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/page/LoginPage.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/page/project/CreateProjectPage.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/page/project/CreateWorkflowPage.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/page/security/TenantManagePage.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/page/security/UserManagePage.java
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/IOUtils.java => e2e/src/test/java/org/apache/dolphinscheduler/testcase/LoginTest.java (50%)
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/testcase/deleteData/DeleteProjectTest.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/testcase/deleteData/DeleteTenantTest.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/testcase/deleteData/DeleteUserTest.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/testcase/deleteData/DeleteWorkflowTest.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/testcase/project/CreateProjectTest.java
create mode 100644 e2e/src/test/java/org/apache/dolphinscheduler/testcase/project/CreateWorkflowTest.java
copy dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/FuncUtils.java => e2e/src/test/java/org/apache/dolphinscheduler/testcase/security/TenantManageTest.java (50%)
copy dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/DefaultEnsembleProvider.java => e2e/src/test/java/org/apache/dolphinscheduler/testcase/security/UserManageTest.java (51%)
create mode 100644 e2e/src/test/resources/config/config.properties
create mode 100644 e2e/testng.xml
create mode 100755 mvnw
create mode 100644 mvnw.cmd
create mode 100644 sql/h2.mv.db