You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jd...@apache.org on 2010/07/31 01:37:19 UTC
svn commit: r980993 - in /hbase/trunk: CHANGES.txt
src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkMetrics.java
src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceMetrics.java
Author: jdcryans
Date: Fri Jul 30 23:37:19 2010
New Revision: 980993
URL: http://svn.apache.org/viewvc?rev=980993&view=rev
Log:
HBASE-2892 Replication metrics aren't updated
Modified:
hbase/trunk/CHANGES.txt
hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkMetrics.java
hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceMetrics.java
Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=980993&r1=980992&r2=980993&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Fri Jul 30 23:37:19 2010
@@ -463,6 +463,7 @@ Release 0.21.0 - Unreleased
HBASE-2890 Initialize RPC JMX metrics on startup (Gary Helmling via Stack)
HBASE-2755 Duplicate assignment of a region after region server recovery
(Kannan Muthukkaruppan via Stack)
+ HBASE-2892 Replication metrics aren't updated
IMPROVEMENTS
HBASE-1760 Cleanup TODOs in HTable
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkMetrics.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkMetrics.java?rev=980993&r1=980992&r2=980993&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkMetrics.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSinkMetrics.java Fri Jul 30 23:37:19 2010
@@ -58,8 +58,6 @@ public class ReplicationSinkMetrics impl
metricsRecord = MetricsUtil.createRecord(context, "replication");
metricsRecord.setTag("RegionServer", name);
context.registerUpdater(this);
- // Add jvmmetrics.
- JvmMetrics.init("RegionServer", name);
// export for JMX
new ReplicationStatistics(this.registry, "ReplicationSink");
}
@@ -78,5 +76,6 @@ public class ReplicationSinkMetrics impl
this.appliedBatchesRate.pushMetric(this.metricsRecord);
this.ageOfLastAppliedOp.pushMetric(this.metricsRecord);
}
+ this.metricsRecord.update();
}
}
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceMetrics.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceMetrics.java?rev=980993&r1=980992&r2=980993&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceMetrics.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceMetrics.java Fri Jul 30 23:37:19 2010
@@ -73,8 +73,6 @@ public class ReplicationSourceMetrics im
metricsRecord = MetricsUtil.createRecord(context, "replication");
metricsRecord.setTag("RegionServer", name);
context.registerUpdater(this);
- // Add jvmmetrics.
- JvmMetrics.init("RegionServer", name);
// export for JMX
new ReplicationStatistics(this.registry, "ReplicationSource for " + id);
}
@@ -97,5 +95,6 @@ public class ReplicationSourceMetrics im
this.ageOfLastShippedOp.pushMetric(this.metricsRecord);
this.sizeOfLogQueue.pushMetric(this.metricsRecord);
}
+ this.metricsRecord.update();
}
}