Skip to content

Commit 89da2d6

Browse files
authored
PHOENIX-7546 :- When hbase client metrics is enabled set hbase client metrics scope (#2089)
1 parent 2f392b8 commit 89da2d6

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

phoenix-core-client/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,8 @@
2121
import static org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder.MAX_VERSIONS;
2222
import static org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder.REPLICATION_SCOPE;
2323
import static org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder.TTL;
24+
import static org.apache.hadoop.hbase.client.MetricsConnection.CLIENT_SIDE_METRICS_ENABLED_KEY;
25+
import static org.apache.hadoop.hbase.client.MetricsConnection.METRICS_SCOPE_KEY;
2426
import static org.apache.hadoop.hbase.ipc.RpcControllerFactory.CUSTOM_CONTROLLER_CONF_KEY;
2527
import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP;
2628
import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_4_15_0;
@@ -554,6 +556,9 @@ public ConnectionQueryServicesImpl(QueryServices services, ConnectionInfo connec
554556
.build();
555557
}
556558

559+
if (this.config.getBoolean(CLIENT_SIDE_METRICS_ENABLED_KEY, false)) {
560+
this.config.set(METRICS_SCOPE_KEY, config.get(QUERY_SERVICES_NAME));
561+
}
557562

558563
if (!QueryUtil.isServerConnection(props)) {
559564
//Start queryDistruptor everytime as log level can be change at connection level as well, but we can avoid starting for server connections.

0 commit comments

Comments
 (0)