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

add integration tests

Browse Source
This commit is contained in:
taiyang-li 2022-04-06 18:47:34 +08:00
parent acb9f1632e
commit 0b0c8ef09e
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/Storages/Hive/StorageHive.cpp
View File

@ -176,7 +176,8 @@ public:
/// Use local cache for remote storage if enabled. /// Use local cache for remote storage if enabled.
std::unique_ptr<ReadBuffer> remote_read_buf; std::unique_ptr<ReadBuffer> remote_read_buf;
if (ExternalDataSourceCache::instance().isInitialized() && getContext()->getSettingsRef().use_local_cache_for_remote_storage) if (ExternalDataSourceCache::instance().isInitialized()
&& getContext()->getSettingsRef().use_local_cache_for_remote_storage)
{ {
size_t buff_size = raw_read_buf->internalBuffer().size(); size_t buff_size = raw_read_buf->internalBuffer().size();
if (buff_size == 0) if (buff_size == 0)
@ -547,7 +548,8 @@ HiveFilePtr StorageHive::createHiveFileIfNeeded(
if (!hivefile_key_condition.checkInHyperrectangle(hive_file->getMinMaxIndex()->hyperrectangle, hivefile_name_types.getTypes()) if (!hivefile_key_condition.checkInHyperrectangle(hive_file->getMinMaxIndex()->hyperrectangle, hivefile_name_types.getTypes())
.can_be_true) .can_be_true)
{ {
LOG_TRACE(log, "Skip hive file {} by index {}", hive_file->getPath(), hive_file->describeMinMaxIndex(hive_file->getMinMaxIndex())); LOG_TRACE(
log, "Skip hive file {} by index {}", hive_file->getPath(), hive_file->describeMinMaxIndex(hive_file->getMinMaxIndex()));
return {}; return {};
} }
} }
@ -563,7 +565,12 @@ HiveFilePtr StorageHive::createHiveFileIfNeeded(
if (!hivefile_key_condition.checkInHyperrectangle(sub_minmax_idxes[i]->hyperrectangle, hivefile_name_types.getTypes()) if (!hivefile_key_condition.checkInHyperrectangle(sub_minmax_idxes[i]->hyperrectangle, hivefile_name_types.getTypes())
.can_be_true) .can_be_true)
{ {
LOG_TRACE(log, "Skip split {} of hive file {}", i, hive_file->getPath()); LOG_TRACE(
log,
"Skip split {} of hive file {} by index {}",
i,
hive_file->getPath(),
hive_file->describeMinMaxIndex(sub_minmax_idxes[i]));
skip_splits.insert(i); skip_splits.insert(i);
} }
} }