Fixed json_parser

GrigoriyPA · Dec 7, 2024 · 092c743 · 092c743
1 parent 259bbb9
commit 092c743
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/ydb/core/fq/libs/row_dispatcher/format_handler/parsers/json_parser.cpp b/ydb/core/fq/libs/row_dispatcher/format_handler/parsers/json_parser.cpp
@@ -69,7 +69,7 @@ struct TJsonParserBuffer {
 
 class TColumnParser {
 public:
-    const std::string Name;  // User for column index by std::string_view
+    const std::string Name;  // Used for column index by std::string_view
     const TString TypeYson;
 
 public:
@@ -366,10 +366,13 @@ class TJsonParser : public TTopicParserBase {
                 ParseBuffer();
             }
         }
-        if (Buffer.IsReady() && !Config.LatencyLimit) {
-            ParseBuffer();
-        } else {
-            LOG_ROW_DISPATCHER_TRACE("Collecting data to parse, skip parsing, current buffer size: " << Buffer.GetSize());
+
+        if (Buffer.IsReady()) {
+            if (!Config.LatencyLimit) {
+                ParseBuffer();
+            } else {
+                LOG_ROW_DISPATCHER_TRACE("Collecting data to parse, skip parsing, current buffer size: " << Buffer.GetSize());
+            }
         }
     }