This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch alert_plugin_design
in repository
https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git.
discard 2c67b41 [Feature-3189][alert,spi,dao,plugin-api] base code of
dolphinscheduler spi and alert plugin implement (#3601)
discard ff3d3f0 [feature][ui]Alert plugin design (#3734)
discard 94ef848 fix
discard 2e486ca fix
discard 99abbf7 Modify node version
discard efec7f3 Add form-create plug-in and alarm group management add sample
demo
discard 8de96ac [feature-3665][ui]Add element-ui (#3666)
add 8ef0431 done (#3752)
add 375ec12 [Feature-3773][processInstance, taskInstance] Change title
name : Replacement System.currentTimeMillis () (#3774)
add db663a1 [Improvement][remote]load balance warm up (#3770)
add 3b58145 [Feature]Add Python task "task variable / result transfer"
implementation (#3659)
add eb597e6 [Improvement][API] simplify with stream (#3764)
add 11d3c2c [Improvement][server]lower weight round robin support weight
(#3768)
new a9e3792 [feature-3665][ui]Add element-ui (#3666)
new 2e117bb Add form-create plug-in and alarm group management add sample
demo
new 50bfb30 Modify node version
new 9221b24 fix
new 8ac1462 fix
new 3d5c34a [feature][ui]Alert plugin design (#3734)
new 392e9f5 [Feature-3189][alert,spi,dao,plugin-api] base code of
dolphinscheduler spi and alert plugin implement (#3601)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2c67b41)
\
N -- N -- N refs/heads/alert_plugin_design (392e9f5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 7 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:
.../service/impl/ProcessDefinitionServiceImpl.java | 37 ++--
.../api/service/ProcessDefinitionServiceTest.java | 84 ++++++++
.../apache/dolphinscheduler/common/Constants.java | 4 +
.../dolphinscheduler/common/task/TaskParams.java | 78 ++++++++
.../dolphinscheduler/common/utils/DateUtils.java | 10 +
.../common/utils/VarPoolUtils.java | 124 ++++++++++++
.../common/utils/DateUtilsTest.java | 19 +-
.../common/utils/VarPoolUtilsTest.java | 73 +++++++
.../dao/entity/ProcessInstance.java | 213 ++++++++++++++-------
.../dolphinscheduler/dao/entity/TaskInstance.java | 12 ++
.../remote/command/TaskExecuteResponseCommand.java | 12 ++
.../dolphinscheduler/remote/utils/Constants.java | 5 +
.../apache/dolphinscheduler/remote/utils/Host.java | 48 ++++-
.../master/dispatch/host/assign/HostWeight.java | 44 +++--
.../host/assign/LowerWeightRoundRobin.java | 13 +-
.../master/processor/TaskResponseProcessor.java | 3 +-
.../master/processor/queue/TaskResponseEvent.java | 18 +-
.../processor/queue/TaskResponseService.java | 3 +-
.../server/master/runner/MasterExecThread.java | 15 +-
.../server/worker/registry/WorkerRegistry.java | 44 +++--
.../server/worker/runner/TaskExecuteThread.java | 1 +
.../worker/task/AbstractCommandExecutor.java | 15 +-
.../server/worker/task/AbstractTask.java | 13 ++
.../server/worker/task/python/PythonTask.java | 189 +++++++++---------
.../host/assign/LowerWeightRoundRobinTest.java | 51 ++++-
.../dispatch/host/assign/RandomSelectorTest.java | 16 +-
.../host/assign/RoundRobinSelectorTest.java | 70 ++++---
.../dolphinscheduler/server/utils/HostTest.java | 29 ++-
.../service/process/ProcessService.java | 5 +-
pom.xml | 2 +
sql/dolphinscheduler-postgre.sql | 2 +
sql/dolphinscheduler_mysql.sql | 2 +
.../1.3.3_schema/mysql/dolphinscheduler_ddl.sql | 40 ++++
.../postgresql/dolphinscheduler_ddl.sql | 36 ++++
tools/dependencies/check-LICENSE.sh | 4 +-
35 files changed, 1024 insertions(+), 310 deletions(-)
create mode 100644
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/TaskParams.java
create mode 100644
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/VarPoolUtils.java
create mode 100644
dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/VarPoolUtilsTest.java
copy
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/remote/NettyUtilTest.java
=>
dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/utils/HostTest.java
(58%)
