analyticdb.rb in logstash-output-analyticdb-5.4.0.6

- old
+ new

@@ -371,11 +371,11 @@
 
   def retry_exception?(exception, event)
     retrying = (exception.respond_to? 'getSQLState' and (RETRYABLE_SQLSTATE_CLASSES.include?(exception.getSQLState.to_s[0, 2]) or @retry_sql_states.include?(exception.getSQLState)))
     log_jdbc_exception(exception, retrying, event)
 
-    retrying
+    true 
   end
 
   def log_jdbc_exception(exception, retrying, event)
     current_exception = exception
     log_text = 'JDBC - Exception. ' + (retrying ? 'Retrying' : 'Not retrying')
@@ -399,6 +399,6 @@
 
   def next_sleep_interval(current_interval)
     doubled = current_interval * 2
     doubled > @retry_max_interval ? @retry_max_interval : doubled
   end
-end # class LogStash::Outputs::analyticdb
\ No newline at end of file
+end # class LogStash::Outputs::analyticdb