File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed
ydb/core/fq/libs/row_dispatcher Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change 11
11
#include < ydb/core/fq/libs/common/util.h>
12
12
#include < ydb/core/fq/libs/row_dispatcher/json_filter.h>
13
13
14
- #include < cxxabi.h>
15
-
16
-
17
14
namespace {
18
15
19
16
using TCallback = NFq::TJsonFilter::TCallback;
Original file line number Diff line number Diff line change @@ -179,7 +179,9 @@ class TJsonParser::TImpl {
179
179
}
180
180
rowId++;
181
181
}
182
- Y_ENSURE (rowId == Buffer.NumberValues , " Unexpected number of json documents" );
182
+ if (rowId < Buffer.NumberValues ) {
183
+ throw yexception () << " Failed to parse json messages, expected " << Buffer.NumberValues << " json rows but got " << rowId;
184
+ }
183
185
184
186
for (size_t i = 0 ; i < Columns.size (); ++i) {
185
187
ResizeColumn (Columns[i], ParsedValues[i], Buffer.NumberValues );
You can’t perform that action at this time.
0 commit comments