aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/service
diff options
context:
space:
mode:
authorSudheesh Katkam <skatkam@maprtech.com>2016-05-13 18:16:15 -0700
committerSudheesh Katkam <skatkam@maprtech.com>2016-05-17 14:59:21 -0700
commitb075bf6102e1561ee3755b483e1d1e6018d7e505 (patch)
tree95cde29baf98e501f876df2c91f229a52b8c44d9 /exec/java-exec/src/main/java/org/apache/drill/exec/service
parent09b262776e965ea17a6a863801f7e1ee3e5b3d5a (diff)
DRILL-4654: Add new metrics to the MetricRegistry
+ New metrics: - drill.queries.enqueued number of queries that have been submitted to the drillbit but have not started - drill.queries.running number of running queries for which this drillbit is the foreman - drill.queries.completed number of completed queries (or cancelled or failed) for which this drillbit was the foreman - drill.fragments.running number of query fragments that are running in the drillbit - drill.allocator.root.used amount of memory used in bytes by the internal memory allocator - drill.allocator.root.peak peak amount of memory used in bytes by the internal memory allocator - fd.usage ratio of used to total file descriptors (on *nix systems) + Rename "current" to "used" for RPC allocator current memory usage to follow convention + Borrow SystemPropertyUtil class from Netty + Configure DrillMetrics through system properties + Remove unused methods and imports closes #495
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/service')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/service/ServiceEngine.java9
1 files changed, 4 insertions, 5 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/service/ServiceEngine.java b/exec/java-exec/src/main/java/org/apache/drill/exec/service/ServiceEngine.java
index 17edbc26e..d5055461c 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/service/ServiceEngine.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/service/ServiceEngine.java
@@ -28,7 +28,6 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
-import org.apache.commons.lang3.StringUtils;
import org.apache.drill.common.AutoCloseables;
import org.apache.drill.common.config.DrillConfig;
import org.apache.drill.exec.ExecConstants;
@@ -92,9 +91,9 @@ public class ServiceEngine implements AutoCloseable {
}
- private final void registerMetrics(final MetricRegistry registry) {
+ private void registerMetrics(final MetricRegistry registry) {
final String prefix = PooledByteBufAllocatorL.METRIC_PREFIX + "rpc.";
- DrillMetrics.register(prefix + "user.current", new Gauge<Long>() {
+ DrillMetrics.register(prefix + "user.used", new Gauge<Long>() {
@Override
public Long getValue() {
return userAllocator.getAllocatedMemory();
@@ -106,7 +105,7 @@ public class ServiceEngine implements AutoCloseable {
return userAllocator.getPeakMemoryAllocation();
}
});
- DrillMetrics.register(prefix + "bit.control.current", new Gauge<Long>() {
+ DrillMetrics.register(prefix + "bit.control.used", new Gauge<Long>() {
@Override
public Long getValue() {
return controlAllocator.getAllocatedMemory();
@@ -119,7 +118,7 @@ public class ServiceEngine implements AutoCloseable {
}
});
- DrillMetrics.register(prefix + "bit.data.current", new Gauge<Long>() {
+ DrillMetrics.register(prefix + "bit.data.used", new Gauge<Long>() {
@Override
public Long getValue() {
return dataAllocator.getAllocatedMemory();