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

Fix typo

Browse Source
This commit is contained in:
Robert Schulze 2024-07-08 07:38:07 +00:00
parent d8d2007a62
commit 3fa1fd321f
No known key found for this signature in database
GPG Key ID: 26703B55FB13728A
5 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/en/operations/system-tables/metrics.md
View File

@ -357,7 +357,7 @@ Number of currently running inserts to Kafka
Number of alive connections
### KeeperOutstandingRequets
### KeeperOutstandingRequests
Number of outstanding requests

2
src/Common/CurrentMetrics.cpp
View File

@ -267,7 +267,7 @@
M(AsyncInsertCacheSize, "Number of async insert hash id in cache") \
M(S3Requests, "S3 requests count") \
M(KeeperAliveConnections, "Number of alive connections") \
M(KeeperOutstandingRequets, "Number of outstanding requests") \
M(KeeperOutstandingRequests, "Number of outstanding requests") \
M(ThreadsInOvercommitTracker, "Number of waiting threads inside of OvercommitTracker") \
M(IOUringPendingEvents, "Number of io_uring SQEs waiting to be submitted") \
M(IOUringInFlightEvents, "Number of io_uring SQEs in flight") \

2
src/Coordination/KeeperConstants.cpp
View File

@ -372,7 +372,7 @@ extern const std::vector<Event> keeper_profile_events
M(AsynchronousReadWait) \
M(S3Requests) \
M(KeeperAliveConnections) \
M(KeeperOutstandingRequets) \
M(KeeperOutstandingRequests) \
M(ThreadsInOvercommitTracker) \
M(IOUringPendingEvents) \
M(IOUringInFlightEvents) \

14
src/Coordination/KeeperDispatcher.cpp
View File

@ -28,7 +28,7 @@
namespace CurrentMetrics
{
extern const Metric KeeperAliveConnections;
extern const Metric KeeperOutstandingRequets;
extern const Metric KeeperOutstandingRequests;
}
namespace ProfileEvents
@ -139,7 +139,7 @@ void KeeperDispatcher::requestThread()
{
if (requests_queue->tryPop(request, max_wait))
{
CurrentMetrics::sub(CurrentMetrics::KeeperOutstandingRequets);
CurrentMetrics::sub(CurrentMetrics::KeeperOutstandingRequests);
if (shutdown_called)
break;
@ -171,7 +171,7 @@ void KeeperDispatcher::requestThread()
/// Trying to get batch requests as fast as possible
if (requests_queue->tryPop(request))
{
CurrentMetrics::sub(CurrentMetrics::KeeperOutstandingRequets);
CurrentMetrics::sub(CurrentMetrics::KeeperOutstandingRequests);
/// Don't append read request into batch, we have to process them separately
if (!coordination_settings->quorum_reads && request.request->isReadRequest())
{
@ -419,7 +419,7 @@ bool KeeperDispatcher::putRequest(const Coordination::ZooKeeperRequestPtr & requ
{
throw Exception(ErrorCodes::TIMEOUT_EXCEEDED, "Cannot push request to queue within operation timeout");
}
CurrentMetrics::add(CurrentMetrics::KeeperOutstandingRequets);
CurrentMetrics::add(CurrentMetrics::KeeperOutstandingRequests);
return true;
}
@ -543,7 +543,7 @@ void KeeperDispatcher::shutdown()
/// Set session expired for all pending requests
while (requests_queue && requests_queue->tryPop(request_for_session))
{
CurrentMetrics::sub(CurrentMetrics::KeeperOutstandingRequets);
CurrentMetrics::sub(CurrentMetrics::KeeperOutstandingRequests);
auto response = request_for_session.request->makeResponse();
response->error = Coordination::Error::ZSESSIONEXPIRED;
setResponse(request_for_session.session_id, response);
@ -670,7 +670,7 @@ void KeeperDispatcher::sessionCleanerTask()
};
if (!requests_queue->push(std::move(request_info)))
LOG_INFO(log, "Cannot push close request to queue while cleaning outdated sessions");
CurrentMetrics::add(CurrentMetrics::KeeperOutstandingRequets);
CurrentMetrics::add(CurrentMetrics::KeeperOutstandingRequests);
/// Remove session from registered sessions
finishSession(dead_session);
@ -794,7 +794,7 @@ int64_t KeeperDispatcher::getSessionID(int64_t session_timeout_ms)
/// Push new session request to queue
if (!requests_queue->tryPush(std::move(request_info), session_timeout_ms))
throw Exception(ErrorCodes::TIMEOUT_EXCEEDED, "Cannot push session id request to queue within session timeout");
CurrentMetrics::add(CurrentMetrics::KeeperOutstandingRequets);
CurrentMetrics::add(CurrentMetrics::KeeperOutstandingRequests);
if (future.wait_for(std::chrono::milliseconds(session_timeout_ms)) != std::future_status::ready)
throw Exception(ErrorCodes::TIMEOUT_EXCEEDED, "Cannot receive session id within session timeout");

2
utils/check-style/aspell-ignore/en/aspell-dict.txt
View File

@ -449,7 +449,7 @@ Kahan
Kaser
KeeperAliveConnections
KeeperMap
KeeperOutstandingRequets
KeeperOutstandingRequests
Kerberos
Khanna
KittenHouse