thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-24 00:22:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #57979 from ClickHouse/add-test-49708

Browse Source 
Add a test for #49708
This commit is contained in:
Alexey Milovidov 2023-12-18 21:29:11 +01:00 committed by GitHub
commit 1a7de9158f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Storages/StorageFile.cpp
View File

@ -10,7 +10,6 @@
#include <Interpreters/Context.h> #include <Interpreters/Context.h>
#include <Interpreters/evaluateConstantExpression.h> #include <Interpreters/evaluateConstantExpression.h>
#include <Parsers/ASTCreateQuery.h>
#include <Parsers/ASTSelectQuery.h> #include <Parsers/ASTSelectQuery.h>
#include <Parsers/ASTIdentifier_fwd.h> #include <Parsers/ASTIdentifier_fwd.h>
#include <Parsers/ASTInsertQuery.h> #include <Parsers/ASTInsertQuery.h>
@ -26,8 +25,6 @@
#include <IO/Archives/createArchiveReader.h> #include <IO/Archives/createArchiveReader.h>
#include <IO/Archives/IArchiveReader.h> #include <IO/Archives/IArchiveReader.h>
#include <DataTypes/DataTypeLowCardinality.h>
#include <DataTypes/DataTypeString.h>
#include <Formats/FormatFactory.h> #include <Formats/FormatFactory.h>
#include <Formats/ReadSchemaUtils.h> #include <Formats/ReadSchemaUtils.h>
#include <Processors/Formats/IInputFormat.h> #include <Processors/Formats/IInputFormat.h>
@ -39,7 +36,6 @@
#include <Processors/Formats/ISchemaReader.h> #include <Processors/Formats/ISchemaReader.h>
#include <Processors/Sources/NullSource.h> #include <Processors/Sources/NullSource.h>
#include <Processors/Sources/ConstChunkGenerator.h> #include <Processors/Sources/ConstChunkGenerator.h>
#include <Processors/ResizeProcessor.h>
#include <Processors/Executors/PullingPipelineExecutor.h> #include <Processors/Executors/PullingPipelineExecutor.h>
#include <Common/escapeForFileName.h> #include <Common/escapeForFileName.h>
@ -56,7 +52,6 @@
#include <unistd.h> #include <unistd.h>
#include <filesystem> #include <filesystem>
#include <shared_mutex> #include <shared_mutex>
#include <cmath>
#include <algorithm> #include <algorithm>
#ifdef __clang__ #ifdef __clang__

3
src/TableFunctions/TableFunctionFile.cpp
View File

@ -2,17 +2,14 @@
#include <TableFunctions/ITableFunctionFileLike.h> #include <TableFunctions/ITableFunctionFileLike.h>
#include <TableFunctions/TableFunctionFile.h> #include <TableFunctions/TableFunctionFile.h>
#include "Parsers/IAST_fwd.h"
#include "registerTableFunctions.h" #include "registerTableFunctions.h"
#include <Access/Common/AccessFlags.h> #include <Access/Common/AccessFlags.h>
#include <Interpreters/Context.h> #include <Interpreters/Context.h>
#include <Storages/ColumnsDescription.h> #include <Storages/ColumnsDescription.h>
#include <Storages/StorageFile.h> #include <Storages/StorageFile.h>
#include <Storages/VirtualColumnUtils.h>
#include <TableFunctions/TableFunctionFactory.h> #include <TableFunctions/TableFunctionFactory.h>
#include <Interpreters/evaluateConstantExpression.h> #include <Interpreters/evaluateConstantExpression.h>
#include <Formats/FormatFactory.h> #include <Formats/FormatFactory.h>
#include <Parsers/ASTIdentifier_fwd.h>
namespace DB namespace DB

1
tests/queries/0_stateless/02946_parallel_replicas_distributed.reference Normal file
View File

@ -0,0 +1 @@
100 4950

17
tests/queries/0_stateless/02946_parallel_replicas_distributed.sql Normal file
View File

@ -0,0 +1,17 @@
DROP TABLE IF EXISTS test;
DROP TABLE IF EXISTS test_d;
CREATE TABLE test (id UInt64, date Date)
ENGINE = MergeTree
ORDER BY id
AS select *, '2023-12-25' from numbers(100);
CREATE TABLE IF NOT EXISTS test_d as test
ENGINE = Distributed(test_cluster_one_shard_three_replicas_localhost, currentDatabase(), test);
SELECT count(), sum(id)
FROM test_d
SETTINGS allow_experimental_parallel_reading_from_replicas = 1, max_parallel_replicas = 3, prefer_localhost_replica = 0;
DROP TABLE test_d;
DROP TABLE test;