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

Merge pull request #4229 from nvartolomei/nv/typos

Browse Source 
Make START REPLICATED SENDS command start replicated sends
This commit is contained in:
alexey-milovidov 2019-02-02 14:44:51 +03:00 committed by GitHub
commit 297c2511c7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dbms/src/Interpreters/InterpreterSystemQuery.cpp
View File

@ -185,8 +185,8 @@ BlockIO InterpreterSystemQuery::execute()
case Type::STOP_REPLICATED_SENDS: case Type::STOP_REPLICATED_SENDS:
startStopAction(context, query, ActionLocks::PartsSend, false); startStopAction(context, query, ActionLocks::PartsSend, false);
break; break;
case Type::START_REPLICATEDS_SENDS: case Type::START_REPLICATED_SENDS:
startStopAction(context, query, ActionLocks::PartsSend, false); startStopAction(context, query, ActionLocks::PartsSend, true);
break; break;
case Type::STOP_REPLICATION_QUEUES: case Type::STOP_REPLICATION_QUEUES:
startStopAction(context, query, ActionLocks::ReplicationQueue, false); startStopAction(context, query, ActionLocks::ReplicationQueue, false);

4
dbms/src/Parsers/ASTSystemQuery.cpp
View File

@ -59,7 +59,7 @@ const char * ASTSystemQuery::typeToString(Type type)
return "START FETCHES"; return "START FETCHES";
case Type::STOP_REPLICATED_SENDS: case Type::STOP_REPLICATED_SENDS:
return "STOP REPLICATED SENDS"; return "STOP REPLICATED SENDS";
case Type::START_REPLICATEDS_SENDS: case Type::START_REPLICATED_SENDS:
return "START REPLICATED SENDS"; return "START REPLICATED SENDS";
case Type::STOP_REPLICATION_QUEUES: case Type::STOP_REPLICATION_QUEUES:
return "STOP REPLICATION QUEUES"; return "STOP REPLICATION QUEUES";
@ -97,7 +97,7 @@ void ASTSystemQuery::formatImpl(const FormatSettings & settings, FormatState &,
|| type == Type::STOP_FETCHES || type == Type::STOP_FETCHES
|| type == Type::START_FETCHES || type == Type::START_FETCHES
|| type == Type::STOP_REPLICATED_SENDS || type == Type::STOP_REPLICATED_SENDS
|| type == Type::START_REPLICATEDS_SENDS || type == Type::START_REPLICATED_SENDS
|| type == Type::STOP_REPLICATION_QUEUES || type == Type::STOP_REPLICATION_QUEUES
|| type == Type::START_REPLICATION_QUEUES) || type == Type::START_REPLICATION_QUEUES)
{ {

2
dbms/src/Parsers/ASTSystemQuery.h
View File

@ -36,7 +36,7 @@ public:
STOP_FETCHES, STOP_FETCHES,
START_FETCHES, START_FETCHES,
STOP_REPLICATED_SENDS, STOP_REPLICATED_SENDS,
START_REPLICATEDS_SENDS, START_REPLICATED_SENDS,
STOP_REPLICATION_QUEUES, STOP_REPLICATION_QUEUES,
START_REPLICATION_QUEUES, START_REPLICATION_QUEUES,
FLUSH_LOGS, FLUSH_LOGS,

2
dbms/src/Parsers/ParserSystemQuery.cpp
View File

@ -58,7 +58,7 @@ bool ParserSystemQuery::parseImpl(IParser::Pos & pos, ASTPtr & node, Expected &
case Type::STOP_FETCHES: case Type::STOP_FETCHES:
case Type::START_FETCHES: case Type::START_FETCHES:
case Type::STOP_REPLICATED_SENDS: case Type::STOP_REPLICATED_SENDS:
case Type::START_REPLICATEDS_SENDS: case Type::START_REPLICATED_SENDS:
case Type::STOP_REPLICATION_QUEUES: case Type::STOP_REPLICATION_QUEUES:
case Type::START_REPLICATION_QUEUES: case Type::START_REPLICATION_QUEUES:
parseDatabaseAndTableName(pos, expected, res->target_database, res->target_table); parseDatabaseAndTableName(pos, expected, res->target_database, res->target_table);