Closed zhipcui closed 6 years ago
Hi zhipcui, thank you very much for your contribution. What about add this change to yours ?
private void resetConnection() throws InterruptedException{
if(session.isOpen()){
session.close();
factory.close();
} else {
establishSession();
}
}
best, Luis
Yep, look better. And I have pushed the change.
reseting connection should check if the session is open or not.
fixed https://github.com/keedio/flume-ng-sql-source/issues/60