This is an automated email from the ASF dual-hosted git repository.
awong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kudu.git
commit 3f14af36507fddddf8ba735af7c7ac56396d1ecb
Author: Andrew Wong <awong@cloudera.com>
AuthorDate: Tue Mar 10 17:29:08 2020 -0700
ranger: instantiate Ranger queue size metrics
Hit a segfault when trying to run an actual Ranger subprocess instead of
a mock.
Change-Id: I29ac97df4f5cac3d658ee7a619df6a4bece6b924
Reviewed-on: http://gerrit.cloudera.org:8080/15399
Reviewed-by: Adar Dembo <adar@cloudera.com>
Tested-by: Kudu Jenkins
---
src/kudu/ranger/ranger_client.cc | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/kudu/ranger/ranger_client.cc b/src/kudu/ranger/ranger_client.cc
index c8ca24f..fe3a477 100644
--- a/src/kudu/ranger/ranger_client.cc
+++ b/src/kudu/ranger/ranger_client.cc
@@ -126,12 +126,14 @@ const char* kMainClass = "org.apache.kudu.ranger.RangerSubprocessMain";
#define HISTINIT(member, x) member = METRIC_##x.Instantiate(entity)
RangerSubprocessMetrics::RangerSubprocessMetrics(const scoped_refptr<MetricEntity>&
entity) {
HISTINIT(sp_inbound_queue_length, ranger_subprocess_inbound_queue_length);
- HISTINIT(sp_outbound_queue_length, ranger_subprocess_outbound_queue_length);
HISTINIT(sp_inbound_queue_time_ms, ranger_subprocess_inbound_queue_time_ms);
+ HISTINIT(sp_outbound_queue_length, ranger_subprocess_outbound_queue_length);
HISTINIT(sp_outbound_queue_time_ms, ranger_subprocess_outbound_queue_time_ms);
HISTINIT(sp_execution_time_ms, ranger_subprocess_execution_time_ms);
- HISTINIT(server_outbound_queue_time_ms, ranger_server_outbound_queue_time_ms);
+ HISTINIT(server_inbound_queue_size_bytes, ranger_server_inbound_queue_size_bytes);
HISTINIT(server_inbound_queue_time_ms, ranger_server_inbound_queue_time_ms);
+ HISTINIT(server_outbound_queue_size_bytes, ranger_server_outbound_queue_size_bytes);
+ HISTINIT(server_outbound_queue_time_ms, ranger_server_outbound_queue_time_ms);
}
#undef HISTINIT
|