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

Fix tokenization in DataPartsExchange (it missed the last element)

Browse Source
This commit is contained in:
Robert Schulze 2024-01-10 11:43:03 +00:00
parent 499227b9cf
commit fee98994d4
No known key found for this signature in database
GPG Key ID: 26703B55FB13728A
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Storages/MergeTree/DataPartsExchange.cpp
View File

@ -172,13 +172,15 @@ void Service::processQuery(const HTMLForm & params, ReadBuffer & /*body*/, Write
/// E.g. remote_fs_metadata = "local, s3_plain, web" --> capabilities = ["local", "s3_plain", "web"]
Strings capabilities;
const String delimiter(", ");
size_t pos = 0;
while ((pos = remote_fs_metadata.find(delimiter)) != String::npos)
size_t pos_start = 0;
size_t pos_end;
while ((pos_end = remote_fs_metadata.find(delimiter, pos_start)) != std::string::npos)
{
String capability = remote_fs_metadata.substr(0, pos);
capabilities.push_back(capability);
remote_fs_metadata.erase(0, pos + delimiter.size());
const String token = remote_fs_metadata.substr(pos_start, pos_end - pos_start);
pos_start = pos_end + delimiter.size();
capabilities.push_back(token);
}
capabilities.push_back(remote_fs_metadata.substr(pos_start));
bool send_projections = client_protocol_version >= REPLICATION_PROTOCOL_VERSION_WITH_PARTS_PROJECTION;