ClickHouse/src/QueryPipeline
Azat Khuzhin a871036361
Fix parallel_reading_from_replicas with clickhouse-bechmark (#34751)
* Use INITIAL_QUERY for clickhouse-benchmark

Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com>

* Fix parallel_reading_from_replicas with clickhouse-bechmark

Before it produces the following error:

    $ clickhouse-benchmark --stacktrace -i1 --query "select * from remote('127.1', default.data_mt) limit 10" --allow_experimental_parallel_reading_from_replicas=1 --max_parallel_replicas=3
    Loaded 1 queries.
    Logical error: 'Coordinator for parallel reading from replicas is not initialized'.
    Aborted (core dumped)

Since it uses the same code, i.e RemoteQueryExecutor ->
MultiplexedConnections, which enables coordinator if it was requested
from settings, but it should be done only for non-initial queries, i.e.
when server send connection to another server.

Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com>

* Fix 02226_parallel_reading_from_replicas_benchmark for older shellcheck

By shellcheck 0.8 does not complains, while on CI shellcheck 0.7.0 and
it does complains [1]:

    In 02226_parallel_reading_from_replicas_benchmark.sh line 17:
        --allow_experimental_parallel_reading_from_replicas=1
        ^-- SC2191: The = here is literal. To assign by index, use ( [index]=value ) with no spaces. To keep as literal, quote it.

    Did you mean:
        "--allow_experimental_parallel_reading_from_replicas=1"

  [1]: https://s3.amazonaws.com/clickhouse-test-reports/34751/d883af711822faf294c876b017cbf745b1cda1b3/style_check__actions_/shellcheck_output.txt

Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com>
2022-03-08 16:42:29 +01:00
..
examples
tests Updated additional cases 2021-12-20 15:55:07 +03:00
BlockIO.cpp Fix vulnerable code related to std::move and noexcept 2022-03-02 18:15:27 +00:00
BlockIO.h Fix vulnerable code related to std::move and noexcept 2022-03-02 18:15:27 +00:00
Chain.cpp
Chain.h InterpreterInsertQuery::buildChain: Make sure to keep the context alive 2021-12-13 11:50:46 +01:00
CMakeLists.txt
ConnectionCollector.cpp Add ability to drain connections synchronously 2021-12-14 10:18:57 +03:00
ConnectionCollector.h Add ability to drain connections synchronously 2021-12-14 10:18:57 +03:00
ExecutionSpeedLimits.cpp
ExecutionSpeedLimits.h
narrowBlockInputStreams.cpp
narrowBlockInputStreams.h
Pipe.cpp Revert "Grouping sets dev" 2021-12-25 20:30:31 +03:00
Pipe.h Revert "Grouping sets dev" 2021-12-25 20:30:31 +03:00
PipelineResourcesHolder.cpp clang-tidy check performance-noexcept-move-constructor fix 2022-03-02 18:15:27 +00:00
PipelineResourcesHolder.h clang-tidy check performance-noexcept-move-constructor fix 2022-03-02 18:15:27 +00:00
printPipeline.cpp
printPipeline.h
ProfileInfo.cpp
ProfileInfo.h Update obsolete comments. 2021-10-19 12:58:10 +03:00
QueryPipeline.cpp clang-tidy check performance-noexcept-move-constructor fix 2022-03-02 18:15:27 +00:00
QueryPipeline.h clang-tidy check performance-noexcept-move-constructor fix 2022-03-02 18:15:27 +00:00
QueryPipelineBuilder.cpp Remove unused code 2021-12-14 22:44:54 +03:00
QueryPipelineBuilder.h Remove unused code 2021-12-14 22:44:54 +03:00
RemoteInserter.cpp Improve the opentelemetry span logs for INSERT on distributed table (#34480) 2022-03-03 12:53:29 +01:00
RemoteInserter.h fix inserts to distributed tables in case of change of native protocol 2022-01-29 03:23:25 +03:00
RemoteQueryExecutor.cpp Fix parallel_reading_from_replicas with clickhouse-bechmark (#34751) 2022-03-08 16:42:29 +01:00
RemoteQueryExecutor.h Fix parallel_reading_from_replicas with clickhouse-bechmark (#34751) 2022-03-08 16:42:29 +01:00
RemoteQueryExecutorReadContext.cpp clang-tidy check performance-noexcept-move-constructor fix 2022-03-02 18:15:27 +00:00
RemoteQueryExecutorReadContext.h
SizeLimits.cpp
SizeLimits.h
StreamLocalLimits.h