thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 10:40:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try fix Pipeline stuck

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-12-27 14:16:40 +03:00
parent 30bbba6ed5
commit 7064a8500b
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Processors/DelayedPortsProcessor.cpp
View File

@ -4,9 +4,9 @@ namespace DB
{
DelayedPortsProcessor::DelayedPortsProcessor(
const Block & header, size_t num_ports, const PortNumbers & delayed_ports, bool assert_delayed_ports_empty)
const Block & header, size_t num_ports, const PortNumbers & delayed_ports, bool assert_main_ports_empty)
: IProcessor(InputPorts(num_ports, header),
OutputPorts(num_ports - (assert_delayed_ports_empty ? delayed_ports.size() : 0), header))
OutputPorts((assert_main_ports_empty ? delayed_ports.size() : num_ports), header))
, num_delayed(delayed_ports.size())
{
port_pairs.resize(num_ports);
@ -22,7 +22,7 @@ DelayedPortsProcessor::DelayedPortsProcessor(
port_pairs[i].input_port = &*input_it;
++input_it;
if (!port_pairs[i].is_delayed || !assert_delayed_ports_empty)
if (port_pairs[i].is_delayed || !assert_main_ports_empty)
{
port_pairs[i].output_port = &*output_it;
output_to_pair.push_back(i);

2
src/Processors/DelayedPortsProcessor.h
View File

@ -11,7 +11,7 @@ namespace DB
class DelayedPortsProcessor : public IProcessor
{
public:
DelayedPortsProcessor(const Block & header, size_t num_ports, const PortNumbers & delayed_ports, bool assert_delayed_ports_empty = false);
DelayedPortsProcessor(const Block & header, size_t num_ports, const PortNumbers & delayed_ports, bool assert_main_ports_empty = false);
String getName() const override { return "DelayedPorts"; }