# Exception mechanism of handling db failure conection

**URL:** <https://discuss.elastic.co/t/exception-mechanism-of-handling-db-failure-conection/230519>\
**Category:** Logstash\
**Created:** [April 30, 2020, 10:32am UTC](https://discuss.elastic.co/t/exception-mechanism-of-handling-db-failure-conection/230519 "2020-04-30T10:32:26Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![jagan](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/jagan/32/42200_2.png) [@jagan](https://discuss.elastic.co/u/jagan)\
**Post date:** [April 30, 2020, 10:32am UTC](https://discuss.elastic.co/t/exception-mechanism-of-handling-db-failure-conection/230519/1 "2020-04-30T10:32:26Z")

</div>

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

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [May 28, 2020, 10:32am UTC](https://discuss.elastic.co/t/exception-mechanism-of-handling-db-failure-conection/230519/2 "2020-05-28T10:32:26Z")

</div>

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