Is the TiFlash error a bug?

Note:
This topic has been translated from a Chinese forum by GPT and might contain errors.

Original topic: tiflash报错,是不是bug

| username: wenyi

[2023/04/27 11:24:06.657 +08:00] [ERROR] [MPPTask.cpp:429] ["task running meets error: Code: 0, e.displayText() = DB::Exception: write to tunnel which is already closed, Receiver cancelled, reason: Push mpp packet failed. Receiver state: CLOSED, e.what() = DB::Exception, Stack trace:

0x17221ce DB::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator > const&, int) [tiflash+24256974]
dbms/src/Common/Exception.h:46
0x6e23f34 DB::MPPTunnel::write(std::__1::shared_ptrDB::TrackedMppDataPacket&&) [tiflash+115490612]
dbms/src/Flash/Mpp/MPPTunnel.cpp:168
0x16f5d6c DB::HashPartitionWriter<std::__1::shared_ptrDB::MPPTunnelSet >::partitionAndEncodeThenWriteBlocks() [tiflash+24075628]
dbms/src/Flash/Mpp/HashPartitionWriter.cpp:103
0x6dc7042 DB::ExchangeSenderBlockInputStream::readImpl() [tiflash+115109954]
dbms/src/DataStreams/ExchangeSenderBlockInputStream.cpp:43
0x61609a5 DB::IProfilingBlockInputStream::read(DB::PODArray<unsigned char, 4096ul, Allocator, 15ul, 16ul>&, bool) [tiflash+102107557]
dbms/src/DataStreams/IProfilingBlockInputStream.cpp:75
0x6160695 DB::IProfilingBlockInputStream::read() [tiflash+102106773]
dbms/src/DataStreams/IProfilingBlockInputStream.cpp:43
0x6dcd95e DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::work(unsigned long, DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::WorkingInputs&) [tiflash+115136862]
dbms/src/DataStreams/ParallelInputsProcessor.h:270
0x6dcd476 std::__1::__function::__func<DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::process()::‘lambda’(), std::__1::allocator<DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::process()::‘lambda’()>, void ()>::operator()() [tiflash+115135606]
/usr/local/bin/…/include/c++/v1/__functional/function.h:345
0x1804c9b DB::ExecutableTask<std::__1::packaged_task<void ()> >::execute() [tiflash+25185435]
dbms/src/Common/ExecutableTask.h:52
0x18081e3 DB::DynamicThreadPool::executeTask(std::__1::unique_ptr<DB::IExecutableTask, std::__1::default_deleteDB::IExecutableTask >&) [tiflash+25199075]
dbms/src/Common/DynamicThreadPool.cpp:101
0x1807840 DB::DynamicThreadPool::fixedWork(unsigned long) [tiflash+25196608]
dbms/src/Common/DynamicThreadPool.cpp:115
0x1808932 void
std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_deletestd::__1::__thread_struct >, std::__1::thread DB::ThreadFactory::newThread<void (DB::DynamicThreadPool::)(unsigned long), DB::DynamicThreadPool, unsigned long&>(bool, std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator >, void (DB::DynamicThreadPool::&&)(unsigned long), DB::DynamicThreadPool&&, unsigned long&)::‘lambda’(auto&&…), DB::DynamicThreadPool*, unsigned long> >(void*) [tiflash+25200946]
/usr/local/bin/…/include/c++/v1/thread:291
0x7f3537ce8ea5 start_thread [libpthread.so.0+32421]
0x7f35370ed96d __clone [libc.so.6+1042797]"] [source=MPPquery:441074540374392854:6,task] [thread_id=252]

| username: wenyi | Original post link

