lib/fluent/plugin/out_bigquery_insert.rb in fluent-plugin-bigquery-2.3.0 vs lib/fluent/plugin/out_bigquery_insert.rb in fluent-plugin-bigquery-3.0.0

@@ -94,9 +94,11 @@
         table_id = extract_placeholders(table_format, metadata)
         template_suffix = @template_suffix ? extract_placeholders(@template_suffix, metadata) : nil
         schema = get_schema(project, dataset, metadata)
 
         insert(project, dataset, table_id, rows, schema, template_suffix)
+      rescue MultiJson::ParseError => e
+        raise Fluent::UnrecoverableError.new(e)
       end
 
       def insert(project, dataset, table_id, rows, schema, template_suffix)
         writer.insert_rows(project, dataset, table_id, rows, schema, template_suffix: template_suffix)
       rescue Fluent::BigQuery::Error => e