You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@arrow.apache.org by "Jonathan Keane (Jira)" <ji...@apache.org> on 2022/02/19 14:16:00 UTC
[jira] [Resolved] (ARROW-15708) [R] [CI] skip snappy encoded parquets on clang sanitizer
[ https://issues.apache.org/jira/browse/ARROW-15708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Keane resolved ARROW-15708.
------------------------------------
Fix Version/s: 8.0.0
Resolution: Fixed
Issue resolved by pull request 12443
[https://github.com/apache/arrow/pull/12443]
> [R] [CI] skip snappy encoded parquets on clang sanitizer
> --------------------------------------------------------
>
> Key: ARROW-15708
> URL: https://issues.apache.org/jira/browse/ARROW-15708
> Project: Apache Arrow
> Issue Type: Improvement
> Components: Continuous Integration, R
> Reporter: Jonathan Keane
> Assignee: Jonathan Keane
> Priority: Major
> Labels: pull-request-available
> Fix For: 8.0.0
>
> Time Spent: 1.5h
> Remaining Estimate: 0h
>
> Showing up in our nightlies with:
> {code}
> #17 0x7f5004603315 in arrow::Future<std::__1::vector<std::__1::shared_ptr<arrow::ChunkedArray>, std::__1::allocator<std::__1::shared_ptr<arrow::ChunkedArray> > > > arrow::internal::OptionalParallelForAsync<parquet::arrow::(anonymous namespace)::FileReaderImpl::DecodeRowGroups(std::__1::shared_ptr<parquet::arrow::(anonymous namespace)::FileReaderImpl>, std::__1::vector<int, std::__1::allocator<int> > const&, std::__1::vector<int, std::__1::allocator<int> > const&, arrow::internal::Executor*)::$_4&, std::__1::shared_ptr<parquet::arrow::ColumnReaderImpl>, std::__1::shared_ptr<arrow::ChunkedArray> >(bool, std::__1::vector<std::__1::shared_ptr<parquet::arrow::ColumnReaderImpl>, std::__1::allocator<std::__1::shared_ptr<parquet::arrow::ColumnReaderImpl> > >, parquet::arrow::(anonymous namespace)::FileReaderImpl::DecodeRowGroups(std::__1::shared_ptr<parquet::arrow::(anonymous namespace)::FileReaderImpl>, std::__1::vector<int, std::__1::allocator<int> > const&, std::__1::vector<int, std::__1::allocator<int> > const&, arrow::internal::Executor*)::$_4&, arrow::internal::Executor*) /arrow/cpp/src/arrow/util/parallel.h:95:7
> #18 0x7f50046026d9 in parquet::arrow::(anonymous namespace)::FileReaderImpl::DecodeRowGroups(std::__1::shared_ptr<parquet::arrow::(anonymous namespace)::FileReaderImpl>, std::__1::vector<int, std::__1::allocator<int> > const&, std::__1::vector<int, std::__1::allocator<int> > const&, arrow::internal::Executor*) /arrow/cpp/src/parquet/arrow/reader.cc:1198:10
> #19 0x7f5004601994 in parquet::arrow::RowGroupGenerator::ReadOneRowGroup(arrow::internal::Executor*, std::__1::shared_ptr<parquet::arrow::(anonymous namespace)::FileReaderImpl>, int, std::__1::vector<int, std::__1::allocator<int> > const&) /arrow/cpp/src/parquet/arrow/reader.cc:1090:18
> #20 0x7f5004658330 in parquet::arrow::RowGroupGenerator::operator()()::'lambda'()::operator()() const /arrow/cpp/src/parquet/arrow/reader.cc:1064:14
> #21 0x7f500465806f in std::__1::enable_if<is_future<arrow::Future<std::__1::function<arrow::Future<std::__1::shared_ptr<arrow::RecordBatch> > ()> > >::value, void>::type arrow::detail::ContinueFuture::operator()<parquet::arrow::RowGroupGenerator::operator()()::'lambda'(), arrow::Future<std::__1::function<arrow::Future<std::__1::shared_ptr<arrow::RecordBatch> > ()> >, arrow::Future<std::__1::function<arrow::Future<std::__1::shared_ptr<arrow::RecordBatch> > ()> > >(arrow::Future<std::__1::function<arrow::Future<std::__1::shared_ptr<arrow::RecordBatch> > ()> >, parquet::arrow::RowGroupGenerator::operator()()::'lambda'()&&) const /arrow/cpp/src/arrow/util/future.h:177:9
> #22 0x7f5004657c03 in void arrow::detail::ContinueFuture::IgnoringArgsIf<parquet::arrow::RowGroupGenerator::operator()()::'lambda'(), arrow::Future<std::__1::function<arrow::Future<std::__1::shared_ptr<arrow::RecordBatch> > ()> >, arrow::internal::Empty const&>(std::__1::integral_constant<bool, true>, arrow::Future<std::__1::function<arrow::Future<std::__1::shared_ptr<arrow::RecordBatch> > ()> >&&, parquet::arrow::RowGroupGenerator::operator()()::'lambda'()&&, arrow::internal::Empty const&) const /arrow/cpp/src/arrow/util/future.h:186:5
> #23 0x7f500465797a in arrow::Future<arrow::internal::Empty>::ThenOnComplete<parquet::arrow::RowGroupGenerator::operator()()::'lambda'(), arrow::Future<arrow::internal::Empty>::PassthruOnFailure<parquet::arrow::RowGroupGenerator::operator()()::'lambda'()> >::operator()(arrow::Result<arrow::internal::Empty> const&) && /arrow/cpp/src/arrow/util/future.h:599:25
> #24 0x7f5005c95bfe in arrow::internal::FnOnce<void (arrow::FutureImpl const&)>::operator()(arrow::FutureImpl const&) && /arrow/cpp/src/arrow/util/functional.h:140:17
> #25 0x7f5005c948f5 in arrow::ConcreteFutureImpl::RunOrScheduleCallback(std::__1::shared_ptr<arrow::FutureImpl> const&, arrow::FutureImpl::CallbackRecord&&, bool) /arrow/cpp/src/arrow/util/future.cc:298:7
> #26 0x7f5005c94017 in arrow::ConcreteFutureImpl::DoMarkFinishedOrFailed(arrow::FutureState) /arrow/cpp/src/arrow/util/future.cc:327:7
> #27 0x7f50042731fe in arrow::Future<arrow::internal::Empty>::DoMarkFinished(arrow::Result<arrow::internal::Empty>) /arrow/cpp/src/arrow/util/future.h:712:14
> #28 0x7f5004272df8 in void arrow::Future<arrow::internal::Empty>::MarkFinished<arrow::internal::Empty, void>(arrow::Status) /arrow/cpp/src/arrow/util/future.h:463:12
> #29 0x7f500465244b in arrow::Future<arrow::internal::Empty> arrow::internal::Executor::DoTransfer<arrow::internal::Empty, arrow::Future<arrow::internal::Empty>, arrow::Status>(arrow::Future<arrow::internal::Empty>, bool)::'lambda'(arrow::Status const&)::operator()(arrow::Status const&) /arrow/cpp/src/arrow/util/thread_pool.h:217:21
> #30 0x7f500465244b in arrow::Future<arrow::internal::Empty>::WrapStatusyOnComplete::Callback<arrow::Future<arrow::internal::Empty> arrow::internal::Executor::DoTransfer<arrow::internal::Empty, arrow::Future<arrow::internal::Empty>, arrow::Status>(arrow::Future<arrow::internal::Empty>, bool)::'lambda'(arrow::Status const&)>::operator()(arrow::FutureImpl const&) && /arrow/cpp/src/arrow/util/future.h:509:9
> #31 0x7f5005c95bfe in arrow::internal::FnOnce<void (arrow::FutureImpl const&)>::operator()(arrow::FutureImpl const&) && /arrow/cpp/src/arrow/util/functional.h:140:17
> #32 0x7f5005d6f147 in arrow::internal::FnOnce<void ()>::operator()() && /arrow/cpp/src/arrow/util/functional.h:140:17
> #33 0x7f5005d6dc65 in arrow::internal::WorkerLoop(std::__1::shared_ptr<arrow::internal::ThreadPool::State>, std::__1::__list_iterator<std::__1::thread, void*>) /arrow/cpp/src/arrow/util/thread_pool.cc:178:11
> #34 0x7f5005d6d67b in arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3::operator()() const /arrow/cpp/src/arrow/util/thread_pool.cc:349:7
> #35 0x7f5005d6d67b in decltype(std::__1::forward<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>(fp)()) std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3&&) /usr/bin/../include/c++/v1/type_traits:3899:1
> #36 0x7f5005d6cf9c in void* std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3> >(void*) /usr/bin/../include/c++/v1/thread:291:5
> #37 0x7f50182343f8 in start_thread (/lib64/libpthread.so.0+0x93f8)
> #38 0x7f50180774c2 in clone (/lib64/libc.so.6+0x1014c2)
> {code}
> https://dev.azure.com/ursacomputing/crossbow/_build/results?buildId=19810&view=logs&j=0da5d1d9-276d-5173-c4c4-9d4d4ed14fdb&t=d9b15392-e4ce-5e4c-0c8c-b69645229181&l=4096
--
This message was sent by Atlassian Jira
(v8.20.1#820001)