Porting ALICE-specific changes#6
Conversation
|
Thanks for opening a pull request! If this is not a minor PR. Could you open an issue for this pull request on JIRA? https://issues.apache.org/jira/browse/ARROW Opening JIRAs ahead of time contributes to the Openness of the Apache Arrow project. Then could you also rename pull request title in the following format? or See also: |
|
@ktf here are the changes. Let's wait for the tests to run before merging, though, maybe I have missed something. |
d5699e2 to
2fdd118
Compare
|
There is at least this issue: |
|
@pzhristov that one I already fixed, but there is gandiva-internal-test failing and I can't seem to find the reason. On top of that I cannot build arrow tests locally, neither with brew-installed google test, nor the one from alibuild. Also the latter does not seem to have an environment config. |
|
@aalkin Thanks, at least it compiles now. |
|
@ktf @pzhristov I think I've fixed issues introduced by my code, there is still s3fs test failing, and some of the CI tests fail at installing dependencies but all that is not relevant for us. I believe this is good to go. |
|
@aalkin Thanks, I will test it on CC7/CC8, where we had issues with 3.0.0. |
|
I've merged this so that we can try in the CI as well. |
From a deadlocked run... ``` #0 0x00007f8a5d48dccd in __lll_lock_wait () from /lib64/libpthread.so.0 #1 0x00007f8a5d486f05 in pthread_mutex_lock () from /lib64/libpthread.so.0 #2 0x00007f8a566e7e89 in arrow::internal::FnOnce<void ()>::FnImpl<arrow::Future<Aws::Utils::Outcome<Aws::S3::Model::ListObjectsV2Result, Aws::S3::S3Error> >::Callback<arrow::fs::(anonymous namespace)::TreeWalker::ListObjectsV2Handler> >::invoke() () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #3 0x00007f8a5650efa0 in arrow::FutureImpl::AddCallback(arrow::internal::FnOnce<void ()>) () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #4 0x00007f8a566e67a9 in arrow::fs::(anonymous namespace)::TreeWalker::ListObjectsV2Handler::SpawnListObjectsV2() () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #5 0x00007f8a566e723f in arrow::fs::(anonymous namespace)::TreeWalker::WalkChild(std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> >, int) () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #6 0x00007f8a566e827d in arrow::internal::FnOnce<void ()>::FnImpl<arrow::Future<Aws::Utils::Outcome<Aws::S3::Model::ListObjectsV2Result, Aws::S3::S3Error> >::Callback<arrow::fs::(anonymous namespace)::TreeWalker::ListObjectsV2Handler> >::invoke() () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #7 0x00007f8a5650efa0 in arrow::FutureImpl::AddCallback(arrow::internal::FnOnce<void ()>) () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #8 0x00007f8a566e67a9 in arrow::fs::(anonymous namespace)::TreeWalker::ListObjectsV2Handler::SpawnListObjectsV2() () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #9 0x00007f8a566e723f in arrow::fs::(anonymous namespace)::TreeWalker::WalkChild(std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> >, int) () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so #10 0x00007f8a566e74b1 in arrow::fs::(anonymous namespace)::TreeWalker::DoWalk() () from /arrow/r/check/arrow.Rcheck/arrow/libs/arrow.so ``` The callback `ListObjectsV2Handler` is being called recursively and the mutex is non-reentrant thus deadlock. To fix it I got rid of the mutex on `TreeWalker` by using `arrow::util::internal::TaskGroup` instead of manually tracking the #/status of in-flight requests. Closes apache#9842 from westonpace/bugfix/arrow-12040 Lead-authored-by: Weston Pace <weston.pace@gmail.com> Co-authored-by: Antoine Pitrou <antoine@python.org> Signed-off-by: Antoine Pitrou <antoine@python.org>
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
* Additional native functions for float32 in Gandiva * Extend bitwise operations for more int types * Adapt to upstream trigonometric function definitions * Prevent clash with c++ variant
No description provided.