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

Fix log level

Browse Source
This commit is contained in:
kssenii 2024-05-13 21:39:34 +02:00
parent 1c527e86aa
commit cab2c160fe
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Storages/S3Queue/S3QueueFilesMetadata.cpp
View File

@ -948,7 +948,7 @@ bool S3QueueFilesMetadata::ProcessingNodeHolder::remove(Coordination::Requests *
catch (...)
{
ProfileEvents::increment(ProfileEvents::CannotRemoveEphemeralNode);
LOG_TEST(log, "Failed to remove processing node for file {}: {}", path, getCurrentExceptionMessage(true));
LOG_ERROR(log, "Failed to remove processing node for file {}: {}", path, getCurrentExceptionMessage(true));
}
return false;
}
@ -967,7 +967,7 @@ void S3QueueFilesMetadata::cleanupThreadFunc()
}
catch (...)
{
LOG_TEST(log, "Failed to cleanup nodes in zookeeper: {}", getCurrentExceptionMessage(true));
LOG_ERROR(log, "Failed to cleanup nodes in zookeeper: {}", getCurrentExceptionMessage(true));
}
if (shutdown)
@ -1065,7 +1065,7 @@ void S3QueueFilesMetadata::cleanupThreadFuncImpl()
}
catch (...)
{
LOG_TEST(log, "Failed to fetch metadata for node {}: {}", node, getCurrentExceptionMessage(true));
LOG_ERROR(log, "Failed to fetch metadata for node {}: {}", node, getCurrentExceptionMessage(true));
}
}
@ -1085,7 +1085,7 @@ void S3QueueFilesMetadata::cleanupThreadFuncImpl()
}
catch (...)
{
LOG_TEST(log, "Failed to fetch metadata for node {}: {}", path, getCurrentExceptionMessage(true));
LOG_ERROR(log, "Failed to fetch metadata for node {}: {}", path, getCurrentExceptionMessage(true));
}
}

4
src/Storages/S3Queue/S3QueueSource.cpp
View File

@ -238,7 +238,7 @@ Chunk StorageS3QueueSource::generate()
}
catch (...)
{
LOG_TEST(log, "Failed to set file {} as failed: {}",
LOG_ERROR(log, "Failed to set file {} as failed: {}",
key_with_info->key, getCurrentExceptionMessage(true));
}
@ -265,7 +265,7 @@ Chunk StorageS3QueueSource::generate()
}
catch (...)
{
LOG_TEST(log, "Failed to set file {} as failed: {}",
LOG_ERROR(log, "Failed to set file {} as failed: {}",
key_with_info->key, getCurrentExceptionMessage(true));
}

2
src/Storages/S3Queue/StorageS3Queue.cpp
View File

@ -469,7 +469,7 @@ void StorageS3Queue::threadFunc()
}
catch (...)
{
LOG_TEST(log, "Failed to process data: {}", getCurrentExceptionMessage(true));
LOG_ERROR(log, "Failed to process data: {}", getCurrentExceptionMessage(true));
}
if (!shutdown_called)