Skip to content

Commit b7451df

Browse files
committed
fix: targets gc
1 parent 2660eb4 commit b7451df

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Dockerfile

+1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
FROM ubuntu:latest
2+
RUN apt update && apt install -y curl
23
COPY kvass /kvass
34
ENTRYPOINT ["/kvass"]

pkg/coordinator/rebalance.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -214,8 +214,7 @@ func (c *Coordinator) gcTargets(changeAbleShards []*shardInfo, active map[uint64
214214
// is in_transfer state and had been scraped by other shard
215215
if (tar.TargetState == target.StateInTransfer && st.TargetState == target.StateNormal) ||
216216
// is in normal state and had been scraped by other shard with lower head series
217-
(tar.TargetState == target.StateNormal &&
218-
st.TargetState == target.StateNormal &&
217+
(tar.TargetState == st.TargetState &&
219218
other.runtime.HeadSeries < s.runtime.HeadSeries) {
220219
delete(s.scraping, h)
221220
break

0 commit comments

Comments
 (0)