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 6d087cc [Feature][JsonSplit] fix processDefinitionService ut and bug
(#4894)
add 73b2d5b [Fix-4843] Rename WORKER_GROUP to WORKER_GROUPS (#4843)
(#4856)
add d217937 [Improvement][alert plugin]fix alert massage (#4880)
add fbe0eda Update README.md (#4882)
new 8720c26 Merge remote-tracking branch 'upstream/dev' into spilit
new df0e3e9 Merge branch 'json_split' of
https://github.com/apache/incubator-dolphinscheduler into spilit
add e008781 rpc
add fd05153 rpc
add e247284 rpc
add 2327da7 rpc
add c78f5e2 rpc
add 3bcb892 rpc
add d2f136b rpc
add 74a4de4 rpc
add ed164fe rpc
add 985a4fc rpc
add 0db1906 rpc test
add 9d3c37e rpc
add e950b65 rpc
add 4ae52cb rpc
add 939ee1f rpc
add 6fafcc2 rpc
add 21cec62 test
add ff67386 update
add 91b27b7 Merge branch 'dev' into rpc
add 230f3a3 add rpc config
add a2d245d add rpc config
add 9f58eb7 add rpc config
add a97f781 add license
add 4325410 add license
add 958d2fd add license
add d1f4e6a add IUserService Interface
add ea97ed1 fix bug and add license
add a63c2c6 fix bug
add 246332b fix bug
add 967ab64 fix bug and code style
add 7a976f4 fix code smell
add d1658e9 fix init rpc request error
add 0f62284 add rpc protocol
add 825870c Rename LICENSE-protostuff-api.txt to LICENSE-protostuff.txt
add efde946 Delete LICENSE-protostuff-collectionschema.txt
add 3a8df41 Delete LICENSE-protostuff-core.txt
add 3c18d63 Delete LICENSE-protostuff-runtime.txt
add 0a92a53 add jmh test
add 93fb043 code style
add 54ca216 rpc protocol
add 392136c rpc protocol
add 4578079 rpc protocol
add d3a1da4 code style
add 3ba0321 code style
add c9daf6a async not needed callback
add 50dbe7d async not needed callback
add 98d2406 async not needed callback
add fba133c move license
add dad9436 Merge branch 'dev' into rpc
add 12c1347 rpc
add 91304e6 test
add 1c047e4 test
add d30500f test
add b4c7e35 Merge branch 'dev' into rpc
add dc20d6a add NOTICE
add c6b7eb3 Merge pull request #4565 from CalvinKirs/rpc
add 40031d8 Fix Slack invite links
add 5cadf4e Merge pull request #4892 from jbampton/fix-slack-links
add 90e9d41 chore: fix case of GitHub and JavaScript
add a75793d Merge pull request #4890 from jbampton/fix-word-case
add 3b562f5 [Fix-4886][Docker] Fix invalid volume specification in Windows
add b8788f0 Merge pull request #4887 from
chengshiwen/fix-docker-invalid-volume
add d170b92 Update the url for `QuickStart in Docker` (#4895)
add a388b68 Optimize HashMap Initial Capacity. (#4896)
add 139211f Reduce queries after successful project creation. (#4901)
add 6911a39 [Improvement][Docker] Add FAQ in readme
add 27d7b43 [Improvement][Docker] Add default login username and password
in readme
add 5e58b3a [Improvement][K8s] Update outdated readme
add 83ea710 [Improvement][K8s] Add FAQ in readme
add c200911 [Improvement][Docker] Rename worker group to worker groups
add 3ff4e21 [Improvement][K8s] Add readme to use namespace, access ui and
delete pv
add 4cab409 [Improvement][Docker] Update environment variables
add da6e150 [Improvement][Docker] Add DOLPHINSCHEDULER_OPTS for docker
compose/swarm
add 5adf1db [Improvement][Docker] Update readme
add bfc5d1e Merge pull request #4875 from chengshiwen/improve-docker-faq
add a25c397 [Improvement][README] Update official website link in readme
(#4903)
new 2603d52 Merge remote-tracking branch 'upstream/dev' into spilit
The 3 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:
.github/ISSUE_TEMPLATE/feature_request.md | 2 +-
.github/ISSUE_TEMPLATE/improvement_suggestion.md | 2 +-
.github/PULL_REQUEST_TEMPLATE.md | 2 +-
README.md | 37 +--
README_zh_CN.md | 55 ++--
docker/build/Dockerfile | 3 +-
docker/build/README.md | 195 +++++++++++++-
docker/build/README_zh_CN.md | 194 +++++++++++++-
.../conf/dolphinscheduler/common.properties.tpl | 2 +-
...cheduler_env.sh => dolphinscheduler_env.sh.tpl} | 18 +-
.../conf/dolphinscheduler/worker.properties.tpl | 4 +-
docker/build/startup-init-conf.sh | 21 +-
docker/docker-swarm/docker-compose.yml | 31 ++-
docker/docker-swarm/docker-stack.yml | 39 ++-
docker/docker-swarm/dolphinscheduler_env.sh | 28 --
docker/kubernetes/dolphinscheduler/README.md | 290 +++++++++++++++------
.../configmap-dolphinscheduler-worker.yaml | 2 +-
.../statefulset-dolphinscheduler-worker.yaml | 4 +-
docker/kubernetes/dolphinscheduler/values.yaml | 2 +-
.../plugin/alert/script/ScriptAlertChannel.java | 2 +-
.../api/controller/BaseController.java | 4 +-
.../api/service/impl/ProjectServiceImpl.java | 3 +-
.../common/utils/CollectionUtils.java | 9 +-
dolphinscheduler-dist/release-docs/LICENSE | 13 +-
dolphinscheduler-dist/release-docs/NOTICE | 28 ++
...NSE-jamon-runtime.txt => LICENSE-javassist.txt} | 0
...NSE-xml-apis.txt => LICENSE-protostuff-api.txt} | 0
...SE-xml-apis.txt => LICENSE-protostuff-core.txt} | 0
...xml-apis.txt => LICENSE-protostuff-runtime.txt} | 0
...txt => LICENSE-protostuff.collectionschema.txt} | 0
.../release-docs/licenses/LICENSE-reflections.txt | 13 +
dolphinscheduler-microbench/pom.xml | 4 +
.../microbench/common/IUserService.java | 20 +-
.../microbench/common/RpcTest.java | 77 ++++++
.../microbench/common/UserCallback.java | 15 +-
.../microbench/common/UserService.java | 16 +-
dolphinscheduler-remote/pom.xml | 26 ++
.../remote/codec/NettyDecoder.java | 36 +--
.../dolphinscheduler/remote/utils/Constants.java | 2 +-
.../org/apache/dolphinscheduler/rpc/base/Rpc.java | 43 ++-
.../dolphinscheduler/rpc/base/RpcService.java | 19 +-
.../rpc/client/ConsumerConfig.java | 87 +++++++
.../rpc/client/ConsumerConfigCache.java | 26 +-
.../rpc/client/ConsumerInterceptor.java | 124 +++++++++
.../dolphinscheduler/rpc/client/IRpcClient.java | 16 +-
.../dolphinscheduler/rpc/client/RpcClient.java | 37 ++-
.../rpc/client/RpcRequestCache.java | 32 ++-
.../rpc/client/RpcRequestTable.java | 32 ++-
.../dolphinscheduler/rpc/codec/NettyDecoder.java | 82 ++++++
.../dolphinscheduler/rpc/codec/NettyEncoder.java | 52 ++++
.../common/AbstractRpcCallBack.java} | 13 +-
.../rpc/common/ConsumerConfigConstants.java | 16 +-
.../rpc/common/RequestEventType.java | 34 +--
.../rpc/common/ResponseEventType.java | 34 +--
.../dolphinscheduler/rpc/common/RpcRequest.java | 84 ++++++
.../common/RpcResponse.java} | 46 ++--
.../rpc/common/ThreadPoolManager.java | 43 ++-
.../dolphinscheduler/rpc/config/ServiceBean.java | 71 +++++
.../dolphinscheduler/rpc/future/RpcFuture.java | 87 +++++++
.../dolphinscheduler/rpc/protocol/EventType.java | 27 +-
.../rpc/protocol/MessageHeader.java | 77 ++++++
.../dolphinscheduler/rpc/protocol/RpcProtocol.java | 26 +-
.../rpc/protocol/RpcProtocolConstants.java | 12 +-
.../dolphinscheduler/rpc/remote/NettyClient.java | 253 ++++++++++++++++++
.../rpc/remote/NettyClientHandler.java | 120 +++++++++
.../remote/NettyServer.java} | 102 ++------
.../rpc/remote/NettyServerHandler.java | 114 ++++++++
.../rpc/serializer/ProtoStuffSerializer.java | 60 +++++
.../rpc/serializer/ProtoStuffUtils.java | 68 +++++
.../rpc/serializer/RpcSerializer.java | 41 +--
.../rpc/serializer/Serializer.java | 19 +-
.../apache/dolphinscheduler/rpc/IUserService.java | 25 +-
.../org/apache/dolphinscheduler/rpc/RpcTest.java | 64 +++++
.../apache/dolphinscheduler/rpc/UserCallback.java | 16 +-
.../apache/dolphinscheduler/rpc/UserService.java | 31 ++-
.../src/main/resources/worker.properties | 2 +-
.../service/quartz/QuartzExecutors.java | 2 +-
.../dolphinscheduler/common/BrowserCommon.java | 2 +-
pom.xml | 30 +++
tools/dependencies/check-LICENSE.sh | 2 +-
tools/dependencies/known-dependencies.txt | 6 +
81 files changed, 2658 insertions(+), 618 deletions(-)
rename docker/build/conf/dolphinscheduler/env/{dolphinscheduler_env.sh =>
dolphinscheduler_env.sh.tpl} (72%)
delete mode 100755 docker/docker-swarm/dolphinscheduler_env.sh
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-jamon-runtime.txt =>
LICENSE-javassist.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff-api.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff-core.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff-runtime.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff.collectionschema.txt} (100%)
create mode 100644
dolphinscheduler-dist/release-docs/licenses/LICENSE-reflections.txt
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/host/assign/Selector.java
=>
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/IUserService.java
(74%)
create mode 100644
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/RpcTest.java
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/Directory.java
=>
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/UserCallback.java
(78%)
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/Directory.java
=>
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/UserService.java
(72%)
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/exceptions/ApiException.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/base/Rpc.java
(52%)
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/exceptions/ApiException.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/base/RpcService.java
(71%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/ConsumerConfig.java
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptParamsConstants.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/ConsumerConfigCache.java
(60%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/ConsumerInterceptor.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DependResult.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/IRpcClient.java
(79%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/host/RoundRobinHostManager.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/RpcClient.java
(57%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/RpcRequestCache.java
(60%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptParamsConstants.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/RpcRequestTable.java
(52%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyDecoder.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyEncoder.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/{remote/future/InvokeCallback.java
=> rpc/common/AbstractRpcCallBack.java} (73%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ArgsUtils.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/ConsumerConfigConstants.java
(72%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/RequestEventType.java
(65%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/ResponseEventType.java
(64%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/RpcRequest.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/{remote/command/alert/AlertSendResponseResult.java
=> rpc/common/RpcResponse.java} (54%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/host/RoundRobinHostManager.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/ThreadPoolManager.java
(52%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/config/ServiceBean.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/EventType.java
(63%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/MessageHeader.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocol.java
(66%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ArgsUtils.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocolConstants.java
(76%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/remote/NettyClient.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/remote/NettyClientHandler.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/{remote/NettyRemotingServer.java
=> rpc/remote/NettyServer.java} (66%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/remote/NettyServerHandler.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/ProtoStuffSerializer.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/ProtoStuffUtils.java
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/RpcSerializer.java
(54%)
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskRecordStatus.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/Serializer.java
(77%)
copy
dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/DataType.java
=>
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/IUserService.java
(72%)
create mode 100644
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/RpcTest.java
copy
dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/plugin/PluginManagerTest.java
=>
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/UserCallback.java
(71%)
copy
dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/plugin/PluginManagerTest.java
=>
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/UserService.java
(55%)
