Skip to content

Commit 55e7b94

Browse files
committed
fix conflicts
1 parent bb04fd9 commit 55e7b94

File tree

4 files changed

+7
-6
lines changed

4 files changed

+7
-6
lines changed

src/Interpreters/InterpreterKillQueryQuery.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ BlockIO InterpreterKillQueryQuery::execute()
255255
Block exports_block = getSelectResult(
256256
"source_database, source_table, transaction_id, destination_database, destination_table, partition_id",
257257
"system.replicated_partition_exports");
258-
if (!exports_block)
258+
if (exports_block.empty())
259259
return res_io;
260260

261261
const ColumnString & src_db_col = typeid_cast<const ColumnString &>(*exports_block.getByName("source_database").column);
@@ -317,7 +317,7 @@ BlockIO InterpreterKillQueryQuery::execute()
317317
throw Exception(ErrorCodes::ACCESS_DENIED, "Not allowed to kill export partition. "
318318
"To execute this query, it's necessary to have the grant {}", required_access_rights.toString());
319319

320-
res_io.pipeline = QueryPipeline(Pipe(std::make_shared<SourceFromSingleChunk>(header.cloneWithColumns(std::move(res_columns)))));
320+
res_io.pipeline = QueryPipeline(Pipe(std::make_shared<SourceFromSingleChunk>(std::make_shared<const Block>(header.cloneWithColumns(std::move(res_columns))))));
321321

322322
break;
323323
}

src/Parsers/ASTAlterQuery.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -380,14 +380,14 @@ void ASTAlterCommand::formatImpl(WriteBuffer & ostr, const FormatSettings & sett
380380
}
381381
else if (type == ASTAlterCommand::EXPORT_PARTITION)
382382
{
383-
ostr << (settings.hilite ? hilite_keyword : "") << "EXPORT PARTITION " << (settings.hilite ? hilite_none : "");
383+
ostr << "EXPORT PARTITION ";
384384
partition->format(ostr, settings, state, frame);
385385
ostr << " TO TABLE ";
386386
if (!to_database.empty())
387387
{
388-
ostr << (settings.hilite ? hilite_identifier : "") << backQuoteIfNeed(to_database) << (settings.hilite ? hilite_none : "") << ".";
388+
ostr << backQuoteIfNeed(to_database) << ".";
389389
}
390-
ostr << (settings.hilite ? hilite_identifier : "") << backQuoteIfNeed(to_table) << (settings.hilite ? hilite_none : "");
390+
ostr << backQuoteIfNeed(to_table);
391391
}
392392
else if (type == ASTAlterCommand::REPLACE_PARTITION)
393393
{

src/Storages/StorageReplicatedMergeTree.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8701,7 +8701,7 @@ void StorageReplicatedMergeTree::exportPartitionToTable(const PartitionCommand &
87018701
}
87028702

87038703
/// The check for existence and entry removal are not atomic, so this actually might fail.
8704-
ops.emplace_back(zkutil::makeRemoveRecursiveRequest(partition_exports_path, -1));
8704+
ops.emplace_back(zkutil::makeRemoveRecursiveRequest(*zookeeper, partition_exports_path, -1));
87058705
}
87068706

87078707
ops.emplace_back(zkutil::makeCreateRequest(partition_exports_path, "", zkutil::CreateMode::Persistent));

tests/queries/0_stateless/03604_export_merge_tree_partition.reference

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ Select from destination table
1111
2 2020
1212
3 2020
1313
4 2021
14+
5 2021
1415
Export partition 2022
1516
Select from destination table again
1617
1 2020

0 commit comments

Comments
 (0)