Exception mechanism of handling db failure conection

Hi mates,
I have a issue related to database connection failure.Some attributes comes from kafka and some other attributes comes from different databases and ingest to ES via logstash.
All the events gets ingested very well to ES for some times(don't know when exactly db's connection fails ).How do i handled this exception.
The following is the error:
[2020-03-18T01:20:27,066][WARN ][logstash.filters.jdbcstreaming] Exception when executing JDBC query {:exception=>#<Sequel::DatabaseError: Java::JavaSql::SQLRecoverableException: No more data to read from socket>}
[2020-03-18T01:20:27,118][ERROR][logstash.pipeline ] Exception in pipelineworker, the pipeline stopped processing new events, please check your filter configuration and restart Logstash. {:pipeline_id=>"mce-order-lines-inc-inc-opl.json-edelivery-order-lines-inc-1", "exception"=>"Closed Connection", "backtrace"=>["oracle.jdbc.driver.PhysicalConnection.needLine(oracle/jdbc/driver/PhysicalConnection.java:4220)", "oracle.jdbc.driver.OracleStatement.closeOrCache(oracle/jdbc/driver/OracleStatement.java:1431)", "oracle.jdbc.driver.OracleStatement.close(oracle/jdbc/driver/OracleStatement.java:1410)", "oracle.jdbc.driver.OracleStatementWrapper.close(oracle/jdbc/driver/OracleStatementWrapper.java:102)", "java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:498)", "org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:438)", "org.jruby.javasupport.JavaMethod.invokeDirect(org/jruby/javasupport/JavaMethod.java:302)", "apps.ccadmin.logstash6_dot_2.vendor.bundle.jruby.$2_dot_3_dot_0.gems.sequel_minus_5_dot_7_dot_1.lib.sequel.adapters.jdbc.statement(/apps/ccadmin/logstash6.2/vendor/bundle/jruby/2.3.0/gems/sequel-5.7.1/lib/sequel/adapters/jdbc.rb:662)",

Thanks in advance,
Jagan

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.