|
|
@ -43,6 +43,7 @@ import java.util.Optional; |
|
|
import java.util.UUID; |
|
|
import java.util.UUID; |
|
|
import java.util.concurrent.ConcurrentHashMap; |
|
|
import java.util.concurrent.ConcurrentHashMap; |
|
|
import java.util.concurrent.ConcurrentMap; |
|
|
import java.util.concurrent.ConcurrentMap; |
|
|
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
import java.util.concurrent.locks.Lock; |
|
|
import java.util.concurrent.locks.Lock; |
|
|
import java.util.concurrent.locks.ReentrantLock; |
|
|
import java.util.concurrent.locks.ReentrantLock; |
|
|
|
|
|
|
|
|
@ -145,6 +146,7 @@ public class JpaBaseEdgeEventDao extends JpaAbstractSearchTextDao<EdgeEventEntit |
|
|
PreparedStatement stmt = connection.prepareStatement("call cleanup_edge_events_by_ttl(?,?)")) { |
|
|
PreparedStatement stmt = connection.prepareStatement("call cleanup_edge_events_by_ttl(?,?)")) { |
|
|
stmt.setLong(1, ttl); |
|
|
stmt.setLong(1, ttl); |
|
|
stmt.setLong(2, 0); |
|
|
stmt.setLong(2, 0); |
|
|
|
|
|
stmt.setQueryTimeout((int) TimeUnit.HOURS.toSeconds(1)); |
|
|
stmt.execute(); |
|
|
stmt.execute(); |
|
|
printWarnings(stmt); |
|
|
printWarnings(stmt); |
|
|
try (ResultSet resultSet = stmt.getResultSet()) { |
|
|
try (ResultSet resultSet = stmt.getResultSet()) { |
|
|
|