diff --git a/query/src/main/java/tech/ydb/query/impl/SessionPool.java b/query/src/main/java/tech/ydb/query/impl/SessionPool.java index ccbbf4889..fbbe078ae 100644 --- a/query/src/main/java/tech/ydb/query/impl/SessionPool.java +++ b/query/src/main/java/tech/ydb/query/impl/SessionPool.java @@ -252,7 +252,7 @@ public void destroy() { @Override public void close() { - logger.trace("QuerySession[{}] closed with broke status {}", getId(), isBroken); + logger.trace("QuerySession[{}] closed with broken status {}", getId(), isBroken); stats.released.increment(); if (isBroken || isStopped) { @@ -328,6 +328,7 @@ public void run() { PooledQuerySession session = coldIterator.next(); if (!session.getLastActive().isAfter(idleToRemove) && queue.getTotalCount() > minSize) { coldIterator.remove(); + logger.debug("QuerySession[{}] was deleted by idle timeout", session.getId()); } } } diff --git a/table/src/main/java/tech/ydb/table/impl/pool/SessionPool.java b/table/src/main/java/tech/ydb/table/impl/pool/SessionPool.java index 906317fa0..fa34023c1 100644 --- a/table/src/main/java/tech/ydb/table/impl/pool/SessionPool.java +++ b/table/src/main/java/tech/ydb/table/impl/pool/SessionPool.java @@ -85,7 +85,7 @@ public SessionPoolStats stats() { } public CompletableFuture> acquire(Duration timeout) { - logger.debug("acquire session with timeout {}", timeout); + logger.trace("acquire session with timeout {}", timeout); CompletableFuture> future = new CompletableFuture<>(); @@ -131,7 +131,7 @@ private boolean pollNext(CompletableFuture> future) { private boolean validateSession(ClosableSession session, CompletableFuture> future) { if (session.state().switchToActive(clock.instant())) { - logger.debug("session {} accepted", session.getId()); + logger.trace("session {} accepted", session.getId()); if (future.complete(Result.success(session))) { stats.acquired.increment(); } else { @@ -261,6 +261,7 @@ public void run() { if (!state.lastActive().isAfter(idleToRemove) && queue.getTotalCount() > minSize) { coldIterator.remove(); + logger.debug("session {} was deleted by idle timeout", session.getId()); continue; } diff --git a/table/src/main/java/tech/ydb/table/impl/pool/StatefulSession.java b/table/src/main/java/tech/ydb/table/impl/pool/StatefulSession.java index 0b03f75aa..745f9032f 100644 --- a/table/src/main/java/tech/ydb/table/impl/pool/StatefulSession.java +++ b/table/src/main/java/tech/ydb/table/impl/pool/StatefulSession.java @@ -116,6 +116,7 @@ private State updated(Instant now, Throwable th, StatusCode code, boolean shutdo // and if we found it state switch to broken status if (broken) { + logger.debug("{} broken by status code {}", this, code); return new State(Status.BROKEN, lastActive, now); } @@ -125,6 +126,7 @@ private State updated(Instant now, Throwable th, StatusCode code, boolean shutdo if (status == Status.ACTIVE) { if (shutdownHint) { + logger.debug("{} broken by shutdown hint", this); return new State(Status.NEED_SHUTDOWN, now); } return new State(status, now);