diff --git a/src/Processors/Sources/ShellCommandSource.cpp b/src/Processors/Sources/ShellCommandSource.cpp index 55a7afe0538..effe2950104 100644 --- a/src/Processors/Sources/ShellCommandSource.cpp +++ b/src/Processors/Sources/ShellCommandSource.cpp @@ -73,7 +73,7 @@ static int pollWithTimeout(pollfd * pfds, size_t num, size_t timeout_millisecond while (true) { Stopwatch watch; - res = poll(pfds, num, static_cast(timeout_milliseconds)); + res = poll(pfds, static_cast(num), static_cast(timeout_milliseconds)); if (res < 0) { @@ -139,7 +139,7 @@ public: { pfds[0].revents = 0; pfds[1].revents = 0; - size_t num_events = pollWithTimeout(pfds, num_pfds, static_cast(timeout_milliseconds)); + size_t num_events = pollWithTimeout(pfds, num_pfds, timeout_milliseconds); if (0 == num_events) throw Exception(ErrorCodes::TIMEOUT_EXCEEDED, "Pipe read timeout exceeded {} milliseconds", timeout_milliseconds);