You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
CREATE TABLE `/Root/test/my_column_table` (
id Int64 NOT NULL,
income Decimal(22,9),
PRIMARY KEY (id)
)
PARTITION BY HASH(id)
WITH (STORE = COLUMN);
$ls = ListMap(ListFromRange(0, 1000), ($i)-> {return <|id: $i, income: Cast($i as Decimal(22,9)) / 100|>});
upsert into `/Root/test/my_column_table` select * from AS_TABLE($ls);
select sum(income) from `/Root/test/my_column_table`;
#0 CH::Aggregator::Aggregator (this=0x7fa7c74a0fe0, params_=...)
at /home/zverevgeny/github/my/ydb/ydb/library/arrow_clickhouse/Aggregator.cpp:104 #1 0x000000000bb4c064 in CH::AggregatingBlockInputStream::AggregatingBlockInputStream (this=this@entry=0x7fa7c74a0ea0,
input=..., params_=..., final_=true)
at /home/zverevgeny/github/my/ydb/ydb/library/arrow_clickhouse/DataStreams/AggregatingBlockInputStream.h:28 #2 0x000000000bb4abfd in CH::ArrowAggregateFunctionWrapper::Execute (this=0x46ddf066b128, args=..., options=)
at /home/zverevgeny/github/my/ydb/ydb/library/arrow_clickhouse/AggregateFunctions/AggregateFunctionWrapper.h:85 #3 0x000000000a97fa9d in arrow::compute::CallFunction (func_name=..., args=..., options=options@entry=0x46ddf06591e8,
ctx=0x7fa7c74a73b8) at /home/zverevgeny/github/my/ydb/contrib/libs/apache/arrow/cpp/src/arrow/compute/exec.cc:1041 #4 0x000000000bbf196e in NKikimr::NSsa::TInternalFunctionNKikimr::NSsa::TAggregateAssign::Call (this=0x46ddf072d408,
assign=..., batch=...) at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.cpp:78 #5 0x000000000bbe90da in NKikimr::NSsa::TProgramStep::ApplyAggregates (this=this@entry=0x46ddf2a14548, batch=...,
ctx=ctx@entry=0x7fa7c74a73b8) at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.cpp:756 #6 0x000000000bbec351 in NKikimr::NSsa::TProgramStep::Apply (this=0x46ddf2a14548, batch=..., ctx=0x7fa7c74a73b8)
at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.cpp:925 #7 0x0000000008924f02 in NKikimr::NSsa::TProgram::ApplyTo (this=, batch=..., ctx=0x7fa7c74a73b8)
at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.h:479 #8 0x0000000010593211 in NKikimr::NSsa::TProgram::ApplyTo (this=this@entry=0x46ddf1909f78, table=..., ctx=0x7fa7c74a73b8)
at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.h:467 #9 0x000000001058e562 in NKikimr::NOlap::TProgramContainer::ApplyProgramarrow::Table (this=, batch=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/program/program.h:96 #10 0x000000001058da2f in NKikimr::NOlap::NReader::NPlain::TBaseMergeTask::PrepareResultBatch (this=this@entry=0x46ddf199c6e8)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/columnshard/engines/reader/plain_reader/iterator/merge.cpp:41 #11 0x000000001058fb3e in NKikimr::NOlap::NReader::NPlain::TStartMergeTask::DoExecuteImpl (this=0x46ddf199c6e8)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/columnshard/engines/reader/plain_reader/iterator/merge.cpp:106 #12 0x00000000105cc0b1 in NKikimr::NOlap::NReader::IDataTasksProcessor::ITask::DoExecute (this=0x0, taskPtr=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/columnshard/engines/reader/common/conveyor_task.cpp:8 #13 0x00000000105560f0 in NKikimr::NConveyor::ITask::Execute (this=0x46ddf199c6e8, signals=..., taskPtr=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/conveyor/usage/abstract.cpp:13 #14 0x000000001765812e in NKikimr::NConveyor::TWorker::ExecuteTask (this=0x46ddff856e70, workerTask=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/conveyor/service/worker.cpp:10 #15 0x00000000099ecade in NActors::TGenericExecutorThread::Execute (this=this@entry=0x46ddff640c00,
mailbox=mailbox@entry=0x46ddfbfe2140, isTailExecution=)
at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:281 #16 0x00000000099f0431 in NActors::TGenericExecutorThread::ProcessExecutorPool(NActors::IExecutorPool*)::$_0::operator()(NActors::TMailbox*, bool) const (this=this@entry=0x7fa7c74a1f30, mailbox=mailbox@entry=0x46ddfbfe2140, isTailExecution=false)
at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:475 #17 0x00000000099eff83 in NActors::TGenericExecutorThread::ProcessExecutorPool (this=this@entry=0x46ddff640c00,
pool=) at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:529 #18 0x00000000099f0b86 in NActors::TExecutorThread::ThreadProc (this=0x46ddff640c00)
at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:560 #19 0x0000000008f22a08 in (anonymous namespace)::TPosixThread::ThreadProxy (arg=0x46ddfe5e6910)
at /home/zverevgeny/github/my/ydb/util/system/thread.cpp:244 #20 0x00007fa7fe739b5a in start_thread (arg=) at ./nptl/pthread_create.c:444
The text was updated successfully, but these errors were encountered:
@aavdonkin посмотри, плиз. Нужно, как минимум поставить VERIFY, чтобы было проще диагностировать. Желательно, возвращать какую-то ошибку вместо падения
#0 CH::Aggregator::Aggregator (this=0x7fa7c74a0fe0, params_=...)
at /home/zverevgeny/github/my/ydb/ydb/library/arrow_clickhouse/Aggregator.cpp:104
#1 0x000000000bb4c064 in CH::AggregatingBlockInputStream::AggregatingBlockInputStream (this=this@entry=0x7fa7c74a0ea0,
input=..., params_=..., final_=true)
at /home/zverevgeny/github/my/ydb/ydb/library/arrow_clickhouse/DataStreams/AggregatingBlockInputStream.h:28
#2 0x000000000bb4abfd in CH::ArrowAggregateFunctionWrapper::Execute (this=0x46ddf066b128, args=..., options=)
at /home/zverevgeny/github/my/ydb/ydb/library/arrow_clickhouse/AggregateFunctions/AggregateFunctionWrapper.h:85
#3 0x000000000a97fa9d in arrow::compute::CallFunction (func_name=..., args=..., options=options@entry=0x46ddf06591e8,
ctx=0x7fa7c74a73b8) at /home/zverevgeny/github/my/ydb/contrib/libs/apache/arrow/cpp/src/arrow/compute/exec.cc:1041
#4 0x000000000bbf196e in NKikimr::NSsa::TInternalFunctionNKikimr::NSsa::TAggregateAssign::Call (this=0x46ddf072d408,
assign=..., batch=...) at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.cpp:78
#5 0x000000000bbe90da in NKikimr::NSsa::TProgramStep::ApplyAggregates (this=this@entry=0x46ddf2a14548, batch=...,
ctx=ctx@entry=0x7fa7c74a73b8) at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.cpp:756
#6 0x000000000bbec351 in NKikimr::NSsa::TProgramStep::Apply (this=0x46ddf2a14548, batch=..., ctx=0x7fa7c74a73b8)
at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.cpp:925
#7 0x0000000008924f02 in NKikimr::NSsa::TProgram::ApplyTo (this=, batch=..., ctx=0x7fa7c74a73b8)
at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.h:479
#8 0x0000000010593211 in NKikimr::NSsa::TProgram::ApplyTo (this=this@entry=0x46ddf1909f78, table=..., ctx=0x7fa7c74a73b8)
at /home/zverevgeny/github/my/ydb/ydb/core/formats/arrow/program.h:467
#9 0x000000001058e562 in NKikimr::NOlap::TProgramContainer::ApplyProgramarrow::Table (this=, batch=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/program/program.h:96
#10 0x000000001058da2f in NKikimr::NOlap::NReader::NPlain::TBaseMergeTask::PrepareResultBatch (this=this@entry=0x46ddf199c6e8)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/columnshard/engines/reader/plain_reader/iterator/merge.cpp:41
#11 0x000000001058fb3e in NKikimr::NOlap::NReader::NPlain::TStartMergeTask::DoExecuteImpl (this=0x46ddf199c6e8)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/columnshard/engines/reader/plain_reader/iterator/merge.cpp:106
#12 0x00000000105cc0b1 in NKikimr::NOlap::NReader::IDataTasksProcessor::ITask::DoExecute (this=0x0, taskPtr=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/columnshard/engines/reader/common/conveyor_task.cpp:8
#13 0x00000000105560f0 in NKikimr::NConveyor::ITask::Execute (this=0x46ddf199c6e8, signals=..., taskPtr=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/conveyor/usage/abstract.cpp:13
#14 0x000000001765812e in NKikimr::NConveyor::TWorker::ExecuteTask (this=0x46ddff856e70, workerTask=...)
at /home/zverevgeny/github/my/ydb/ydb/core/tx/conveyor/service/worker.cpp:10
#15 0x00000000099ecade in NActors::TGenericExecutorThread::Execute (this=this@entry=0x46ddff640c00,
mailbox=mailbox@entry=0x46ddfbfe2140, isTailExecution=)
at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:281
#16 0x00000000099f0431 in NActors::TGenericExecutorThread::ProcessExecutorPool(NActors::IExecutorPool*)::$_0::operator()(NActors::TMailbox*, bool) const (this=this@entry=0x7fa7c74a1f30, mailbox=mailbox@entry=0x46ddfbfe2140, isTailExecution=false)
at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:475
#17 0x00000000099eff83 in NActors::TGenericExecutorThread::ProcessExecutorPool (this=this@entry=0x46ddff640c00,
pool=) at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:529
#18 0x00000000099f0b86 in NActors::TExecutorThread::ThreadProc (this=0x46ddff640c00)
at /home/zverevgeny/github/my/ydb/ydb/library/actors/core/executor_thread.cpp:560
#19 0x0000000008f22a08 in (anonymous namespace)::TPosixThread::ThreadProxy (arg=0x46ddfe5e6910)
at /home/zverevgeny/github/my/ydb/util/system/thread.cpp:244
#20 0x00007fa7fe739b5a in start_thread (arg=) at ./nptl/pthread_create.c:444
The text was updated successfully, but these errors were encountered: