diff options
| author | Ivan <ilezhankin@yandex-team.ru> | 2024-12-10 20:36:19 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-10 17:36:19 +0000 |
| commit | 15933e4b4c25961cecb34190ed5108907efaa4d5 (patch) | |
| tree | 005756ebcf9882f88981f7504e7cd9bffdbca8ab | |
| parent | 80aedb4f97ed19b07d98011239dd7e193c7b77f8 (diff) | |
| download | ydb-15933e4b4c25961cecb34190ed5108907efaa4d5.tar.gz | |
Revert MinFillPercentage usage in Dq (#12458)
| -rw-r--r-- | ydb/library/yql/dq/runtime/dq_output_consumer.cpp | 2 | ||||
| -rw-r--r-- | ydb/library/yql/dq/runtime/dq_output_consumer.h | 5 |
2 files changed, 3 insertions, 4 deletions
diff --git a/ydb/library/yql/dq/runtime/dq_output_consumer.cpp b/ydb/library/yql/dq/runtime/dq_output_consumer.cpp index 86afb673126..397e9d46685 100644 --- a/ydb/library/yql/dq/runtime/dq_output_consumer.cpp +++ b/ydb/library/yql/dq/runtime/dq_output_consumer.cpp @@ -516,7 +516,7 @@ private: if (blockType->GetShape() == NMiniKQL::TBlockType::EShape::Many) { auto itemType = blockType->GetItemType(); YQL_ENSURE(!itemType->IsPg(), "pg types are not supported yet"); - Builders_.emplace_back(MakeArrayBuilder(helper, itemType, *NYql::NUdf::GetYqlMemoryPool(), maxBlockLen, nullptr, {.MinFillPercentage=100})); + Builders_.emplace_back(MakeArrayBuilder(helper, itemType, *NYql::NUdf::GetYqlMemoryPool(), maxBlockLen, nullptr)); } else { Builders_.emplace_back(); } diff --git a/ydb/library/yql/dq/runtime/dq_output_consumer.h b/ydb/library/yql/dq/runtime/dq_output_consumer.h index 1d6a48acd28..ac5d5087f48 100644 --- a/ydb/library/yql/dq/runtime/dq_output_consumer.h +++ b/ydb/library/yql/dq/runtime/dq_output_consumer.h @@ -6,8 +6,8 @@ #include <yql/essentials/minikql/mkql_alloc.h> namespace NKikimr::NMiniKQL { -class TTypeEnvironment; -class THolderFactory; + class TTypeEnvironment; + class THolderFactory; } // namespace NKikimr::NMiniKQL namespace NYql::NDq { @@ -51,5 +51,4 @@ IDqOutputConsumer::TPtr CreateOutputHashPartitionConsumer( IDqOutputConsumer::TPtr CreateOutputBroadcastConsumer(TVector<IDqOutput::TPtr>&& outputs, TMaybe<ui32> outputWidth); - } // namespace NYql::NDq |