mirror of
https://github.com/apache/impala.git
synced 2025-12-19 09:58:28 -05:00
8692bfbef6
After this patch, the statestore keeps track of the time since the last heartbeat for each subscriber. It is exposed as a subscriber metric on the statestore debug page. It also adds a monitoring thread that periodically checks the last heartbeat timestamp for all subscribers and logs the IDs of those that have not been updated since the last periodic check. Testing: Added an end to end test to verify the 'sec_since_heartbeat' metric of a slow subscriber. Change-Id: I754adccc4569e8219d5d01500cccdfc8782953f7 Reviewed-on: http://gerrit.cloudera.org:8080/11052 Reviewed-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com> Tested-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com>
49 lines
1.3 KiB
Cheetah
49 lines
1.3 KiB
Cheetah
<!--
|
|
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.
|
|
-->
|
|
{{> www/common-header.tmpl }}
|
|
|
|
<h2>Subscribers ({{%subscribers}} total)</h2>
|
|
|
|
<table class='table table-hover table-striped'>
|
|
<tr>
|
|
<th>Id</th>
|
|
<th>Address</th>
|
|
<th>Subscribed topics</th>
|
|
<th>Subscribed priority topics</th>
|
|
<th>Transient entries</th>
|
|
<th>Registration ID</th>
|
|
<th>Seconds since last heartbeat</th>
|
|
</tr>
|
|
|
|
{{#subscribers}}
|
|
<tr>
|
|
<td>{{id}}</td>
|
|
<td>{{address}}</td>
|
|
<td>{{num_topics}}</td>
|
|
<td>{{num_priority_topics}}</td>
|
|
<td>{{num_transient}}</td>
|
|
<td>{{registration_id}}</td>
|
|
<td>{{secs_since_heartbeat}}</td>
|
|
</tr>
|
|
{{/subscribers}}
|
|
|
|
</table>
|
|
|
|
{{> www/common-footer.tmpl }}
|