lib/fluent/plugin/out_bigquery_base.rb in fluent-plugin-bigquery-3.0.1 vs lib/fluent/plugin/out_bigquery_base.rb in fluent-plugin-bigquery-3.1.0

@@ -170,10 +170,10 @@
           else
             @table_schema
           end
 
         begin
-          row = schema.format(record)
+          row = schema.format(record, is_load: !!@is_load)
           return if row.empty?
           @formatter.format(tag, time, row)
         rescue
           log.error("format error", record: record, schema: schema)
           raise