Removed unused include

GrigoriyPA · Oct 23, 2024 · fe69dcb · fe69dcb
1 parent 3996850
commit fe69dcb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/ydb/core/fq/libs/row_dispatcher/json_filter.cpp b/ydb/core/fq/libs/row_dispatcher/json_filter.cpp
@@ -11,9 +11,6 @@
 #include <ydb/core/fq/libs/common/util.h>
 #include <ydb/core/fq/libs/row_dispatcher/json_filter.h>
 
-#include <cxxabi.h>
-
-
 namespace {
 
 using TCallback = NFq::TJsonFilter::TCallback;

diff --git a/ydb/core/fq/libs/row_dispatcher/json_parser.cpp b/ydb/core/fq/libs/row_dispatcher/json_parser.cpp
@@ -179,7 +179,9 @@ class TJsonParser::TImpl {
                 }
                 rowId++;
             }
-            Y_ENSURE(rowId == Buffer.NumberValues, "Unexpected number of json documents");
+            if (rowId < Buffer.NumberValues) {
+                throw yexception() << "Failed to parse json messages, expected " << Buffer.NumberValues << " json rows but got " << rowId;
+            }
 
             for (size_t i = 0; i < Columns.size(); ++i) {
                 ResizeColumn(Columns[i], ParsedValues[i], Buffer.NumberValues);