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

Merge pull request #71889 from yariks5s/fix_insert_hive_partititoning

Browse Source 
Fixes for hive partitioning while reading
This commit is contained in:
Yarik Briukhovetskyi 2024-11-19 16:51:47 +00:00 committed by GitHub
commit 98f7681497
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Storages/ObjectStorage/StorageObjectStorage.cpp
View File

@ -47,6 +47,7 @@ String StorageObjectStorage::getPathSample(StorageInMemoryMetadata metadata, Con
auto query_settings = configuration->getQuerySettings(context); auto query_settings = configuration->getQuerySettings(context);
/// We don't want to throw an exception if there are no files with specified path. /// We don't want to throw an exception if there are no files with specified path.
query_settings.throw_on_zero_files_match = false; query_settings.throw_on_zero_files_match = false;
query_settings.ignore_non_existent_file = true;
bool local_distributed_processing = distributed_processing; bool local_distributed_processing = distributed_processing;
if (context->getSettingsRef()[Setting::use_hive_partitioning]) if (context->getSettingsRef()[Setting::use_hive_partitioning])
@ -64,6 +65,9 @@ String StorageObjectStorage::getPathSample(StorageInMemoryMetadata metadata, Con
{} // file_progress_callback {} // file_progress_callback
); );
if (!configuration->isArchive() && !configuration->isPathWithGlobs() && !local_distributed_processing)
return configuration->getPath();
if (auto file = file_iterator->next(0)) if (auto file = file_iterator->next(0))
return file->getPath(); return file->getPath();
return ""; return "";