This is an automated email from the ASF dual-hosted git repository.

chengpan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git


The following commit(s) were added to refs/heads/master by this push:
     new a5b8c3a  Revert "[KYUUBI #1318] Increase CONN_OPEN iff openSession is 
successful"
a5b8c3a is described below

commit a5b8c3ac7f2d1da8df00597ddf5dc6438971bbb6
Author: Cheng Pan <[email protected]>
AuthorDate: Tue Nov 2 21:37:27 2021 +0800

    Revert "[KYUUBI #1318] Increase CONN_OPEN iff openSession is successful"
    
    This reverts commit c78fe427edf3ea2e4d94e9cc1801058818438db3.
---
 .../src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala
 
b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala
index b3d3cc0..cb8bf70 100644
--- 
a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala
+++ 
b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala
@@ -67,13 +67,11 @@ class KyuubiSessionImpl(
   override def open(): Unit = {
     MetricsSystem.tracing { ms =>
       ms.incCount(CONN_TOTAL)
+      ms.incCount(MetricRegistry.name(CONN_OPEN, user))
     }
     withZkClient(sessionConf) { zkClient =>
       val (host, port) = engine.getOrCreate(zkClient)
       openSession(host, port)
-      MetricsSystem.tracing { ms =>
-        ms.incCount(MetricRegistry.name(CONN_OPEN, user))
-      }
     }
     // we should call super.open after kyuubi session is already opened
     super.open()

Reply via email to