diff options
author | mrlolthe1st <mrlolthe1st@yandex-team.com> | 2023-08-11 15:58:41 +0300 |
---|---|---|
committer | mrlolthe1st <mrlolthe1st@yandex-team.com> | 2023-08-11 17:10:11 +0300 |
commit | 98300f1884159e59d7cad62ce0bcff3d89100a7d (patch) | |
tree | b247c1971885804b90d9b35fa54c589d6f17f12d | |
parent | d7b9affd76f35d87b3dcb56a703d6ff4c689413e (diff) | |
download | ydb-98300f1884159e59d7cad62ce0bcff3d89100a7d.tar.gz |
YQL-16280: hotfix
hotfix
-rw-r--r-- | ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp index a8b661b22d8..a441c4aaff4 100644 --- a/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp +++ b/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp @@ -337,7 +337,6 @@ public: } TMaybe<ui64> EstimateReadSize(ui64 dataSizePerJob, ui32 maxTasksPerStage, const TVector<const TExprNode*>& nodes, TExprContext& ctx) override { - TVector<bool> hasErasurePerNode; hasErasurePerNode.reserve(nodes.size()); TVector<ui64> dataSizes(nodes.size()); @@ -354,7 +353,7 @@ public: auto& groupIdPathInfo = clusterToGroups[cluster]; const auto canUseYtPartitioningApi = State_->Configuration->_EnableYtPartitioning.Get(cluster).GetOrElse(false); - + auto input = maybeRead.Cast().Input(); for (auto section: input) { groupIdPathInfo.emplace_back(); @@ -383,7 +382,7 @@ public: } if (chunksCount > maxChunks) { AddErrorWrap(ctx, node_->Pos(), "table with too many chunks"); - return false; + return Nothing(); } clusterToNodesAndErasure[cluster].push_back({node_, hasErasure}); } else { |