aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMaxim Kovalev <maxkovalev@ydb.tech>2024-06-18 11:57:43 +0300
committerGitHub <noreply@github.com>2024-06-18 11:57:43 +0300
commit5e1e7090691371011db03b2cf0f01561c2512c19 (patch)
treec1c2752af3e9bd1e26090b12680eb417c0fb8dfa
parentdcd5f7dcfaae0db7cfbaff3df7815c5e7f7fd3e1 (diff)
downloadydb-5e1e7090691371011db03b2cf0f01561c2512c19.tar.gz
Improve error message for max chunk count (#5615)
-rw-r--r--ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp6
1 files changed, 3 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 143f26afc1..435f8d5d61 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
@@ -221,7 +221,7 @@ public:
}
if (auto maxChunks = State_->Configuration->MaxChunksForDqRead.Get().GetOrElse(DEFAULT_MAX_CHUNKS_FOR_DQ_READ); canFallback && chunksCount > maxChunks) {
- throw TFallbackError() << DqFallbackErrorMessageWrap("table with too many chunks");
+ throw TFallbackError() << DqFallbackErrorMessageWrap( TStringBuilder() << "table with too many chunks: " << chunksCount << " > " << maxChunks);
}
if (hasErasure) {
@@ -470,7 +470,7 @@ public:
}
}
if (auto maxChunks = State_->Configuration->MaxChunksForDqRead.Get().GetOrElse(DEFAULT_MAX_CHUNKS_FOR_DQ_READ); chunksCount > maxChunks) {
- AddMessage(ctx, "table with too many chunks", skipIssues, State_->PassiveExecution);
+ AddMessage(ctx, TStringBuilder() << "table with too many chunks: " << chunksCount << " > " << maxChunks, skipIssues, State_->PassiveExecution);
return false;
}
return true;
@@ -592,7 +592,7 @@ public:
}
}
if (chunksCount > maxChunks) {
- AddErrorWrap(ctx, node_->Pos(), "table with too many chunks");
+ AddErrorWrap(ctx, node_->Pos(), TStringBuilder() << "table with too many chunks: " << chunksCount << " > " << maxChunks);
return Nothing();
}
clusterToNodesAndErasure[cluster].push_back({node_, hasErasure});