Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id EFBB2200D3D for ; Mon, 13 Nov 2017 13:07:17 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id EE21B160BE4; Mon, 13 Nov 2017 12:07:17 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DEE1C160C0E for ; Mon, 13 Nov 2017 13:07:16 +0100 (CET) Received: (qmail 39123 invoked by uid 500); 13 Nov 2017 12:07:16 -0000 Mailing-List: contact commits-help@drill.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: commits@drill.apache.org Delivered-To: mailing list commits@drill.apache.org Received: (qmail 38959 invoked by uid 99); 13 Nov 2017 12:07:16 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Nov 2017 12:07:16 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 3E746F4D96; Mon, 13 Nov 2017 12:07:15 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: arina@apache.org To: commits@drill.apache.org Date: Mon, 13 Nov 2017 12:07:24 -0000 Message-Id: <68da4b496b714ffab80a28eca357324e@git.apache.org> In-Reply-To: <0132678ab3184c1784ff46634886ac05@git.apache.org> References: <0132678ab3184c1784ff46634886ac05@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [10/11] drill git commit: DRILL-5923: Display name for query state archived-at: Mon, 13 Nov 2017 12:07:18 -0000 DRILL-5923: Display name for query state closes #1021 Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/30da051b Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/30da051b Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/30da051b Branch: refs/heads/master Commit: 30da051b968926b7ead388b7df56c402dbdd5cb8 Parents: ed6c4bc Author: Prasad Nagaraj Subramanya Authored: Thu Nov 9 15:00:15 2017 -0800 Committer: Arina Ielchiieva Committed: Mon Nov 13 11:45:20 2017 +0200 ---------------------------------------------------------------------- .../server/rest/profile/ProfileResources.java | 8 ++-- .../exec/server/rest/profile/ProfileUtil.java | 48 ++++++++++++++++++++ .../server/rest/profile/ProfileWrapper.java | 4 ++ .../src/main/resources/rest/profile/profile.ftl | 3 +- 4 files changed, 59 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/drill/blob/30da051b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileResources.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileResources.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileResources.java index 875c96e..14056b0 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileResources.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileResources.java @@ -63,7 +63,7 @@ import com.google.common.collect.Lists; @Path("/") @RolesAllowed(DrillUserPrincipal.AUTHENTICATED_ROLE) public class ProfileResources { - static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(ProfileResources.class); + private static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(ProfileResources.class); @Inject UserAuthEnabled authEnabled; @Inject WorkManager work; @@ -217,7 +217,8 @@ public class ProfileResources { runningQueries.add( new ProfileInfo(work.getContext().getConfig(), runningEntry.getKey(), profile.getStart(), System.currentTimeMillis(), - profile.getForeman().getAddress(), profile.getQuery(), profile.getState().name(), + profile.getForeman().getAddress(), profile.getQuery(), + ProfileUtil.getQueryStateDisplayName(profile.getState()), profile.getUser(), profile.getTotalCost(), profile.getQueueName())); } } catch (Exception e) { @@ -247,7 +248,8 @@ public class ProfileResources { finishedQueries.add( new ProfileInfo(work.getContext().getConfig(), profileEntry.getKey(), profile.getStart(), profile.getEnd(), - profile.getForeman().getAddress(), profile.getQuery(), profile.getState().name(), + profile.getForeman().getAddress(), profile.getQuery(), + ProfileUtil.getQueryStateDisplayName(profile.getState()), profile.getUser(), profile.getTotalCost(), profile.getQueueName())); } } catch (Exception e) { http://git-wip-us.apache.org/repos/asf/drill/blob/30da051b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileUtil.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileUtil.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileUtil.java new file mode 100644 index 0000000..cfc7977 --- /dev/null +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileUtil.java @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.drill.exec.server.rest.profile; + +import org.apache.drill.exec.proto.UserBitShared.QueryResult.QueryState; + +public class ProfileUtil { + // Display names for QueryState enum in UserBitShared.proto + private static final String[] queryStateDisplayNames = { + "Starting", // STARTING = 0 + "Running", // RUNNING = 1 + "Succeeded", // COMPLETED = 2 + "Canceled", // CANCELED = 3 + "Failed", // FAILED = 4 + "CancellationRequested", // CANCELLATION_REQUESTED = 5 + "Enqueued" // ENQUEUED = 6 + }; + + + /** + * Utility to return display name for query state + * @param queryState + * @return display string for query state + */ + public final static String getQueryStateDisplayName(QueryState queryState) { + int queryStateOrdinal = queryState.getNumber(); + if (queryStateOrdinal >= queryStateDisplayNames.length) { + return queryState.name(); + } else { + return queryStateDisplayNames[queryStateOrdinal]; + } + } +} http://git-wip-us.apache.org/repos/asf/drill/blob/30da051b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileWrapper.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileWrapper.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileWrapper.java index ef9ccc3..3a7d432 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileWrapper.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileWrapper.java @@ -148,6 +148,10 @@ public class ProfileWrapper { return id; } + public String getQueryStateDisplayName() { + return ProfileUtil.getQueryStateDisplayName(profile.getState()); + } + public String getPlanningDuration() { //Check if Planning End is known if (profile.getPlanEnd() > 0L) { http://git-wip-us.apache.org/repos/asf/drill/blob/30da051b/exec/java-exec/src/main/resources/rest/profile/profile.ftl ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/resources/rest/profile/profile.ftl b/exec/java-exec/src/main/resources/rest/profile/profile.ftl index 889e17a..ff78da3 100644 --- a/exec/java-exec/src/main/resources/rest/profile/profile.ftl +++ b/exec/java-exec/src/main/resources/rest/profile/profile.ftl @@ -135,6 +135,7 @@ table.sortable thead .sorting_desc { background-image: url("/static/img/black-de <#assign queueName = model.getProfile().getQueueName() /> <#assign queued = queueName != "" && queueName != "-" /> +

Query Profile

@@ -162,7 +163,7 @@ table.sortable thead .sorting_desc { background-image: url("/static/img/black-de - ${model.getProfile().getState().name()} + ${model.getQueryStateDisplayName()} ${model.getProfile().getForeman().getAddress()} ${model.getProfile().getTotalFragments()} <#if queued>