Skip to content

Commit

Permalink
Revert "ensure only one record per pid in DynamoDBOffsetStore saveTim…
Browse files Browse the repository at this point in the history
…estampOffsets"

This reverts commit d8dd7bf.
  • Loading branch information
leviramsey committed Nov 22, 2024
1 parent be9bb85 commit 04c6ce4
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -391,8 +391,9 @@ private[projection] class DynamoDBOffsetStore(
records
.groupBy(_.pid)
.valuesIterator
.map(_.maxBy(_.seqNr))
.filterNot(oldState.isDuplicate _)
.collect {
case recordsByPid if !oldState.isDuplicate(recordsByPid.last) => recordsByPid.last
}
.toVector
}
}
Expand Down

0 comments on commit 04c6ce4

Please sign in to comment.