[DSIP-9][Feature][Server] Add Raft consensus algorithm registry, remove zookeeper dependency#11144
[DSIP-9][Feature][Server] Add Raft consensus algorithm registry, remove zookeeper dependency#11144zhuxt2015 wants to merge 9 commits intoapache:devfrom
Conversation
Codecov Report
@@ Coverage Diff @@
## dev #11144 +/- ##
============================================
- Coverage 40.49% 40.17% -0.32%
- Complexity 4887 4951 +64
============================================
Files 951 988 +37
Lines 37201 37712 +511
Branches 4080 4145 +65
============================================
+ Hits 15065 15152 +87
- Misses 20613 21021 +408
- Partials 1523 1539 +16
Help us with your feedback. Take ten seconds to tell us how you rate us. |
|
please add related license, refer to https://dolphinscheduler.apache.org/en-us/community/development/DS-License.html |
2314e10 to
a9504bb
Compare
...aft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/EphemeralNodeManager.java
Outdated
Show resolved
Hide resolved
...aft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/EphemeralNodeManager.java
Outdated
Show resolved
Hide resolved
...aft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/EphemeralNodeManager.java
Outdated
Show resolved
Hide resolved
...gistry-raft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/RaftRegistry.java
Show resolved
Hide resolved
...aft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/EphemeralNodeManager.java
Outdated
Show resolved
Hide resolved
...aft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/EphemeralNodeManager.java
Outdated
Show resolved
Hide resolved
...aft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/EphemeralNodeManager.java
Outdated
Show resolved
Hide resolved
Done. |
|
SonarCloud Quality Gate failed. |
| <artifactId>jersey-core</artifactId> | ||
| <groupId>com.sun.jersey</groupId> | ||
| </exclusion> | ||
| <exclusion> |
There was a problem hiding this comment.
It's better to define the protobuf-java version in bom. Then you don't need to exclude it in everywhere.
...cheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-raft/README.md
Show resolved
Hide resolved
...cheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-raft/README.md
Show resolved
Hide resolved
...gistry-raft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/RaftRegistry.java
Show resolved
Hide resolved
...gistry-raft/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/RaftRegistry.java
Show resolved
Hide resolved
...t/src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/RaftRegistryProperties.java
Show resolved
Hide resolved
| @ConfigurationProperties(prefix = "registry") | ||
| public class RaftRegistryProperties { | ||
| private String clusterName; | ||
| private String serverAddressList; |
There was a problem hiding this comment.
Do we need to add validator for this class?
...src/main/java/org/apache/dolphinscheduler/plugin/registry/raft/SubscribeListenerManager.java
Show resolved
Hide resolved
.../main/java/org/apache/dolphinscheduler/plugin/registry/raft/RaftConnectionStateListener.java
Show resolved
Hide resolved
.../main/java/org/apache/dolphinscheduler/plugin/registry/raft/RaftConnectionStateListener.java
Show resolved
Hide resolved
|
Hi @zhuxt2015 please check the review comment and resolve conflicts. |
fa5e69c to
43e6ebe
Compare
OK, testing in local |
|
@zhuxt2015 This is a significant improvement. By using jRaft as registry plugin, it seems registry center will no more need to rely on external third-party components such as mysql, etcd, or zookeeper. May I ask whether you have time to follow up with this PR? Thanks : ) |
|
@zhuxt2015 Hi, would u like to continue with this work? If you are no more interested or do not have time for it, do u mind me helping with the rest? |
|
This pull request has been automatically marked as stale because it has not had recent activity for 120 days. It will be closed in 7 days if no further activity occurs. |
|
This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encouraged to continue work on this pull request. |








Purpose of the pull request
fix #10874
Brief change log
Verify this pull request
This pull request is code cleanup without any test coverage.
(or)
This pull request is already covered by existing tests, such as (please describe tests).
(or)
This change added tests and can be verified as follows: