fix

swalrus1 · swalrus1 · commit e18e24fd7bce · 2025-03-11T12:28:23.000+03:00
diff --git a/ydb/core/tx/columnshard/engines/reader/duplicates/manager.cpp b/ydb/core/tx/columnshard/engines/reader/duplicates/manager.cpp
@@ -27,8 +27,8 @@ std::vector<ui64> TRangeIndex::FindIntersections(const ui64 p) const {
 
 void TIntervalCounter::PropagateDelta(const TPosition& node) {
     if (PropagatedDeltas[node.GetIndex()]) {
-        Count[node.GetIndex() * 2 + 1] += PropagatedDeltas[node.GetIndex()] * node.IntervalSize();
-        Count[node.GetIndex() * 2 + 2] += PropagatedDeltas[node.GetIndex()] * node.IntervalSize();
+        Count[node.GetIndex() * 2 + 1] += PropagatedDeltas[node.GetIndex()] * (node.IntervalSize() / 2);
+        Count[node.GetIndex() * 2 + 2] += PropagatedDeltas[node.GetIndex()] * (node.IntervalSize() / 2);
         PropagatedDeltas[node.GetIndex()] = 0;
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -27,8 +27,8 @@ std::vector<ui64> TRangeIndex::FindIntersections(const ui64 p) const {`
`27`	`27`
`28`	`28`	`void TIntervalCounter::PropagateDelta(const TPosition& node) {`
`29`	`29`	`if (PropagatedDeltas[node.GetIndex()]) {`
`30`		`- Count[node.GetIndex() * 2 + 1] += PropagatedDeltas[node.GetIndex()] * node.IntervalSize();`
`31`		`- Count[node.GetIndex() * 2 + 2] += PropagatedDeltas[node.GetIndex()] * node.IntervalSize();`
	`30`	`+ Count[node.GetIndex() * 2 + 1] += PropagatedDeltas[node.GetIndex()] * (node.IntervalSize() / 2);`
	`31`	`+ Count[node.GetIndex() * 2 + 2] += PropagatedDeltas[node.GetIndex()] * (node.IntervalSize() / 2);`
`32`	`32`	`PropagatedDeltas[node.GetIndex()] = 0;`
`33`	`33`	`}`
`34`	`34`	`}`