sidkhillon commented on code in PR #7577:
URL: https://github.com/apache/hbase/pull/7577#discussion_r2653704839
##########
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:
Just made that fix -- thanks for the suggestion. I also realized we need to
refresh the sources when we have a change in the peer config that affects the
source, so I've made that change as well. Please let me know if you find any
issues with it. Thanks!
--
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]
