lib/logstash/outputs/analyticdb.rb in logstash-output-analyticdb-5.4.0.8 vs lib/logstash/outputs/analyticdb.rb in logstash-output-analyticdb-5.4.0.9

@@ -249,9 +249,10 @@
             insert_sql.concat(",").concat(one_sql[@pre_len, one_sql.length])
             sql_len = sql_len + one_sql.length - @pre_len
           end
         rescue => e
           retry_exception?(e, event.to_json())
+          is_insert_err = true
         end
       end
       statement.execute(insert_sql)
     rescue => e
       @logger.error("Submit data error, sql is #{insert_sql}, error is #{e}")