(fluss-rust) branch main updated: ci: check tablet server availabitility (#437)

[yuxia]

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

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss-rust.git


The following commit(s) were added to refs/heads/main by this push:
     new 7b3015b  ci: check tablet server availabitility (#437)
7b3015b is described below

commit 7b3015ba5a3fba4819b165c99efdeff6a5f1f872
Author: Kaiqi Dong <kaiqi.d...@bitvavo.com>
AuthorDate: Mon Mar 9 02:43:03 2026 +0100

    ci: check tablet server availabitility (#437)
---
 bindings/cpp/test/test_utils.h | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/bindings/cpp/test/test_utils.h b/bindings/cpp/test/test_utils.h
index f5b4971..17a1da7 100644
--- a/bindings/cpp/test/test_utils.h
+++ b/bindings/cpp/test/test_utils.h
@@ -306,8 +306,17 @@ class FlussTestEnvironment : public ::testing::Environment 
{
             if (result.Ok()) {
                 auto admin_result = connection_.GetAdmin(admin_);
                 if (admin_result.Ok()) {
-                    std::cout << "Connected to Fluss cluster." << std::endl;
-                    return;
+                    // check tablet server is available
+                    std::vector<fluss::ServerNode> nodes;
+                    auto nodes_result = admin_.GetServerNodes(nodes);
+                    if (nodes_result.Ok() &&
+                        std::any_of(nodes.begin(), nodes.end(),
+                                    [](const fluss::ServerNode& n) {
+                                        return n.server_type == "TabletServer";
+                                    })) {
+                        std::cout << "Connected to Fluss cluster." << 
std::endl;
+                        return;
+                    }
                 }
             }
             std::cout << "Waiting for Fluss cluster to be ready..." << 
std::endl;