This is an automated email from the ASF dual-hosted git repository. dbecker pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/impala.git
commit 11a9861ec695fe62b39095940514b28a8c684484 Author: Xiang Yang <[email protected]> AuthorDate: Wed Jun 28 13:01:13 2023 +0000 IMPALA-12246: Record client network address in the same line when log open or close session. Testing: - Manually test. Change-Id: I5044a002ea3c40c0c964eb14bc4949ade374bcfe Reviewed-on: http://gerrit.cloudera.org:8080/20134 Reviewed-by: Impala Public Jenkins <[email protected]> Tested-by: Impala Public Jenkins <[email protected]> --- be/src/service/impala-hs2-server.cc | 4 +++- be/src/service/impala-server.cc | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/be/src/service/impala-hs2-server.cc b/be/src/service/impala-hs2-server.cc index 3a3a36805..1000caec8 100644 --- a/be/src/service/impala-hs2-server.cc +++ b/be/src/service/impala-hs2-server.cc @@ -429,7 +429,9 @@ void ImpalaServer::OpenSession(TOpenSessionResp& return_val, return_val.status.__set_statusCode(thrift::TStatusCode::SUCCESS_STATUS); return_val.serverProtocolVersion = state->hs2_version; VLOG_QUERY << "Opened session: " << PrintId(session_id) - << " effective username: " << GetEffectiveUser(*state); + << ", effective username: " << GetEffectiveUser(*state) + << ", client address: " + << "<" << TNetworkAddressToString(state->network_address) << ">."; } void ImpalaServer::CloseSession(TCloseSessionResp& return_val, diff --git a/be/src/service/impala-server.cc b/be/src/service/impala-server.cc index c1ab28531..d2fe8f37d 100644 --- a/be/src/service/impala-server.cc +++ b/be/src/service/impala-server.cc @@ -1720,7 +1720,9 @@ Status ImpalaServer::CloseSessionInternal(const TUniqueId& session_id, } // Reconfigure the poll period of session_maintenance_thread_ if necessary. UnregisterSessionTimeout(session_state->session_timeout); - VLOG_QUERY << "Closed session: " << PrintId(session_id); + VLOG_QUERY << "Closed session: " << PrintId(session_id) + << ", client address: " + << "<" << TNetworkAddressToString(session_state->network_address) << ">."; return Status::OK(); }
