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()