aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <rvu@ydb.tech>2023-08-22 20:17:28 +0300
committerudovichenko-r <rvu@ydb.tech>2023-08-22 21:01:49 +0300
commitb1ecde7c1687c482814146a0db446ffc44b3c028 (patch)
treed7fac48f2e4ee7a521168d99bffccce2833f83d8
parent17e64b505994706d741b4a7cd32b34d9c85c67c8 (diff)
downloadydb-b1ecde7c1687c482814146a0db446ffc44b3c028.tar.gz
[dq] Check dynamic tables early
YQL-16351
-rw-r--r--ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp8
1 files changed, 8 insertions, 0 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 a441c4aaff4..7ca72f87cd2 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
@@ -280,6 +280,7 @@ public:
AddInfo(ctx, TStringBuilder() << "disabled for cluster " << cluster, skipIssues);
return false;
}
+ const auto canUseYtPartitioningApi = State_->Configuration->_EnableYtPartitioning.Get(cluster).GetOrElse(false);
ui64 chunksCount = 0ull;
for (auto section: maybeRead.Cast().Input()) {
if (HasSettingsExcept(maybeRead.Cast().Input().Item(0).Settings().Ref(), DqReadSupportedSettings)) {
@@ -321,7 +322,14 @@ public:
} else if (NYql::HasSetting(tableInfo->Settings.Ref(), EYtSettingType::WithQB)) {
AddInfo(ctx, "table with QB2 premapper", skipIssues);
return false;
+ } else if (pathInfo.Ranges && !canUseYtPartitioningApi) {
+ AddInfo(ctx, "table with ranges", skipIssues);
+ return false;
+ } else if (tableInfo->Meta->IsDynamic && !canUseYtPartitioningApi) {
+ AddInfo(ctx, "dynamic table", skipIssues);
+ return false;
}
+
chunksCount += tableInfo->Stat->ChunkCount;
}
}