(arrow-experiments) branch main updated: GH-43130: [C++][ArrowFlight] Crash due to UCS thread mode (#30)

[ianmcook]

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

ianmcook pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-experiments.git


The following commit(s) were added to refs/heads/main by this push:
     new 92c98c3  GH-43130: [C++][ArrowFlight] Crash due to UCS thread mode 
(#30)
92c98c3 is described below

commit 92c98c374a4c98f8a8ca1258a081c2ecb645f2f7
Author: Amir Gonnen <amirgon...@gmail.com>
AuthorDate: Mon Jul 8 18:31:13 2024 +0300

    GH-43130: [C++][ArrowFlight] Crash due to UCS thread mode (#30)
    
    Fix reference example based on the same fix on Arrow.
    
    See: https://github.com/apache/arrow/pull/43120
---
 dissociated-ipc/ucx_client.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dissociated-ipc/ucx_client.cc b/dissociated-ipc/ucx_client.cc
index 91bf140..a15b52b 100644
--- a/dissociated-ipc/ucx_client.cc
+++ b/dissociated-ipc/ucx_client.cc
@@ -57,7 +57,7 @@ arrow::Result<std::unique_ptr<utils::Connection>> 
UcxClient::CreateConn() {
   std::memset(&worker_params, 0, sizeof(worker_params));
   worker_params.field_mask =
       UCP_WORKER_PARAM_FIELD_THREAD_MODE | UCP_WORKER_PARAM_FIELD_FLAGS;
-  worker_params.thread_mode = UCS_THREAD_MODE_SERIALIZED;
+  worker_params.thread_mode = UCS_THREAD_MODE_MULTI;
   worker_params.flags = UCP_WORKER_FLAG_IGNORE_REQUEST_LEAK;
 
   ucp_worker_h ucp_worker;