This is an automated email from the ASF dual-hosted git repository.
isapego pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new fffbc662d7e IGNITE-21553 fixed test: compute broadcast when using
incorrect node. (#6381)
fffbc662d7e is described below
commit fffbc662d7e8b29647af81b2f644a0d70b35114b
Author: Ed Rakhmankulov <[email protected]>
AuthorDate: Thu Aug 7 20:08:19 2025 +0300
IGNITE-21553 fixed test: compute broadcast when using incorrect node.
(#6381)
---
.../cpp/tests/client-test/compute_test.cpp | 21 ++++++++-------------
1 file changed, 8 insertions(+), 13 deletions(-)
diff --git a/modules/platforms/cpp/tests/client-test/compute_test.cpp
b/modules/platforms/cpp/tests/client-test/compute_test.cpp
index b0a561dc9a6..4898e5bdd5a 100644
--- a/modules/platforms/cpp/tests/client-test/compute_test.cpp
+++ b/modules/platforms/cpp/tests/client-test/compute_test.cpp
@@ -222,21 +222,16 @@ TEST_F(compute_test, unknown_node_execute_throws) {
ignite_error);
}
-// TODO https://issues.apache.org/jira/browse/IGNITE-21553
-TEST_F(compute_test, DISABLED_unknown_node_broadcast_throws) {
+TEST_F(compute_test, unknown_node_broadcast_throws) {
auto unknown_node = cluster_node(uuid(1, 2), "random", {"127.0.0.1",
1234});
- EXPECT_THROW(
- {
- try {
-
m_client.get_compute().submit_broadcast(broadcast_job_target::node(unknown_node),
m_echo_job, {"unused"});
- } catch (const ignite_error &e) {
- EXPECT_THAT(e.what_str(),
- testing::HasSubstr("None of the specified nodes are
present in the cluster: [random]"));
- throw;
- }
- },
- ignite_error);
+ auto results =
+
m_client.get_compute().submit_broadcast(broadcast_job_target::node(unknown_node),
m_echo_job, {"unused"});
+
+ EXPECT_TRUE(results.get_job_executions()[0].has_error());
+
+ auto& e = results.get_job_executions()[0].error();
+ EXPECT_THAT(e.what_str(), testing::HasSubstr("None of the specified nodes
are present in the cluster: [random]"));
}
TEST_F(compute_test, all_arg_types) {
