[HBASE-16870] Add the metrics of replication sources which were transformed from other dead rs to ReplicationLoad

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.4.0, 1.2.3, 1.1.7, 2.0.0
• Fix Version/s: 1.4.0, 1.2.4, 0.98.24, 1.1.8, 2.0.0
• Component/s: Replication
• Hadoop Flags: Reviewed
• Assignee: Guanghao Zhang
• Reporter: Guanghao Zhang
• Created: 18/Oct/16 11:18
• Updated: 20/Nov/17 11:07
• Resolved: 22/Oct/16 06:30

Description

  private void buildReplicationLoad() {
    // get source
    List<ReplicationSourceInterface> sources = this.replicationManager.getSources();
    List<MetricsSource> sourceMetricsList = new ArrayList<MetricsSource>();

    for (ReplicationSourceInterface source : sources) {
      if (source instanceof ReplicationSource) {
        sourceMetricsList.add(((ReplicationSource) source).getSourceMetrics());
      }
    }

    // get sink
    MetricsSink sinkMetrics = this.replicationSink.getSinkMetrics();
    this.replicationLoad.buildReplicationLoad(sourceMetricsList, sinkMetrics);
  }

The buildReplicationLoad method in o.a.h.h.r.r.Replication didn't consider the replication source which were transformed from other died rs.

Issue Links

• relates to: HBASE-18936 Backport HBASE-16870 to branch-1.3