Skip to content
This repository was archived by the owner on Jan 8, 2020. It is now read-only.

Commit 3d6106a

Browse files
committed
Merge branch 'develop'
2 parents 67769b0 + 41ce975 commit 3d6106a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/org/keedio/flume/source/HibernateHelper.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -95,11 +95,11 @@ public void resetConnectionAndSleep() throws InterruptedException {
9595
long startTime = System.currentTimeMillis();
9696

9797
session.close();
98-
establishSession();
98+
session = factory.openSession();
9999

100100
long execTime = System.currentTimeMillis() - startTime;
101101

102102
if (execTime < sqlSourceHelper.getRunQueryDelay())
103103
Thread.sleep(sqlSourceHelper.getRunQueryDelay() - execTime);
104-
}
104+
}
105105
}

0 commit comments

Comments
 (0)