Skip to content

bugfix: handle Python source cancel during MV failover#1142

Merged
yokofly merged 1 commit intodevelopfrom
py-table-func-cancelled
Mar 25, 2026
Merged

bugfix: handle Python source cancel during MV failover#1142
yokofly merged 1 commit intodevelopfrom
py-table-func-cancelled

Conversation

@yokofly
Copy link
Copy Markdown
Collaborator

@yokofly yokofly commented Mar 25, 2026

Code: 394. DB::Exception: Query was cancelled. (QUERY_WAS_CANCELLED), Stack trace (when copying this message, always include the lines below):

0. DB::Exception::Exception(DB::Exception::MessageMasked&&, int, bool) @ 0x000000000e1563f7 in /usr/bin/timeplusd
1. DB::Exception::Exception<char const (&) [20], void>(int, char const (&) [20]) @ 0x00000000094bbd21 in /usr/bin/timeplusd
2. DB::cpython::iterNext(DB::cpython::PyObjectPtr const&) @ 0x000000001cb73986 in /usr/bin/timeplusd
3. DB::PythonStreamingSource::generate() @ 0x000000001b0d2ba4 in /usr/bin/timeplusd
4. DB::ISource::tryGenerate() @ 0x0000000014afa3ba in /usr/bin/timeplusd
5. DB::ISource::work() @ 0x0000000014af9f76 in /usr/bin/timeplusd
6. DB::ExecutionThreadContext::executeTask() @ 0x0000000014bc8fb7 in /usr/bin/timeplusd
7. DB::PipelineExecutor::executeStepImpl(unsigned long, std::atomic<bool>*) @ 0x0000000014bbe723 in /usr/bin/timeplusd
8. DB::PipelineExecutor::executeImpl(unsigned long, DB::ExecuteMode) @ 0x0000000014bbd426 in /usr/bin/timeplusd
9. DB::PipelineExecutor::execute(unsigned long, DB::ExecuteMode) @ 0x0000000014bbcc78 in /usr/bin/timeplusd
10. void std::__function::__policy_invoker<void ()>::__call_impl[abi:ne180100]<std::__function::__default_alloc_func<ThreadFromGlobalPoolImpl<true>::ThreadFromGlobalPoolImpl<DB::CompletedPipelineExecutor::execute()::$_0>(DB::CompletedPipelineExecutor::execute()::$_0&&)::'lambda'(), void ()>>(std::__function::__policy_storage const*) @ 0x0000000014bbbad0 in /usr/bin/timeplusd
11. ThreadPoolImpl<std::thread>::worker(std::__list_iterator<std::thread, void*>) @ 0x000000000e30307a in /usr/bin/timeplusd
12. void* std::__thread_proxy[abi:ne180100]<std::tuple<std::unique_ptr<std::__thread_struct, std::default_delete<std::__thread_struct>>, void ThreadPoolImpl<std::thread>::scheduleImpl<void>(std::function<void ()>, Priority, std::optional<unsigned long>, bool)::'lambda0'()>>(void*) @ 0x000000000e3084e1 in /usr/bin/timeplusd
13. ? @ 0x0000000000094ac3 in /usr/lib/x86_64-linux-gnu/libc.so.6
14. ? @ 0x00000000001268d0 in /usr/lib/x86_64-linux-gnu/libc.so.6
 

Co-authored-by: chatgpt-codex-connector[bot] <199175422+chatgpt-codex-connector[bot]@users.noreply.github.com>
@yokofly yokofly merged commit 8c72826 into develop Mar 25, 2026
7 of 11 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant