You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by cg...@apache.org on 2022/10/23 12:46:36 UTC
[drill] branch master updated: DRILL-8341: Add Scanned Plugin List to Sys Profiles Table (#2690)
This is an automated email from the ASF dual-hosted git repository.
cgivre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git
The following commit(s) were added to refs/heads/master by this push:
new 64a8afcf0c DRILL-8341: Add Scanned Plugin List to Sys Profiles Table (#2690)
64a8afcf0c is described below
commit 64a8afcf0cc89b618e7c3ce889b84208c38d3047
Author: Charles S. Givre <cg...@apache.org>
AuthorDate: Sun Oct 23 08:46:30 2022 -0400
DRILL-8341: Add Scanned Plugin List to Sys Profiles Table (#2690)
---
.../org/apache/drill/exec/store/sys/ProfileInfoIterator.java | 10 ++++++++--
.../apache/drill/exec/work/metadata/TestMetadataProvider.java | 2 +-
2 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java
index f068915260..a5a01aab36 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java
@@ -90,6 +90,8 @@ public class ProfileInfoIterator extends ProfileIterator {
computeDuration(profile.getPlanEnd(), assumedQueueEndTime),
computeDuration(assumedQueueEndTime, profile.getEnd()),
profile.getState().name(),
+ profile.getScannedPluginsCount(),
+ profile.getScannedPluginsList().toString(),
profile.getQuery()
);
}
@@ -129,11 +131,13 @@ public class ProfileInfoIterator extends ProfileIterator {
public final long executeTime;
public final long totalTime;
public final String state;
+ public final long pluginCount;
+ public final String pluginList;
public final String query;
public ProfileInfo(String query_id, Timestamp time, String foreman, long fragmentCount, String username,
String queueName, long planDuration, long queueWaitDuration, long executeDuration,
- String state, String query) {
+ String state, long pluginCount, String pluginList, String query) {
this.queryId = query_id;
this.startTime = time;
this.foreman = foreman;
@@ -145,13 +149,15 @@ public class ProfileInfoIterator extends ProfileIterator {
this.executeTime = executeDuration;
this.totalTime = this.planTime + this.queueTime + this.executeTime;
this.query = query;
+ this.pluginCount = pluginCount;
+ this.pluginList = pluginList;
this.state = state;
}
private ProfileInfo() {
this(UNKNOWN_VALUE, new Timestamp(0), UNKNOWN_VALUE, 0L,
UNKNOWN_VALUE, UNKNOWN_VALUE, 0L, 0L,
- 0L, UNKNOWN_VALUE, UNKNOWN_VALUE);
+ 0L, UNKNOWN_VALUE, 0L, UNKNOWN_VALUE, UNKNOWN_VALUE);
}
/**
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java b/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java
index d85b7847d8..c0c742afe2 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java
@@ -242,7 +242,7 @@ public class TestMetadataProvider extends BaseTestQuery {
assertEquals(RequestStatus.OK, resp.getStatus());
List<ColumnMetadata> columns = resp.getColumnsList();
- assertEquals(170, columns.size());
+ assertEquals(172, columns.size());
// too many records to verify the output.
}