fix(server): allow higher term shard deleting

streamnative · Nov 4, 2024 · 7f284bc · 7f284bc
1 parent 9a1b781
commit 7f284bc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/server/follower_controller.go b/server/follower_controller.go
@@ -749,7 +749,7 @@ func (fc *followerController) DeleteShard(request *proto.DeleteShardRequest) (*p
 	fc.Lock()
 	defer fc.Unlock()
 
-	if request.Term != fc.term {
+	if request.Term < fc.term {
 		fc.log.Warn("Invalid term when deleting shard",
 			slog.Int64("follower-term", fc.term),
 			slog.Int64("new-term", request.Term))

diff --git a/server/leader_controller.go b/server/leader_controller.go
@@ -1090,7 +1090,7 @@ func (lc *leaderController) DeleteShard(request *proto.DeleteShardRequest) (*pro
 	lc.Lock()
 	defer lc.Unlock()
 
-	if request.Term != lc.term {
+	if request.Term < lc.term {
 		lc.log.Warn("Invalid term when deleting shard",
 			slog.Int64("follower-term", lc.term),
 			slog.Int64("new-term", request.Term))