[2023/04/27 11:30:10.316 +08:00] [ERROR] [MPPTask.cpp:429] [“task running meets error: Code: 0, e.displayText() = DB::Exception: write to tunnel which is already closed, Receiver cancelled, reason: Push mpp packet failed. Receiver state: CLOSED, e.what() = DB::Exception, Stack trace:\n\n\n 0x17221ce\tDB::Exception::Exception(std::__1:: basic_string<char, std::__1::char_traits, std::__1::allocator > const&, int) [tiflash+24256974]\n \tdbms/src/Common/Exception.h:46\n 0x6e23f34\tDB::MPPTunnel::write(std::__1::shared_ptrDB::TrackedMppDataPacket&&) [tiflash+115490612]\n \tdbms/src/Flash/Mpp/MPPTunnel.cpp:168\n 0x16f5d6c\tDB::HashPartitionWriter<std::__1::shared_ptrDB::MPPTunnelSet >::partitionAndEncodeThenWriteBlocks() [tiflash+24075628]\n \tdbms/src/Flash/Mpp/HashPartitionWriter.cpp:103\n 0x6dc7042\tDB::ExchangeSenderBlockInputStream::readImpl() [tiflash+115109954]\n \tdbms/src/DataStreams/ExchangeSenderBlockInputStream.cpp:43\n 0x61609a5\tDB::IProfilingBlockInputStream::read(DB::PODArray<unsigned char, 4096ul, Allocator, 15ul, 16ul>&, bool) [tiflash+102107557]\n \tdbms/src/DataStreams/IProfilingBlockInputStream.cpp:75\n 0x6160695\tDB::IProfilingBlockInputStream::read() [tiflash+102106773]\n \tdbms/src/DataStreams/IProfilingBlockInputStream.cpp:43\n 0x6dcd95e\tDB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::work(unsigned long, DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::WorkingInputs&) [tiflash+115136862]\n \tdbms/src/DataStreams/ParallelInputsProcessor.h:270\n 0x6dcd476\tstd::__1::__function::__func<DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::process()::‘lambda’(), std::__1::allocator<DB::ParallelInputsProcessor<DB::UnionBlockInputStream<(DB::StreamUnionMode)0, true>::Handler, (DB::StreamUnionMode)0>::process()::‘lambda’()>, void ()>::operator()() [tiflash+115135606]\n \t/usr/local/bin/…/include/c++/v1/__functional/function.h:345\n 0x1804c9b\tDB::ExecutableTask<std::__1::packaged_task<void ()> >::execute() [tiflash+25185435]\n \tdbms/src/Common/ExecutableTask.h:52\n 0x18081e3\tDB::DynamicThreadPool::executeTask(std::__1::unique_ptr<DB::IExecutableTask, std::__1::default_deleteDB::IExecutableTask >&) [tiflash+25199075]\n \tdbms/src/Common/DynamicThreadPool.cpp:101\n 0x1807840\tDB::DynamicThreadPool::fixedWork(unsigned long) [tiflash+25196608]\n \tdbms/src/Common/DynamicThreadPool.cpp:115\n 0x1808932\tvoid std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_deletestd::__1::__thread_struct >, std::__1::thread DB::ThreadFactory::newThread<void (DB::DynamicThreadPool::)(unsigned long), DB::DynamicThreadPool, unsigned long&>(bool, std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator >, void (DB::DynamicThreadPool::&&)(unsigned long), DB::DynamicThreadPool&&, unsigned long&)::‘lambda’(auto&&…), DB::DynamicThreadPool*, unsigned long> >(void*) [tiflash+25200946]\n \t/usr/local/bin/…/include/c++/v1/thread:291\n 0x7f3537ce8ea5\tstart_thread [libpthread.so.0+32421]\n 0x7f35370ed96d\t__clone [libc.so.6+1042797]”] [source=MPPquery:441074635008376845:4,task] [thread_id=258]
[2023/04/27 11:30:10.316 +08:00] [WARN] [MPPTaskManager.cpp:152] [“Begin to abort query: 441074635008376845, abort type: ONERROR, reason: From MPPquery:441074635008376845:4,task: Code: 0, e.displayText() = DB::Exception: write to tunnel which is already closed,Receiver cancelled, reason: Push mpp packet failed. Receiver state: CLOSED, e.what() = DB::Exception,”] [thread_id=258]
[2023/04/27 11:30:10.316 +08:00] [WARN] [MPPTaskManager.cpp:195] ["Remaining task in query 441074635008376845 are: MPPquery:441074635008376845:1,task MPPquery:441074635008376845:11,task MPPquery:441074635008376845:12,task MPPquery:441074635008376845:13,task MPPquery:441074635008376845:4,task MPPquery:441074635008376845:10,task "] [thread_id=258]
[2023/04/27 11:30:10.316 +08:00] [WARN] [MPPTask.cpp:471] [“Begin abort task: MPPquery:441074635008376845:1,task, abort type: ONERROR”] [source=MPPquery:441074635008376845:1,task] [thread_id=258]
[2023/04/27 11:30:10.316 +08:00] [WARN] [MPPTask.cpp:500] [“Finish abort task from running”] [source=MPPquery:441074635008376845:1,task] [thread_id=258]
[2023/04/27 11:30:10.316 +08:00] [WARN] [MPPTask.cpp:471] [“Begin abort task: MPPquery:441074635008376845:11,task, abort type: ONERROR”] [source=MPPquery:441074635008376845:11,task] [thread_id=258]
[2023/04/27 11:30:10.317 +08:00] [WARN] [MPPTask.cpp:500] [“Finish abort task from running”] [source=MPPquery:441074635008376845:11,task] [thread_id=258]
[2023/04/27 11:30:10.317 +08:00] [WARN] [MPPTask.cpp:471] [“Begin abort task: MPPquery:441074635008376845:12,task, abort type: ONERROR”] [source=MPPquery:441074635008376845:12,task] [thread_id=258]
[2023/04/27 11:30:10.317 +08:00] [WARN] [MPPTask.cpp:500] [“Finish abort task from running”] [source=MPPquery:441074635008376845:12,task] [thread_id=258]
[2023/04/27 11:30:10.317 +08:00] [WARN] [MPPTask.cpp:471] [“Begin abort task: MPPquery:441074635008376845:13,task, abort type: ONERROR”] [source=MPPquery:441074635008376845:13,task] [thread_id=258]
[2023/04/27 11:30:10.318 +08:00] [WARN] [MPPTask.cpp:500] [“Finish abort task from running”] [source=MPPquery:441074635008376845:13,task] [thread_id=258]
[2023/04/27 11:30:10.318 +08:00] [WARN] [MPPTask.cpp:471] [“Begin abort task: MPPquery:441074635008376845:4,task, abort type: ONERROR”] [source=MPPquery:441074635008376845:4,task] [thread_id=258]
[2023/04/27 11:30:10.322 +08:00] [WARN] [MPPTask.cpp:500] [“Finish abort task from running”] [source=MPPquery:441074635008376845:4,task] [thread_id=258]
[2023/04/27 11:30:10.322 +08:00] [WARN] [MPPTask.cpp:471] [“Begin abort task: MPPquery:441074635008376845:10,task, abort type: ONERROR”] [source=MPPquery:441074635008376845:10,task] [thread_id=258]
[2023/04/27 11:30:10.322 +08:00] [WARN] [MPPTask.cpp:500] [“Finish abort task from running”] [source=MPPquery:441074635008376845:10,task] [thread_id=258]
[2023/04/27 11:30:10.322 +08:00] [WARN] [MPPTaskManager.cpp:207] [“Finish abort query: 441074635008376845”] [thread_id=258]
[2023/04/27 11:30:10.323 +08:00] [WARN] [MPPTask.cpp:413] [“finish task which is in FAILED state”] [source=MPPquery:441074635008376845:10,task] [thread_id=552]
[2023/04/27 11:30:10.324 +08:00] [WARN] [MPPTaskManager.cpp:152] [“Begin to abort query: 441074635008376845, abort type: ONCANCELLATION, reason: Receive cancel request from TiDB”] [thread_id=745]
[2023/04/27 11:30:10.324 +08:00] [WARN] [MPPTaskManager.cpp:167] [“441074635008376845 already in abort process, skip abort”] [thread_id=745]

| username: wenyi | Original post link

TiFlash columnar database has many more issues compared to StarRocks pure columnar database.

| username: tidb狂热爱好者 | Original post link

I remember that the first query for your issue was successful, but continuous queries will result in an error. Wait a while and try again.