(kvrocks) branch unstable updated: fix(test): extend the replication wait time to prevent the flaky test (#3531)

[twice]

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

PragmaTwice 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 d51384c05 fix(test): extend the replication wait time to prevent the 
flaky test (#3531)
d51384c05 is described below

commit d51384c05cecbcf4ac3b2adc4451444f45abaaac
Author: hulk <hulk.webs...@gmail.com>
AuthorDate: Thu Jun 18 18:51:49 2026 +0800

    fix(test): extend the replication wait time to prevent the flaky test 
(#3531)
    
    Currently, WaitForSync only allows 5s for master_link_status to reach
    "up",
    which is not enough under loaded CI runners (e.g. SonarCloud coverage
    builds);
    
    Reproduced locally by running 16 background CPU burners and looping the
    test:
    ```
    for i in $(seq 1 6); do
       go test -count=1 -run TestReplicationWithLimitSpeed$ \
          ./integration/replication/... \
          -binPath=.../build/kvrocks -workspace=/tmp/kvrocks-test-ws
    done
    ```
    
    Before the fix: 1/6 runs failed with the same trace as the CI flake
    ("Condition never satisfied" at client.go:50, called from
    replication_test.go:362).
    After the fix: 8/8 runs pass under the same CPU load (run times 34-51s
    vs. an
    unloaded baseline of ~28s, confirming load was active).
    
    
    Related flaky run:
    https://github.com/apache/kvrocks/actions/runs/27660686644/job/81804342125
    
    
    🤖 Generated with [Claude Code](https://claude.com/claude-code)
    
    Co-authored-by: Claude Opus 4.7 (1M context) <nore...@anthropic.com>
---
 tests/gocase/integration/replication/replication_test.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/gocase/integration/replication/replication_test.go 
b/tests/gocase/integration/replication/replication_test.go
index 23ccabd10..d21239ef2 100644
--- a/tests/gocase/integration/replication/replication_test.go
+++ b/tests/gocase/integration/replication/replication_test.go
@@ -359,7 +359,9 @@ func TestReplicationWithLimitSpeed(t *testing.T) {
                require.Eventually(t, func() bool {
                        return slave.LogFileMatches(t, ".*skip count: 1.*")
                }, 50*time.Second, 1000*time.Millisecond)
-               util.WaitForSync(t, slaveClient)
+               require.Eventually(t, func() bool {
+                       return util.FindInfoEntry(slaveClient, 
"master_link_status") == "up"
+               }, 30*time.Second, 100*time.Millisecond)
                require.Equal(t, "b", slaveClient.Get(ctx, "a").Val())
        })
 }