thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

impl

Browse Source
This commit is contained in:
Nikita Taranov 2024-07-26 21:49:41 +01:00
parent 6e3dccf365
commit 0d8a3f13e3
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/Processors/Sources/ShellCommandSource.cpp
View File

@ -8,13 +8,15 @@
#include <IO/WriteHelpers.h>
#include <IO/ReadHelpers.h>
#include <QueryPipeline/Pipe.h>
#include <Processors/ISimpleTransform.h>
#include <Processors/Formats/IOutputFormat.h>
#include <Processors/Executors/CompletedPipelineExecutor.h>
#include <Interpreters/Context.h>
#include <Processors/Executors/CompletedPipelineExecutor.h>
#include <Processors/Formats/IOutputFormat.h>
#include <Processors/ISimpleTransform.h>
#include <QueryPipeline/Pipe.h>
#include <boost/circular_buffer.hpp>
#include <ranges>
namespace DB
{
@ -137,9 +139,15 @@ public:
while (!bytes_read)
{
LOG_TRACE(
getLogger("TimeoutReadBufferFromFileDescriptor"),
"Starting polling on descriptors ({}) with timeout {} ms",
fmt::join(std::span(pfds, pfds + num_pfds) | std::views::transform([](const auto & pollfd) { return pollfd.fd; }), ", "),
timeout_milliseconds);
pfds[0].revents = 0;
pfds[1].revents = 0;
size_t num_events = pollWithTimeout(pfds, num_pfds, timeout_milliseconds);
LOG_TRACE(getLogger("TimeoutReadBufferFromFileDescriptor"), "Poll returned with num_events={}", num_events);
if (0 == num_events)
throw Exception(ErrorCodes::TIMEOUT_EXCEEDED, "Pipe read timeout exceeded {} milliseconds", timeout_milliseconds);

1
tests/integration/test_executable_dictionary/test.py
View File

@ -245,6 +245,7 @@ def test_executable_input_slow_python(started_cluster):
)
@pytest.mark.repeat(50)
def test_executable_implicit_input_slow_python(started_cluster):
skip_test_msan(node)
assert node.query_and_get_error(