aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormrlolthe1st <mrlolthe1st@yandex-team.com>2023-08-11 15:58:41 +0300
committermrlolthe1st <mrlolthe1st@yandex-team.com>2023-08-11 17:10:11 +0300
commit98300f1884159e59d7cad62ce0bcff3d89100a7d (patch)
treeb247c1971885804b90d9b35fa54c589d6f17f12d
parentd7b9affd76f35d87b3dcb56a703d6ff4c689413e (diff)
downloadydb-98300f1884159e59d7cad62ce0bcff3d89100a7d.tar.gz
YQL-16280: hotfix
hotfix
-rw-r--r--ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp5
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 {