pitrou opened a new pull request #11725:
URL: https://github.com/apache/arrow/pull/11725
Error log of Valgrind failure:
```
[----------] 3 tests from TestArrowReadDeltaEncoding
[ RUN ] TestArrowReadDeltaEncoding.DeltaBinaryPacked
[ OK ] TestArrowReadDeltaEncoding.DeltaBinaryPacked (812 ms)
[ RUN ] TestArrowReadDeltaEncoding.DeltaByteArray
==12587== Conditional jump or move depends on uninitialised value(s)
==12587== at 0x4F12C57: Advance (bit_stream_utils.h:426)
==12587== by 0x4F12C57: parquet::(anonymous
namespace)::DeltaBitPackDecoder<parquet::PhysicalType<(parquet::Type::type)1>
>::GetInternal(int*, int) (encoding.cc:2216)
==12587== by 0x4F13823: Decode (encoding.cc:2091)
==12587== by 0x4F13823: parquet::(anonymous
namespace)::DeltaByteArrayDecoder::SetData(int, unsigned char const*, int)
(encoding.cc:2360)
==12587== by 0x4E89EF5: parquet::(anonymous
namespace)::ColumnReaderImplBase<parquet::PhysicalType<(parquet::Type::type)6>
>::InitializeDataDecoder(parquet::DataPage const&, long) (column_reader.cc:797)
==12587== by 0x4E9AE63: ReadNewPage (column_reader.cc:614)
==12587== by 0x4E9AE63: HasNextInternal (column_reader.cc:576)
==12587== by 0x4E9AE63: parquet::internal::(anonymous
namespace)::TypedRecordReader<parquet::PhysicalType<(parquet::Type::type)6>
>::ReadRecords(long) (column_reader.cc:1228)
==12587== by 0x4DFB19F: parquet::arrow::(anonymous
namespace)::LeafReader::LoadBatch(long) (reader.cc:467)
==12587== by 0x4DF513C: parquet::arrow::ColumnReaderImpl::NextBatch(long,
std::shared_ptr<arrow::ChunkedArray>*) (reader.cc:108)
==12587== by 0x4DFB74D: parquet::arrow::(anonymous
namespace)::FileReaderImpl::ReadColumn(int, std::vector<int,
std::allocator<int> > const&, parquet::arrow::ColumnReader*,
std::shared_ptr<arrow::ChunkedArray>*) (reader.cc:273)
==12587== by 0x4E11FDA: operator() (reader.cc:1180)
==12587== by 0x4E11FDA:
arrow::Future<std::vector<std::shared_ptr<arrow::ChunkedArray>,
std::allocator<arrow::Future> > >
arrow::internal::OptionalParallelForAsync<parquet::arrow::(anonymous
namespace)::FileReaderImpl::DecodeRowGroups(std::shared_ptr<parquet::arrow::(anonymous
namespace)::FileReaderImpl>, std::vector<int, std::allocator<int> > const&,
std::vector<int, std::allocator<int> > const&,
arrow::internal::Executor*)::{lambda(unsigned long,
std::shared_ptr<parquet::arrow::ColumnReaderImpl>)#1}&,
std::shared_ptr<parquet::arrow::ColumnReaderImpl>,
std::shared_ptr<arrow::ChunkedArray> >(bool,
std::vector<std::shared_ptr<parquet::arrow::ColumnReaderImpl>,
std::allocator<arrow::Future<std::vector<std::shared_ptr<arrow::ChunkedArray>,
std::allocator<arrow::Future> > > > >, parquet::arrow::(anonymous
namespace)::FileReaderImpl::DecodeRowGroups(std::shared_ptr<parquet::arrow::(anonymous
namespace)::FileReaderImpl>, std::vector<int, std::allocator<int> > const&,
std::vector<int,
std::allocator<int> > const&, arrow::internal::Executor*)::{lambda(unsigned
long, std::shared_ptr<parquet::arrow::ColumnReaderImpl>)#1}&,
arrow::internal::Executor*) (parallel.h:95)
==12587== by 0x4E126A9: parquet::arrow::(anonymous
namespace)::FileReaderImpl::DecodeRowGroups(std::shared_ptr<parquet::arrow::(anonymous
namespace)::FileReaderImpl>, std::vector<int, std::allocator<int> > const&,
std::vector<int, std::allocator<int> > const&, arrow::internal::Executor*)
(reader.cc:1198)
==12587== by 0x4E12F50: parquet::arrow::(anonymous
namespace)::FileReaderImpl::ReadRowGroups(std::vector<int, std::allocator<int>
> const&, std::vector<int, std::allocator<int> > const&,
std::shared_ptr<arrow::Table>*) (reader.cc:1160)
==12587== by 0x4DFA2BC: parquet::arrow::(anonymous
namespace)::FileReaderImpl::ReadTable(std::vector<int, std::allocator<int> >
const&, std::shared_ptr<arrow::Table>*) (reader.cc:198)
==12587== by 0x4DFA392: parquet::arrow::(anonymous
namespace)::FileReaderImpl::ReadTable(std::shared_ptr<arrow::Table>*)
(reader.cc:289)
==12587== by 0x1DCE62:
parquet::arrow::TestArrowReadDeltaEncoding::ReadTableFromParquetFile(std::__cxx11::basic_string<char,
std::char_traits<char>, std::allocator<char> > const&,
std::shared_ptr<arrow::Table>*) (arrow_reader_writer_test.cc:4174)
==12587== by 0x2266D2:
parquet::arrow::TestArrowReadDeltaEncoding_DeltaByteArray_Test::TestBody()
(arrow_reader_writer_test.cc:4209)
==12587== by 0x4AD2C9B: void
testing::internal::HandleSehExceptionsInMethodIfSupported<testing::Test,
void>(testing::Test*, void (testing::Test::*)(), char const*) (gtest.cc:2607)
==12587== by 0x4AC9DD1: void
testing::internal::HandleExceptionsInMethodIfSupported<testing::Test,
void>(testing::Test*, void (testing::Test::*)(), char const*) (gtest.cc:2643)
==12587== by 0x4AA4C02: testing::Test::Run() (gtest.cc:2682)
==12587== by 0x4AA563A: testing::TestInfo::Run() (gtest.cc:2861)
==12587== by 0x4AA600F: testing::TestSuite::Run() (gtest.cc:3015)
==12587== by 0x4AB631B: testing::internal::UnitTestImpl::RunAllTests()
(gtest.cc:5855)
==12587== by 0x4AD3CE7: bool
testing::internal::HandleSehExceptionsInMethodIfSupported<testing::internal::UnitTestImpl,
bool>(testing::internal::UnitTestImpl*, bool
(testing::internal::UnitTestImpl::*)(), char const*) (gtest.cc:2607)
==12587== by 0x4ACB063: bool
testing::internal::HandleExceptionsInMethodIfSupported<testing::internal::UnitTestImpl,
bool>(testing::internal::UnitTestImpl*, bool
(testing::internal::UnitTestImpl::*)(), char const*) (gtest.cc:2643)
==12587== by 0x4AB47B6: testing::UnitTest::Run() (gtest.cc:5438)
==12587== by 0x4218918: RUN_ALL_TESTS() (gtest.h:2490)
==12587== by 0x421895B: main (gtest_main.cc:52)
```
--
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]