summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVitaly Isaev <[email protected]>2025-04-16 13:34:12 +0300
committerGitHub <[email protected]>2025-04-16 13:34:12 +0300
commitcf08f1c9fbbff9a6a8617ca76aeeb2c80ef1bfab (patch)
tree0922254c959b2ec042b773c28dc7525cb949f6b8
parentb37d721911ff8eb6c79c25caa3083729ce4b8aef (diff)
YDB FQ: enhance error occurring during Generic::TPartition parsing (#17230)
-rw-r--r--ydb/library/yql/providers/generic/actors/yql_generic_read_actor.cpp10
1 files changed, 8 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/generic/actors/yql_generic_read_actor.cpp b/ydb/library/yql/providers/generic/actors/yql_generic_read_actor.cpp
index 9620eee9c3d..b1f0c0ac246 100644
--- a/ydb/library/yql/providers/generic/actors/yql_generic_read_actor.cpp
+++ b/ydb/library/yql/providers/generic/actors/yql_generic_read_actor.cpp
@@ -399,7 +399,10 @@ namespace NYql::NDq {
if (!readRanges.empty()) {
for (const auto& readRange : readRanges) {
Generic::TPartition partition;
- YQL_ENSURE(partition.ParseFromString(readRange), "Failed to parse partition from read ranges");
+ YQL_ENSURE(
+ partition.ParseFromString(readRange),
+ "Failed to parse partition from read ranges: " << partition.InitializationErrorString()
+ );
partitions.emplace_back(std::move(partition));
}
} else {
@@ -407,7 +410,10 @@ namespace NYql::NDq {
if (iter != taskParams.end()) {
Generic::TPartition partition;
TStringInput input(iter->first);
- YQL_ENSURE(partition.ParseFromString(iter->second), "Failed to parse partition from task params");
+ YQL_ENSURE(
+ partition.ParseFromString(iter->second),
+ "Failed to parse partition from task params: " << partition.InitializationErrorString()
+ );
partitions.emplace_back(std::move(partition));
}
}