[yql] Add info about DQ fallback

1 files changed, 7 insertions, 5 deletions

diff --git a/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp b/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp
index cf7c7aaf2d5..25d7c45d76b 100644
--- a/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp
+++ b/ydb/library/yql/providers/dq/provider/yql_dq_recapture.cpp
@@ -80,17 +80,19 @@ public:
             TNodeSet visited;
             Scan(*input, ctx, good, dataSize, visited, hasJoin);
 
+            if (good && hasJoin && dataSize > State_->Settings->MaxDataSizePerQuery.Get().GetOrElse(10_GB)) {
+                Statistics_["DqAnalyzerBigJoin"]++;
+                AddInfo(ctx, TStringBuilder() << "too big join input: " << dataSize);
+                good = false;
+            }
+
             if (good) {
                 Statistics_["DqAnalyzerOk"]++;
             } else {
                 Statistics_["DqAnalyzerFail"] ++;
             }
 
-            if ((hasJoin && dataSize > State_->Settings->MaxDataSizePerQuery.Get().GetOrElse(10_GB))) {
-                Statistics_["DqAnalyzerBigJoin"]++;
-            }
-
-            if (!good || (hasJoin && dataSize > State_->Settings->MaxDataSizePerQuery.Get().GetOrElse(10_GB))) {
+            if (!good) {
                 YQL_CLOG(DEBUG, ProviderDq) << "good: " << good << " hasJoin: " << hasJoin << " dataSize: " << dataSize;
                 return TStatus::Ok;
             }