This is an automated email from the ASF dual-hosted git repository.
leonbao pushed a change to branch json_split
in repository
https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git.
from 0c2b065 [Feature][jsonsplit]modify listResources mothod and remove
getResourceIds mothod (#4928)
add 54fc458 [Fix-4908][UI] Fix dependent task item cannot delete and
select (#4909)
add 43ba29a [Improvement-4624] When the server exist in the dead server
list of zk,need stop service byself (#4626)
add d01b2c4 [Fix-4921][UI] Fix download log get return 404 (#4922)
add ba2bb22 [Improvement][API] create project success return project id
(#4927)
add 397c781 [Fix-4929][dao]fix ClassCastException when run hive sql with
udf (#4930)
add f6088f2 Optimize code comments (#4933)
add ccd8aae [Improvement][Server] Improve dependent task unit tests
(#4911)
add 5bfe3fc [Fix][SqlTask] fix hive sqltask invalid connection
parameters. (#4917)
new dcf9792 merge from dev 2021-03-03
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../api/service/impl/ProjectServiceImpl.java | 3 +-
.../dao/datasource/BaseDataSource.java | 26 ++
.../dao/datasource/HiveDataSource.java | 17 +
.../dolphinscheduler/dao/entity/UdfFunc.java | 2 +-
.../dao/datasource/BaseDataSourceTest.java | 34 ++
.../dao/datasource/HiveDataSourceTest.java | 2 +-
.../server/master/MasterServer.java | 69 +++-
.../dispatch/host/LowerWeightHostManager.java | 2 +-
.../server/master/registry/MasterRegistry.java | 38 +-
.../server/registry/HeartBeatTask.java | 33 +-
.../server/registry/ZookeeperNodeManager.java | 4 +-
.../server/registry/ZookeeperRegistryCenter.java | 92 ++++-
.../server/worker/WorkerServer.java | 74 ++--
.../server/worker/registry/WorkerRegistry.java | 36 +-
.../server/worker/task/sql/SqlTask.java | 3 +
.../dolphinscheduler/server/zk/ZKMasterClient.java | 12 +-
.../server/master/DependentTaskTest.java | 447 +++++++++++++++------
.../consumer/TaskPriorityQueueConsumerTest.java | 4 +-
.../server/master/registry/MasterRegistryTest.java | 7 +-
.../registry/ZookeeperRegistryCenterTest.java | 61 +++
.../worker/processor/TaskCallbackServiceTest.java | 4 +-
.../server/worker/registry/WorkerRegistryTest.java | 44 +-
.../service/zk/AbstractZKClient.java | 83 +---
.../service/zk/RegisterOperator.java | 155 +++++++
.../service/zk/ZookeeperCachedOperator.java | 3 +
.../service/zk/RegisterOperatorTest.java | 116 ++++++
.../conf/home/pages/dag/_source/formModel/log.vue | 2 +-
.../formModel/tasks/_source/dependItemList.vue | 34 +-
.../_source/formModel/tasks/_source/nodeStatus.vue | 2 +
.../dag/_source/formModel/tasks/conditions.vue | 1 -
.../resource/pages/file/pages/details/index.vue | 2 +-
pom.xml | 3 +
32 files changed, 1042 insertions(+), 373 deletions(-)
create mode 100644
dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/registry/ZookeeperRegistryCenterTest.java
create mode 100644
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/RegisterOperator.java
create mode 100644
dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/zk/RegisterOperatorTest.java
