wgtmac commented on PR #33739:
URL: https://github.com/apache/arrow/pull/33739#issuecomment-1386752574
> Do you have error logs?
I ran TSAN and found the following data race, though it didn't report the
root cause.
```
Data race (pid=96483)
Read of size 2 at 0x00010ed0bd78 by thread T6:
at 0x103ab997c
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::MaybeCalculateValidityBits(short const*, long long, long long*, long long*,
long long*) ([column_writer.cc:1420](http://column_writer.cc:1420/))
at 0x103ab9458
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)::'lambda'(long long, long
long)::operator()(long long, long long) const
([column_writer.cc:1196](http://column_writer.cc:1196/))
at 0x103ab9308 void
parquet::DoInBatches<parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)::'lambda'(long long, long long)&>(long long,
long long,
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)::'lambda'(long long, long long)&)
([column_writer.cc:1097](http://column_writer.cc:1097/))
at 0x103aa9d90
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)
([column_writer.cc:1218](http://column_writer.cc:1218/))
at 0x103aaaa34 non-virtual thunk to
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*) ([column_writer.cc](http://column_writer.cc/))
at 0x103a03a24 arrow::Status
parquet::WriteArrowZeroCopy<parquet::PhysicalType<(parquet::Type::type)5>
>(arrow::Array const&, long long, short const*, short const*,
parquet::ArrowWriteContext*,
parquet::TypedColumnWriter<parquet::PhysicalType<(parquet::Type::type)5> >*,
bool) ([column_writer.cc:1798](http://column_writer.cc:1798/))
at 0x103a03590
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteArrowDense(short const*, short const*, long long, arrow::Array const&,
parquet::ArrowWriteContext*, bool)
([column_writer.cc:2144](http://column_writer.cc:2144/))
at 0x103aaa18c
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteArrow(short const*, short const*, long long, arrow::Array const&,
parquet::ArrowWriteContext*, bool)
([column_writer.cc:1243](http://column_writer.cc:1243/))
at 0x103aaa804 non-virtual thunk to
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteArrow(short const*, short const*, long long, arrow::Array const&,
parquet::ArrowWriteContext*, bool)
([column_writer.cc](http://column_writer.cc/))
at 0x1038ad2dc parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)::operator()(parquet::arrow::MultipathLevelBuilderResult const&) const
([writer.cc:142](http://writer.cc:142/))
at 0x1038acf74 decltype(static_cast<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&>(fp)(static_cast<parquet::arrow::MultipathLevelBuilderResult
const&>(fp0))) std::__1::__invoke<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult
const&>(parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult const&)
(type_traits:3640)
at 0x1038aceb0 arrow::Status
std::__1::__invoke_void_return_wrapper<arrow::Status,
false>::__call<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult
const&>(parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult const&) (invoke.h:30)
at 0x1038ace24
std::__1::__function::__alloc_func<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&), std::__1::allocator<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)>, arrow::Status (parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&)
(function.h:180)
at 0x1038aadcc std::__1::__function::__func<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&), std::__1::allocator<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)>, arrow::Status (parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&)
(function.h:354)
at 0x10377d050 std::__1::__function::__value_func<arrow::Status
(parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&) const
(function.h:507)
at 0x10377b7ac std::__1::function<arrow::Status
(parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&) const
(function.h:1184)
at 0x10377b444 parquet::arrow::(anonymous
namespace)::WritePath(parquet::arrow::ElementRange, parquet::arrow::(anonymous
namespace)::PathInfo*, parquet::ArrowWriteContext*,
std::__1::function<arrow::Status (parquet::arrow::MultipathLevelBuilderResult
const&)>) ([path_internal.cc:637](http://path_internal.cc:637/))
at 0x10377ab0c parquet::arrow::MultipathLevelBuilderImpl::Write(int,
parquet::ArrowWriteContext*, std::__1::function<arrow::Status
(parquet::arrow::MultipathLevelBuilderResult const&)>)
([path_internal.cc:874](http://path_internal.cc:874/))
at 0x1038a096c parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)
([writer.cc:142](http://writer.cc:142/))
at 0x1038af078
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)::operator()(int) const
([writer.cc:439](http://writer.cc:439/))
at 0x1038b04f0
std::__1::enable_if<((!(std::is_void<arrow::Status>::value)) &&
(!(is_future<arrow::Status>::value))) &&
((!(arrow::Future<arrow::internal::Empty>::is_empty)) ||
(std::is_same<arrow::Status, arrow::Status>::value)), void>::type
arrow::detail::ContinueFuture::operator()<parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&, arrow::Status,
arrow::Future<arrow::internal::Empty> >(arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&) const (future.h:150)
at 0x1038b032c
decltype(static_cast<arrow::detail::ContinueFuture&>(fp)(static_cast<arrow::Future<arrow::internal::Empty>&>(fp0),
static_cast<parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&>(fp0), static_cast<int&>(fp0)))
std::__1::__invoke<arrow::detail::ContinueFuture&,
arrow::Future<arrow::internal::Empty>&,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&>(arrow::detail::ContinueFuture&,
arrow::Future<arrow::internal::Empty>&,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&) (type_traits:3640)
at 0x1038b028c std::__1::__bind_return<arrow::detail::ContinueFuture,
std::__1::tuple<arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int), int>, std::__1::tuple<>,
__is_valid_bind_return<arrow::detail::ContinueFuture,
std::__1::tuple<arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int), int>, std::__1::tuple<> >::value>::type
std::__1::__apply_functor<arrow::detail::ContinueFuture,
std::__1::tuple<arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int), int>, 0ul, 1ul, 2ul, std::__1::tuple<>
>(arrow::detail::ContinueFuture&, std::__1::tuple<a
rrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int), int>&, std::__1::__tuple_indices<0ul, 1ul, 2ul>,
std::__1::tuple<>&&) (bind.h:263)
at 0x1038b01d0 std::__1::__bind_return<arrow::detail::ContinueFuture,
std::__1::tuple<arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int), int>, std::__1::tuple<>,
__is_valid_bind_return<arrow::detail::ContinueFuture,
std::__1::tuple<arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int), int>, std::__1::tuple<> >::value>::type
std::__1::__bind<arrow::detail::ContinueFuture,
arrow::Future<arrow::internal::Empty>&,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&>::operator()<>() (bind.h:298)
at 0x1038b00f0 arrow::internal::FnOnce<void
()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture,
arrow::Future<arrow::internal::Empty>&,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&> >::invoke() (functional.h:152)
at 0x104109f58 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*)
Previous write of size 4 at 0x00010ed0bd78 by thread T10:
at 0x103affe9c void arrow::stl::allocator<int>::construct<int, int
const&>(int*, int const&) (stl_allocator.h:79)
at 0x103affe1c void std::__1::allocator_traits<arrow::stl::allocator<int>
>::construct<int, int const&, void>(arrow::stl::allocator<int>&, int*, int
const&) (allocator_traits.h:290)
at 0x103affbb4 void std::__1::vector<int, arrow::stl::allocator<int>
>::__construct_one_at_end<int const&>(int const&) (vector:778)
at 0x103afe7f8 std::__1::vector<int, arrow::stl::allocator<int>
>::push_back(int const&) (vector:1531)
at 0x103b20e7c parquet::(anonymous
namespace)::DictEncoderImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::Put(double const&) ([encoding.cc:704](http://encoding.cc:704/))
at 0x103b1f15c parquet::(anonymous
namespace)::DictEncoderImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::Put(double const*, int) ([encoding.cc:543](http://encoding.cc:543/))
at 0x103b1fc0c virtual thunk to parquet::(anonymous
namespace)::DictEncoderImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::Put(double const*, int) ([encoding.cc](http://encoding.cc/))
at 0x103aba340
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteValuesSpaced(double const*, long long, long long, unsigned char const*,
long long, long long) ([column_writer.cc:1574](http://column_writer.cc:1574/))
at 0x103ab96b8
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)::'lambda'(long long, long
long)::operator()(long long, long long) const
([column_writer.cc:1207](http://column_writer.cc:1207/))
at 0x103ab9308 void
parquet::DoInBatches<parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)::'lambda'(long long, long long)&>(long long,
long long,
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)::'lambda'(long long, long long)&)
([column_writer.cc:1097](http://column_writer.cc:1097/))
at 0x103aa9d90
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*)
([column_writer.cc:1218](http://column_writer.cc:1218/))
at 0x103aaaa34 non-virtual thunk to
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteBatchSpaced(long long, short const*, short const*, unsigned char
const*, long long, double const*) ([column_writer.cc](http://column_writer.cc/))
at 0x103a03a24 arrow::Status
parquet::WriteArrowZeroCopy<parquet::PhysicalType<(parquet::Type::type)5>
>(arrow::Array const&, long long, short const*, short const*,
parquet::ArrowWriteContext*,
parquet::TypedColumnWriter<parquet::PhysicalType<(parquet::Type::type)5> >*,
bool) ([column_writer.cc:1798](http://column_writer.cc:1798/))
at 0x103a03590
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteArrowDense(short const*, short const*, long long, arrow::Array const&,
parquet::ArrowWriteContext*, bool)
([column_writer.cc:2144](http://column_writer.cc:2144/))
at 0x103aaa18c
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteArrow(short const*, short const*, long long, arrow::Array const&,
parquet::ArrowWriteContext*, bool)
([column_writer.cc:1243](http://column_writer.cc:1243/))
at 0x103aaa804 non-virtual thunk to
parquet::TypedColumnWriterImpl<parquet::PhysicalType<(parquet::Type::type)5>
>::WriteArrow(short const*, short const*, long long, arrow::Array const&,
parquet::ArrowWriteContext*, bool)
([column_writer.cc](http://column_writer.cc/))
at 0x1038ad2dc parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)::operator()(parquet::arrow::MultipathLevelBuilderResult const&) const
([writer.cc:142](http://writer.cc:142/))
at 0x1038acf74 decltype(static_cast<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&>(fp)(static_cast<parquet::arrow::MultipathLevelBuilderResult
const&>(fp0))) std::__1::__invoke<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult
const&>(parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult const&)
(type_traits:3640)
at 0x1038aceb0 arrow::Status
std::__1::__invoke_void_return_wrapper<arrow::Status,
false>::__call<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult
const&>(parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)&, parquet::arrow::MultipathLevelBuilderResult const&) (invoke.h:30)
at 0x1038ace24
std::__1::__function::__alloc_func<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&), std::__1::allocator<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)>, arrow::Status (parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&)
(function.h:180)
at 0x1038aadcc std::__1::__function::__func<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&), std::__1::allocator<parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)::'lambda'(parquet::arrow::MultipathLevelBuilderResult
const&)>, arrow::Status (parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&)
(function.h:354)
at 0x10377d050 std::__1::__function::__value_func<arrow::Status
(parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&) const
(function.h:507)
at 0x10377b7ac std::__1::function<arrow::Status
(parquet::arrow::MultipathLevelBuilderResult
const&)>::operator()(parquet::arrow::MultipathLevelBuilderResult const&) const
(function.h:1184)
at 0x10377b444 parquet::arrow::(anonymous
namespace)::WritePath(parquet::arrow::ElementRange, parquet::arrow::(anonymous
namespace)::PathInfo*, parquet::ArrowWriteContext*,
std::__1::function<arrow::Status (parquet::arrow::MultipathLevelBuilderResult
const&)>) ([path_internal.cc:637](http://path_internal.cc:637/))
at 0x10377ab0c parquet::arrow::MultipathLevelBuilderImpl::Write(int,
parquet::ArrowWriteContext*, std::__1::function<arrow::Status
(parquet::arrow::MultipathLevelBuilderResult const&)>)
([path_internal.cc:874](http://path_internal.cc:874/))
at 0x1038a096c parquet::arrow::(anonymous
namespace)::ArrowColumnWriterV2::Write(parquet::ArrowWriteContext*)
([writer.cc:142](http://writer.cc:142/))
at 0x1038af078
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)::operator()(int) const
([writer.cc:439](http://writer.cc:439/))
at 0x1038b04f0
std::__1::enable_if<((!(std::is_void<arrow::Status>::value)) &&
(!(is_future<arrow::Status>::value))) &&
((!(arrow::Future<arrow::internal::Empty>::is_empty)) ||
(std::is_same<arrow::Status, arrow::Status>::value)), void>::type
arrow::detail::ContinueFuture::operator()<parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&, arrow::Status,
arrow::Future<arrow::internal::Empty> >(arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&) const (future.h:150)
at 0x1038b032c
decltype(static_cast<arrow::detail::ContinueFuture&>(fp)(static_cast<arrow::Future<arrow::internal::Empty>&>(fp0),
static_cast<parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&>(fp0), static_cast<int&>(fp0)))
std::__1::__invoke<arrow::detail::ContinueFuture&,
arrow::Future<arrow::internal::Empty>&,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&>(arrow::detail::ContinueFuture&,
arrow::Future<arrow::internal::Empty>&,
parquet::arrow::FileWriterImpl::WriteRecordBatch(arrow::RecordBatch
const&)::'lambda'(long long, long long)::operator()(long long, long long)
const::'lambda'(int)&, int&) (type_traits:3640)
at 0x1038b028c std::__1::__bind_return<arrow::detail::ContinueFuture,
std::__1::tuple<arrow::Future<arrow::internal::Empty>,
parquet::arrow::FileWriterImpl::Wr
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
