diff --git service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java index 7341635..4d59d5b 100644 --- service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java +++ service/src/java/org/apache/hive/service/cli/session/HiveSessionImpl.java @@ -113,7 +113,7 @@ private volatile long lastAccessTime; private volatile long lastIdleTime; - private volatile int pendingCount = 0; + private volatile int activeCalls = 0; public HiveSessionImpl(SessionHandle sessionHandle, TProtocolVersion protocol, String username, String password, @@ -337,7 +337,7 @@ protected synchronized void acquire(boolean userAccess) { // set the thread name with the logging prefix. sessionState.updateThreadName(); Hive.set(sessionHive); - pendingCount++; + activeCalls++; lastIdleTime = 0; } @@ -364,10 +364,10 @@ protected synchronized void release(boolean userAccess) { if (userAccess) { lastAccessTime = System.currentTimeMillis(); } - pendingCount--; + activeCalls--; // lastIdleTime is only set by the last one // who calls release with empty opHandleSet. - if (pendingCount == 0 && opHandleSet.isEmpty()) { + if (activeCalls == 0 && opHandleSet.isEmpty()) { lastIdleTime = System.currentTimeMillis(); } }