From 3afdfdef7ac93cda55267994f9865296e061c25c Mon Sep 17 00:00:00 2001 From: Chong Gao Date: Tue, 26 Nov 2024 15:43:44 +0800 Subject: [PATCH] Use exec_policy_nosync instead of exec_policy --- src/main/cpp/compile_commands.json | 1 + src/main/cpp/src/HLLPP.cu | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) create mode 120000 src/main/cpp/compile_commands.json diff --git a/src/main/cpp/compile_commands.json b/src/main/cpp/compile_commands.json new file mode 120000 index 000000000..921c8b97d --- /dev/null +++ b/src/main/cpp/compile_commands.json @@ -0,0 +1 @@ +/home/chongg/code/spark-rapids-jni/target/jni/cmake-build/compile_commands.json \ No newline at end of file diff --git a/src/main/cpp/src/HLLPP.cu b/src/main/cpp/src/HLLPP.cu index ca35e7786..939d8fe2e 100644 --- a/src/main/cpp/src/HLLPP.cu +++ b/src/main/cpp/src/HLLPP.cu @@ -92,7 +92,7 @@ std::unique_ptr estimate_from_hll_sketches(cudf::column_view const auto result = cudf::make_numeric_column( cudf::data_type{cudf::type_id::INT64}, input.size(), cudf::mask_state::ALL_VALID, stream); // evaluate from struct - thrust::for_each_n(rmm::exec_policy(stream), + thrust::for_each_n(rmm::exec_policy_nosync(stream), thrust::make_counting_iterator(0), input.size(), estimate_fn{d_inputs, precision, result->mutable_view().data()});