diff options
author | udovichenko-r <rvu@ydb.tech> | 2023-08-22 20:17:28 +0300 |
---|---|---|
committer | udovichenko-r <rvu@ydb.tech> | 2023-08-22 21:01:49 +0300 |
commit | b1ecde7c1687c482814146a0db446ffc44b3c028 (patch) | |
tree | d7fac48f2e4ee7a521168d99bffccce2833f83d8 | |
parent | 17e64b505994706d741b4a7cd32b34d9c85c67c8 (diff) | |
download | ydb-b1ecde7c1687c482814146a0db446ffc44b3c028.tar.gz |
[dq] Check dynamic tables early
YQL-16351
-rw-r--r-- | ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp | 8 |
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; } } |