diff options
| -rw-r--r-- | ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp index 372efc48dda..749df5783f7 100644 --- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp +++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp @@ -67,6 +67,7 @@ void Load(IInputStream& input, void* buf, size_t size) { char* p = (char*)buf; while (size) { auto len = input.Read(p, size); + YQL_ENSURE(len != 0); p += len; size -= len; } |