From fe69dcbd64e6e62cf1791b69eeca3cf7b1b823bc Mon Sep 17 00:00:00 2001
From: Grigoriy Pisarenko <grigoriypisar@ydb.tech>
Date: Wed, 23 Oct 2024 11:48:07 +0000
Subject: [PATCH] Removed unused include

---
 ydb/core/fq/libs/row_dispatcher/json_filter.cpp | 3 ---
 ydb/core/fq/libs/row_dispatcher/json_parser.cpp | 4 +++-
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/ydb/core/fq/libs/row_dispatcher/json_filter.cpp b/ydb/core/fq/libs/row_dispatcher/json_filter.cpp
index c4f1e3dd2436..fbc89e816b47 100644
--- 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
index 2afcc8dbf77d..69a592f7fe19 100644
--- 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);