You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2022/03/17 15:31:52 UTC
[hbase] branch branch-2.5 updated: HBASE-26833 Addendum fix NPE in TestReplicationSource.testTerminateClearsBuffer
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.5 by this push:
new 2e8f0a0 HBASE-26833 Addendum fix NPE in TestReplicationSource.testTerminateClearsBuffer
2e8f0a0 is described below
commit 2e8f0a0326bbe3c4163cf162c74e7ed5f242fdc6
Author: Duo Zhang <zh...@apache.org>
AuthorDate: Thu Mar 17 23:13:41 2022 +0800
HBASE-26833 Addendum fix NPE in TestReplicationSource.testTerminateClearsBuffer
(cherry picked from commit bd65ad42a297335a09ad862761e44ba101d97770)
---
.../hadoop/hbase/replication/regionserver/TestReplicationSource.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java
index 484bd5b..6da3600 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java
@@ -291,8 +291,8 @@ public class TestReplicationSource {
ReplicationPeer mockPeer = mock(ReplicationPeer.class);
Mockito.when(mockPeer.getPeerBandwidth()).thenReturn(0L);
Configuration testConf = HBaseConfiguration.create();
- source.init(testConf, null, mockManager, null, mockPeer, null,
- "testPeer", null, p -> OptionalLong.empty(), mock(MetricsSource.class));
+ source.init(testConf, null, mockManager, null, mockPeer, Mockito.mock(Server.class), "testPeer",
+ null, p -> OptionalLong.empty(), mock(MetricsSource.class));
ReplicationSourceWALReader reader = new ReplicationSourceWALReader(null,
conf, null, 0, null, source, null);
ReplicationSourceShipper shipper =