Skip to content

Commit 288f0b9

Browse files
committed
small fix
1 parent 63f0221 commit 288f0b9

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

worker/cdc_ee.go

-4
Original file line numberDiff line numberDiff line change
@@ -201,10 +201,6 @@ func (cdc *CDC) processCDCEvents() {
201201
// In this way, even if leadership changes,
202202
// new leader will know which new events are to be sent.
203203
//
204-
// In case of ludicrous mode, this has been achieved using seenIndex.
205-
// We send the events to the sink as soon as we get the proposal.Mutation
206-
// in ludicrous mode. Hence, this job will manage seenIndex across the cluster
207-
// to manage from which index we have to send the events.
208204
checkAndSendCDCEvents := func() error {
209205
first, err := groups().Node.Store.FirstIndex()
210206
x.Check(err)

worker/draft.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -1538,8 +1538,8 @@ func (n *node) calculateSnapshot(startIdx, lastIdx, minPendingStart uint64) (*pb
15381538
_, span := otrace.StartSpan(n.ctx, "Calculate.Snapshot",
15391539
otrace.WithSampler(otrace.AlwaysSample()))
15401540
defer span.End()
1541-
15421541
discardN := 1
1542+
15431543
// We do not need to block snapshot calculation because of a pending stream. Badger would have
15441544
// pending iterators which would ensure that the data above their read ts would not be
15451545
// discarded. Secondly, if a new snapshot does get calculated and applied, the follower can just

0 commit comments

Comments
 (0)