Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
Impala 2.3.0
Description
Impala allows the creation of tables containing binary:
create table bin_par (c1 binary) stored as parquet;
and crashes on insert if the format is parquet:
insert into bin_par select cast(null as binary) from functional.alltypes;
(gdb) bt #0 0x0000003a3b232625 in raise () from /lib64/libc.so.6 #1 0x0000003a3b233e05 in abort () from /lib64/libc.so.6 #2 0x00000000020651a9 in ?? () #3 0x000000000205c7cd in google::LogMessage::Fail() () #4 0x0000000002060367 in google::LogMessage::SendToLog() () #5 0x000000000205ed9a in google::LogMessage::Flush() () #6 0x000000000205f06d in google::LogMessageFatal::~LogMessageFatal() () #7 0x000000000163ef72 in impala::HdfsParquetTableWriter::Init() () #8 0x00000000015d8f8c in impala::HdfsTableSink::InitOutputPartition(impala::RuntimeState*, impala::HdfsPartitionDescriptor const&, impala::OutputPartition*, bool) () #9 0x00000000015dae57 in impala::HdfsTableSink::GetOutputPartition(impala::RuntimeState*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::pair<impala::OutputPartition*, std::vector<int, std::allocator<int> > >**, bool) () #10 0x00000000015d93c2 in impala::HdfsTableSink::Send(impala::RuntimeState*, impala::RowBatch*, bool) () #11 0x000000000155f06f in impala::PlanFragmentExecutor::OpenInternal() () #12 0x000000000155e8e0 in impala::PlanFragmentExecutor::Open() () #13 0x000000000152f141 in impala::Coordinator::Wait() () #14 0x000000000130bcba in impala::ImpalaServer::QueryExecState::WaitInternal() () #15 0x000000000130b9c4 in impala::ImpalaServer::QueryExecState::Wait() () #16 0x000000000131fb59 in boost::_mfi::mf0<void, impala::ImpalaServer::QueryExecState>::operator()(impala::ImpalaServer::QueryExecState*) const () #17 0x000000000131f5fc in void boost::_bi::list1<boost::_bi::value<impala::ImpalaServer::QueryExecState*> >::operator()<boost::_mfi::mf0<void, impala::ImpalaServer::QueryExecState>, boost::_bi::list0>(boost::_bi::type<void>, boost::_mfi::mf0<void, impala::ImpalaServer::QueryExecState>&, boost::_bi::list0&, int) () #18 0x000000000131f097 in boost::_bi::bind_t<void, boost::_mfi::mf0<void, impala::ImpalaServer::QueryExecState>, boost::_bi::list1<boost::_bi::value<impala::ImpalaServer::QueryExecState*> > >::operator()() () #19 0x000000000131eaa6 in boost::detail::function::void_function_obj_invoker0<boost::_bi::bind_t<void, boost::_mfi::mf0<void, impala::ImpalaServer::QueryExecState>, boost::_bi::list1<boost::_bi::value<impala::ImpalaServer::QueryExecState*> > >, void>::invoke(boost::detail::function::function_buffer&) () #20 0x00000000011f8e8d in boost::function0<void>::operator()() const () #21 0x000000000141386a in impala::Thread::SuperviseThread(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, boost::function<void ()()>, impala::Promise<long>*) () #22 0x000000000141c9f2 in void boost::_bi::list4<boost::_bi::value<std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, boost::_bi::value<std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, boost::_bi::value<boost::function<void ()()> >, boost::_bi::value<impala::Promise<long>*> >::operator()<void (*)(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, boost::function<void ()()>, impala::Promise<long>*), boost::_bi::list0>(boost::_bi::type<void>, void (*&)(std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, std::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, boost::function<void ()()>, impala::Promise<long>*), boost::_bi::list0&, int) ()