From fcc40ee9a6f4d4567ce62bb5d2cddcc96d84696a Mon Sep 17 00:00:00 2001 From: sychen Date: Wed, 21 Feb 2024 11:41:40 +0000 Subject: [PATCH] [KYUUBI #6069] [TEST] TFrontendServiceSuite - close expired operations MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit # :mag: Description ## Issue References ๐Ÿ”— This pull request fixes # ## Describe Your Solution ๐Ÿ”ง Remove unnecessary waits ## Types of changes :bookmark: - [x] Bugfix (non-breaking change which fixes an issue) - [ ] New feature (non-breaking change which adds functionality) - [ ] Breaking change (fix or feature that would cause existing functionality to change) ## Test Plan ๐Ÿงช #### Behavior Without This Pull Request :coffin: Flasy test #### Behavior With This Pull Request :tada: GA #### Related Unit Tests TFrontendServiceSuite - "close expired operations" --- # Checklist ๐Ÿ“ - [ ] This patch was not authored or co-authored using [Generative Tooling](https://www.apache.org/legal/generative-tooling.html) **Be nice. Be informative.** Closes #6069 from cxzl25/fix_TF_close_op_test. Closes #6069 5895d098e [sychen] trigger test a01f67c48 [sychen] trigger test d67f2ea20 [sychen] test Authored-by: sychen Signed-off-by: Cheng Pan (cherry picked from commit 43b5431005611cf03110d152dfaa7c11c0f3f097) Signed-off-by: Cheng Pan --- .../org/apache/kyuubi/service/TFrontendServiceSuite.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/kyuubi-common/src/test/scala/org/apache/kyuubi/service/TFrontendServiceSuite.scala b/kyuubi-common/src/test/scala/org/apache/kyuubi/service/TFrontendServiceSuite.scala index 444bfe2cc..bd485a262 100644 --- a/kyuubi-common/src/test/scala/org/apache/kyuubi/service/TFrontendServiceSuite.scala +++ b/kyuubi-common/src/test/scala/org/apache/kyuubi/service/TFrontendServiceSuite.scala @@ -557,9 +557,7 @@ class TFrontendServiceSuite extends KyuubiFunSuite { assert(cancelOpResp.getStatus.getStatusCode === TStatusCode.SUCCESS_STATUS) assert(sessionManager.getOpenSessionCount === 1) assert(session.lastIdleTime === 0) - eventually(timeout(Span(60, Seconds)), interval(Span(1, Seconds))) { - assert(lastAccessTime < session.lastAccessTime) - } + lastAccessTime = session.lastAccessTime eventually(timeout(Span(60, Seconds)), interval(Span(1, Seconds))) {