diff options
| author | nsofya <nsofya@yandex-team.com> | 2023-08-11 20:57:17 +0300 |
|---|---|---|
| committer | nsofya <nsofya@yandex-team.com> | 2023-08-11 21:47:01 +0300 |
| commit | 656f1abe06dca744d46a0c0459a44cc7c5de919c (patch) | |
| tree | 3b730bd0c76d5c79ab202726151fe8ef388b46ec | |
| parent | a1d2d976c23eb3bef79a2033276347deb779dd81 (diff) | |
| download | ydb-656f1abe06dca744d46a0c0459a44cc7c5de919c.tar.gz | |
KIKIMR-19019: Fix split
| -rw-r--r-- | ydb/core/tx/ev_write/columnshard_splitter.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/tx/ev_write/columnshard_splitter.h b/ydb/core/tx/ev_write/columnshard_splitter.h index 6e41a6b2ec2..fed6f40c92e 100644 --- a/ydb/core/tx/ev_write/columnshard_splitter.h +++ b/ydb/core/tx/ev_write/columnshard_splitter.h @@ -112,10 +112,10 @@ private: TVector<ui64> tabletIds(descSharding.GetColumnShards().begin(), descSharding.GetColumnShards().end()); const ui32 numShards = tabletIds.size(); Y_VERIFY(numShards); - + TFullSplitData result(numShards); if (numShards == 1) { - NArrow::TSplitBlobResult blobsSplitted = NArrow::SplitByBlobSize(batch, NColumnShard::TLimits::GetMaxBlobSize() - 1024 * 1024); + NArrow::TSplitBlobResult blobsSplitted = NArrow::SplitByBlobSize(batch, NColumnShard::TLimits::GetMaxBlobSize() * 0.875); if (!blobsSplitted) { return TYdbConclusionStatus::Fail(Ydb::StatusIds::SCHEME_ERROR, "cannot split batch in according to limits: " + blobsSplitted.GetErrorMessage()); } @@ -143,7 +143,7 @@ private: THashMap<ui64, TString> out; for (size_t i = 0; i < sharded.size(); ++i) { if (sharded[i]) { - NArrow::TSplitBlobResult blobsSplitted = NArrow::SplitByBlobSize(sharded[i], NColumnShard::TLimits::GetMaxBlobSize() - 1024 * 1024); + NArrow::TSplitBlobResult blobsSplitted = NArrow::SplitByBlobSize(sharded[i], NColumnShard::TLimits::GetMaxBlobSize() * 0.875); if (!blobsSplitted) { return TYdbConclusionStatus::Fail(Ydb::StatusIds::SCHEME_ERROR, "cannot split batch in according to limits: " + blobsSplitted.GetErrorMessage()); } |