fix

ivanmorozov333 · ivanmorozov333 · commit be651b5fc382 · 2025-05-10T20:04:42.000+03:00
diff --git a/ydb/library/formats/arrow/splitter/stats.cpp b/ydb/library/formats/arrow/splitter/stats.cpp
@@ -34,10 +34,10 @@ TSimpleSerializationStat::TSimpleSerializationStat(const ui64 bytes, const ui64
 
 std::vector<i64> TSimpleSerializationStat::SplitRecords(
     const ui32 recordsCount, const ui32 expectedRecordsCount, const ui32 expectedColumnPageSize) {
-    if (!SerializedBytes) {
+    if (!SerializedBytes || !RecordsCount) {
         return TSimilarPacker::SplitWithExpected(recordsCount, expectedRecordsCount);
     } else {
-        const ui32 recordsCountPerExpectedPageSize = std::max<ui32>(expectedRecordsCount, expectedColumnPageSize / SerializedBytes);
+        const ui32 recordsCountPerExpectedPageSize = std::max<ui32>(expectedRecordsCount, expectedColumnPageSize / GetSerializedBytesPerRecord());
         return TSimilarPacker::SplitWithExpected(recordsCount, recordsCountPerExpectedPageSize);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -34,10 +34,10 @@ TSimpleSerializationStat::TSimpleSerializationStat(const ui64 bytes, const ui64`
`34`	`34`
`35`	`35`	`std::vector<i64> TSimpleSerializationStat::SplitRecords(`
`36`	`36`	`const ui32 recordsCount, const ui32 expectedRecordsCount, const ui32 expectedColumnPageSize) {`
`37`		`- if (!SerializedBytes) {`
	`37`	`+ if (!SerializedBytes \|\| !RecordsCount) {`
`38`	`38`	`return TSimilarPacker::SplitWithExpected(recordsCount, expectedRecordsCount);`
`39`	`39`	`} else {`
`40`		`- const ui32 recordsCountPerExpectedPageSize = std::max<ui32>(expectedRecordsCount, expectedColumnPageSize / SerializedBytes);`
	`40`	`+ const ui32 recordsCountPerExpectedPageSize = std::max<ui32>(expectedRecordsCount, expectedColumnPageSize / GetSerializedBytesPerRecord());`
`41`	`41`	`return TSimilarPacker::SplitWithExpected(recordsCount, recordsCountPerExpectedPageSize);`
`42`	`42`	`}`
`43`	`43`	`}`