taklwu commented on code in PR #7577:
URL: https://github.com/apache/hbase/pull/7577#discussion_r2653616195
##########
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java:
##########
@@ -862,4 +862,14 @@ public String logPeerId() {
public long getTotalReplicatedEdits() {
return totalReplicatedEdits.get();
}
+
+ @Override
+ public long getSleepForRetriesForTesting() {
+ return sleepForRetries;
+ }
+
+ @Override
+ public Map<String, ReplicationSourceShipper> getWorkerThreadsForTesting() {
+ return workerThreads;
+ }
}
Review Comment:
yeah, it's mostly related to `manager.getSources()` were returning a list of
`ReplicationSourceInterface`.
using cast was what I was thinking like below , and you got my point as well.
```
Map<String, ReplicationSourceShipper> workers =
((ReplicationSource) source).getWorkerThreadsForTesting();
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
