You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ar...@apache.org on 2017/11/13 12:07:22 UTC
[08/11] drill git commit: DRILL-5909: Added new Counter metrics
DRILL-5909: Added new Counter metrics
closes #1019
Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/99e4504f
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/99e4504f
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/99e4504f
Branch: refs/heads/master
Commit: 99e4504f2aa9d11a6bc49a57f5edb70f8d621747
Parents: df95709
Author: Prasad Nagaraj Subramanya <pr...@gmail.com>
Authored: Wed Nov 1 13:49:43 2017 -0700
Committer: Arina Ielchiieva <ar...@gmail.com>
Committed: Mon Nov 13 11:06:53 2017 +0200
----------------------------------------------------------------------
.../org/apache/drill/exec/work/foreman/Foreman.java | 16 ++++++++++++++++
1 file changed, 16 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/drill/blob/99e4504f/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
index 10d8537..a1d150e 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java
@@ -126,6 +126,9 @@ public class Foreman implements Runnable {
private static final Counter enqueuedQueries = DrillMetrics.getRegistry().counter("drill.queries.enqueued");
private static final Counter runningQueries = DrillMetrics.getRegistry().counter("drill.queries.running");
private static final Counter completedQueries = DrillMetrics.getRegistry().counter("drill.queries.completed");
+ private static final Counter succeededQueries = DrillMetrics.getRegistry().counter("drill.queries.succeeded");
+ private static final Counter failedQueries = DrillMetrics.getRegistry().counter("drill.queries.failed");
+ private static final Counter canceledQueries = DrillMetrics.getRegistry().counter("drill.queries.canceled");
private final QueryId queryId;
private final String queryIdString;
@@ -837,6 +840,19 @@ public class Foreman implements Runnable {
logger.warn("unable to close query manager", e);
}
+ // Incrementing QueryState counters
+ switch (state) {
+ case FAILED:
+ failedQueries.inc();
+ break;
+ case CANCELED:
+ canceledQueries.inc();
+ break;
+ case COMPLETED:
+ succeededQueries.inc();
+ break;
+ }
+
runningQueries.dec();
completedQueries.inc();
try {