From 2c4a49444063a21aa2df9669d5a38149e9536566 Mon Sep 17 00:00:00 2001 From: alexey-milovidov Date: Mon, 3 Aug 2020 21:50:02 +0300 Subject: [PATCH] Update DelayedSource.cpp --- src/Processors/Sources/DelayedSource.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Processors/Sources/DelayedSource.cpp b/src/Processors/Sources/DelayedSource.cpp index 64848e2312d..f9e112f5e68 100644 --- a/src/Processors/Sources/DelayedSource.cpp +++ b/src/Processors/Sources/DelayedSource.cpp @@ -83,7 +83,7 @@ IProcessor::Status DelayedSource::prepare() return Status::Finished; } -/// Fix port from returned pipe. Create source_port is created or drop if source_port is null. +/// Fix port from returned pipe. Create source_port if created or drop if source_port is null. void synchronizePorts(OutputPort *& pipe_port, OutputPort * source_port, const Block & header, Processors & processors) { if (source_port)