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

twice pushed a commit to branch unstable
in repository https://gitbox.apache.org/repos/asf/kvrocks.git


The following commit(s) were added to refs/heads/unstable by this push:
     new 1308d8a3 fix(tests): flaky test case in BLMPOP command (#2754)
1308d8a3 is described below

commit 1308d8a305c0cc3dc6b8297cb37f57157a3e9226
Author: hulk <[email protected]>
AuthorDate: Fri Jan 31 16:53:55 2025 +0800

    fix(tests): flaky test case in BLMPOP command (#2754)
---
 tests/gocase/unit/type/list/list_test.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/tests/gocase/unit/type/list/list_test.go 
b/tests/gocase/unit/type/list/list_test.go
index b2bd71f5..38854aa7 100644
--- a/tests/gocase/unit/type/list/list_test.go
+++ b/tests/gocase/unit/type/list/list_test.go
@@ -1462,15 +1462,16 @@ func testList(t *testing.T, configs 
util.KvrocksServerConfigs) {
                        // https://github.com/apache/kvrocks/issues/2617
                        // WriteArgs are required to be executed first
                        time.Sleep(100 * time.Millisecond)
-                       require.NoError(t, rdb.RPush(ctx, key2, "one", 
"two").Err())
+
                        require.NoError(t, rdb.RPush(ctx, key1, "ONE", 
"TWO").Err())
+                       require.NoError(t, rdb.RPush(ctx, key2, "one", 
"two").Err())
                        if direction == "LEFT" {
-                               rd.MustReadStringsWithKey(t, key2, 
[]string{"one", "two"})
+                               rd.MustReadStringsWithKey(t, key1, 
[]string{"ONE", "TWO"})
                        } else {
-                               rd.MustReadStringsWithKey(t, key2, 
[]string{"two", "one"})
+                               rd.MustReadStringsWithKey(t, key1, 
[]string{"TWO", "ONE"})
                        }
-                       require.EqualValues(t, 0, rdb.Exists(ctx, key2).Val())
-                       require.EqualValues(t, 2, rdb.LLen(ctx, key1).Val())
+                       require.EqualValues(t, 0, rdb.Exists(ctx, key1).Val())
+                       require.EqualValues(t, 2, rdb.LLen(ctx, key2).Val())
                })
 
                t.Run(fmt.Sprintf("BLMPOP test blocked served secondKey noCount 
%s", direction), func(t *testing.T) {

Reply via email to