search

keedio / flume-ng-sql-source

Flume Source to import data from SQL Databases
Apache License 2.0
264 stars 164 forks source link

when reloading agent config, throwing exception: Session was already closed #60

Closed zhipcui closed 6 years ago

zhipcui commented 6 years ago 
04 Jun 2018 15:51:02,639 ERROR [PollableSourceRunner-SQLSource-r] (org.apache.flume.source.PollableSourceRunner$PollingRunner.run:150)  - Unhandled exception, logging and sleeping for 0ms
org.hibernate.SessionException: Session was already closed
    at org.hibernate.internal.SessionImpl.close(SessionImpl.java:359)
    at org.keedio.flume.source.HibernateHelper.resetConnection(HibernateHelper.java:147)
    at org.keedio.flume.source.HibernateHelper.executeQuery(HibernateHelper.java:103)
    at org.keedio.flume.source.SQLSource.process(SQLSource.java:102)
    at org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:133)
    at java.lang.Thread.run(Thread.java:748)