Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill >> mail # dev >> [13/24] diag wip


Copy link to this message
-
[13/24] diag wip
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/cb90852a/protocol/src/main/protobuf/BitControl.proto
diff --git a/protocol/src/main/protobuf/BitControl.proto b/protocol/src/main/protobuf/BitControl.proto
index d9fa4b4..386f692 100644
+++ b/protocol/src/main/protobuf/BitControl.proto
@@ -40,27 +40,8 @@ message BitStatus {
 }
 
 message FragmentStatus {
-  
-  enum FragmentState {
-    SENDING = 0;
-    AWAITING_ALLOCATION = 1;
-    RUNNING = 2;
-    FINISHED = 3;
-    CANCELLED = 4;
-    FAILED = 5;
-  }
-  
-  optional int64 memory_use = 1;
-  optional int64 batches_completed = 2;
-  optional int64 records_completed = 3;
-  optional int32 estimated_completion_percentage = 4;
-  optional FragmentState state = 5;
-  optional int64 data_processed = 6;
-  
-  optional FragmentHandle handle = 7;
-  optional exec.shared.DrillPBError error = 8;
-  optional int64 running_time = 9;
-  optional exec.shared.MinorFragmentProfile profile = 10;
+  optional exec.shared.MinorFragmentProfile profile = 1;
+  optional FragmentHandle handle = 2;
 }
 
 message PlanFragment {

http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/cb90852a/protocol/src/main/protobuf/UserBitShared.proto
diff --git a/protocol/src/main/protobuf/UserBitShared.proto b/protocol/src/main/protobuf/UserBitShared.proto
index c379112..9a3dd2a 100644
+++ b/protocol/src/main/protobuf/UserBitShared.proto
@@ -82,7 +82,8 @@ message QueryProfile {
   optional int64 start = 3;
   optional int64 end = 4;
   optional string query = 5;
-  repeated MajorFragmentProfile fragment_profile = 6;
+  optional string plan = 6;
+  repeated MajorFragmentProfile fragment_profile = 7;
 }
 
 message MajorFragmentProfile {
@@ -91,15 +92,19 @@ message MajorFragmentProfile {
 }
 
 message MinorFragmentProfile {
-  optional int32 minor_fragment_id = 1;
-  repeated OperatorProfile operator_profile = 2;
-  optional int64 start_time = 3;
-  optional int64 end_time = 4;  
+  optional FragmentState state = 1;
+  optional DrillPBError error = 2;
+  optional int32 minor_fragment_id = 3;
+  repeated OperatorProfile operator_profile = 4;
+  optional int64 start_time = 5;
+  optional int64 end_time = 6;
+  optional int64 memory_used = 7;
+  optional int64 max_memory_used = 8;
+  optional DrillbitEndpoint endpoint = 9;
 }
 
 message OperatorProfile {
   repeated StreamProfile input_profile = 1;
-  optional StreamProfile output_profile = 2;
   optional int32 operator_id = 3;
   optional int32 operator_type = 4;
   optional int64 setup_nanos = 5;
@@ -120,6 +125,14 @@ message MetricValue {
   optional double double_value = 3;
 }
 
+enum FragmentState {
+  SENDING = 0;
+  AWAITING_ALLOCATION = 1;
+  RUNNING = 2;
+  FINISHED = 3;
+  CANCELLED = 4;
+  FAILED = 5;
+}
 
 enum CoreOperatorType {
   SINGLE_SENDER = 0;
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB