thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-15 10:52:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix TTL info serialization

Browse Source
This commit is contained in:
Anton Popov 2021-01-12 17:04:03 +03:00
parent 61d6a323dd
commit 58b9ef5a10
1 changed files with 19 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/Storages/MergeTree/MergeTreeDataPartTTLInfo.cpp
View File

@ -143,8 +143,8 @@ void MergeTreeDataPartTTLInfos::write(WriteBuffer & out) const
if (!is_first) if (!is_first)
writeString(",", out); writeString(",", out);
writeString(type, out); writeDoubleQuotedString(type, out);
writeString(R"(:[)", out); writeString(":[", out);
for (auto it = infos.begin(); it != infos.end(); ++it) for (auto it = infos.begin(); it != infos.end(); ++it)
{ {
if (it != infos.begin()) if (it != infos.begin())
@ -162,16 +162,26 @@ void MergeTreeDataPartTTLInfos::write(WriteBuffer & out) const
}; };
bool is_first = columns_ttl.empty() && !table_ttl.min; bool is_first = columns_ttl.empty() && !table_ttl.min;
write_infos(moves_ttl, "moves", is_first); if (!moves_ttl.empty())
{
write_infos(moves_ttl, "moves", is_first);
is_first = false;
}
is_first &= moves_ttl.empty(); if (!recompression_ttl.empty())
write_infos(recompression_ttl, "recompression", is_first); {
write_infos(recompression_ttl, "recompression", is_first);
is_first = false;
}
is_first &= recompression_ttl.empty(); if (!group_by_ttl.empty())
write_infos(group_by_ttl, "group_by", is_first); {
write_infos(group_by_ttl, "group_by", is_first);
is_first = false;
}
is_first &= group_by_ttl.empty(); if (!rows_where_ttl.empty())
write_infos(rows_where_ttl, "rows_where", is_first); write_infos(rows_where_ttl, "rows_where", is_first);
writeString("}", out); writeString("}", out);
} }