Logical error: 'Distributed task iterator is not initialized' #84658
Description
Describe the bug
I found this with AzureBlobStorage, but it may be reproducible with S3 too.
How to reproduce
Replace AzureBlobStorage parameters as needed and run:
CREATE TABLE t0 (c0 Int) ENGINE = AzureBlobStorage('http://127.0.0.1:10000/devstoreaccount1', 'cont', 'f2', 'devstoreaccount1', 'Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==', CSV, 'gzip');
SELECT 1 FROM remote('localhost', azureBlobStorage('http://127.0.0.1:10000/devstoreaccount1', 'cont', 'f2', 'devstoreaccount1', 'Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==', CSV, 'gzip', 'c0 Int')) tx SETTINGS prefer_localhost_replica = 0;Error message and/or stacktrace
Stack trace:
<Fatal> : Logical error: 'Distributed task iterator is not initialized'.
<Fatal> : Stack trace (when copying this message, always include the lines below):
0. contrib/llvm-project/libcxx/include/__exception/exception.h:113: Poco::Exception::Exception(String const&, int) @ 0x000000002659b8f2
1. src/Common/Exception.cpp:115: DB::Exception::Exception(DB::Exception::MessageMasked&&, int, bool) @ 0x0000000014093166
2. src/Common/Exception.h:119: DB::Exception::Exception(PreformattedMessage&&, int) @ 0x000000000cd885ac
3. src/Common/Exception.h:137: DB::Exception::Exception<>(int, FormatStringHelperImpl<>) @ 0x000000000cd92c36
4. src/QueryPipeline/RemoteQueryExecutor.cpp:744: DB::RemoteQueryExecutor::processReadTaskRequest() @ 0x0000000019e72a83
5. src/QueryPipeline/RemoteQueryExecutor.cpp:643: DB::RemoteQueryExecutor::processPacket(DB::Packet) @ 0x0000000019e70475
6. src/QueryPipeline/RemoteQueryExecutor.cpp:582: DB::RemoteQueryExecutor::readAsync() @ 0x0000000019e71f42
7. src/Processors/Sources/RemoteSource.cpp:187: DB::RemoteSource::tryGenerate() @ 0x000000001e9fb51d
8. src/Processors/ISource.cpp:110: DB::ISource::work() @ 0x000000001e635cc2
9. src/Processors/Executors/ExecutionThreadContext.cpp:53: DB::ExecutionThreadContext::executeTask() @ 0x000000001e6529d0
10. src/Processors/Executors/PipelineExecutor.cpp:350: DB::PipelineExecutor::executeStepImpl(unsigned long, DB::IAcquiredSlot*, std::atomic<bool>*) @ 0x000000001e645685
11. src/Processors/Executors/PipelineExecutor.cpp:278: DB::PipelineExecutor::executeSingleThread(unsigned long, DB::IAcquiredSlot*) @ 0x000000001e645be9
12. src/Processors/Executors/PipelineExecutor.cpp:561: void std::__function::__policy_invoker<void ()>::__call_impl[abi:se190107]<std::__function::__default_alloc_func<DB::PipelineExecutor::spawnThreads(std::shared_ptr<DB::IAcquiredSlot>)::$_0, void ()>>(std::__function::__policy_storage const*) @ 0x000000001e646603
13. contrib/llvm-project/libcxx/include/__functional/function.h:716: ? @ 0x00000000141dab13
14. contrib/llvm-project/libcxx/include/__type_traits/invoke.h:117: ThreadFromGlobalPoolImpl<false, true>::ThreadFromGlobalPoolImpl<void (ThreadPoolImpl<ThreadFromGlobalPoolImpl<false, true>>::ThreadFromThreadPool::*)(), ThreadPoolImpl<ThreadFromGlobalPoolImpl<false, true>>::ThreadFromThreadPool*>(void (ThreadPoolImpl<ThreadFromGlobalPoolImpl<false, true>>::ThreadFromThreadPool::*&&)(), ThreadPoolImpl<ThreadFromGlobalPoolImpl<false, true>>::ThreadFromThreadPool*&&)::'lambda'()::operator()() @ 0x00000000141e11e6
15. contrib/llvm-project/libcxx/include/__functional/function.h:716: ? @ 0x00000000141d7fa6
16. contrib/llvm-project/libcxx/include/__type_traits/invoke.h:117: void* std::__thread_proxy[abi:se190107]<std::tuple<std::unique_ptr<std::__thread_struct, std::default_delete<std::__thread_struct>>, void (ThreadPoolImpl<std::thread>::ThreadFromThreadPool::*)(), ThreadPoolImpl<std::thread>::ThreadFromThreadPool*>>(void*) @ 0x00000000141de9c0
17. start_thread @ 0x00000000000a27f1
18. __GI___clone3 @ 0x0000000000133c9c