You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by bo...@apache.org on 2019/06/24 02:14:21 UTC
[kylin] 01/02: KYLIN-3933 Invalid replica set cache after status
updated
This is an automated email from the ASF dual-hosted git repository.
boblu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
commit 37a1a802375e0dcaa4179317eceb88afdcc58a40
Author: nichunen <ni...@apache.org>
AuthorDate: Sat Jun 22 22:45:40 2019 +0800
KYLIN-3933 Invalid replica set cache after status updated
---
.../main/java/org/apache/kylin/rest/service/StreamingV2Service.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/StreamingV2Service.java b/server-base/src/main/java/org/apache/kylin/rest/service/StreamingV2Service.java
index 15d9bc3..53bf266 100644
--- a/server-base/src/main/java/org/apache/kylin/rest/service/StreamingV2Service.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/service/StreamingV2Service.java
@@ -284,21 +284,25 @@ public class StreamingV2Service extends BasicService {
@PreAuthorize(Constant.ACCESS_HAS_ROLE_ADMIN)
public void createReplicaSet(ReplicaSet rs) {
getCoordinatorClient().createReplicaSet(rs);
+ clusterStateCache.invalidate("cluster_state");
}
@PreAuthorize(Constant.ACCESS_HAS_ROLE_ADMIN)
public void removeReplicaSet(int rsID) {
getCoordinatorClient().removeReplicaSet(rsID);
+ clusterStateCache.invalidate("cluster_state");
}
@PreAuthorize(Constant.ACCESS_HAS_ROLE_ADMIN)
public void addNodeToReplicaSet(Integer replicaSetID, String nodeID) {
getCoordinatorClient().addNodeToReplicaSet(replicaSetID, nodeID);
+ clusterStateCache.invalidate("cluster_state");
}
@PreAuthorize(Constant.ACCESS_HAS_ROLE_ADMIN)
public void removeNodeFromReplicaSet(Integer replicaSetID, String nodeID) {
getCoordinatorClient().removeNodeFromReplicaSet(replicaSetID, nodeID);
+ clusterStateCache.invalidate("cluster_state");
}
@PreAuthorize(Constant.ACCESS_HAS_ROLE_ADMIN)