Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-26833 Addendum fix NPE in TestReplicationSource.testTerminateClearsBuffer 

(cherry picked from commit bd65ad42a2)
This commit is contained in:
Duo Zhang 2022-03-17 23:13:41 +08:00
parent c413bb1120
commit 2e8f0a0326
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java
View File

@ -291,8 +291,8 @@ public class TestReplicationSource {
ReplicationPeer mockPeer = mock(ReplicationPeer.class); ReplicationPeer mockPeer = mock(ReplicationPeer.class);
Mockito.when(mockPeer.getPeerBandwidth()).thenReturn(0L); Mockito.when(mockPeer.getPeerBandwidth()).thenReturn(0L);
Configuration testConf = HBaseConfiguration.create(); Configuration testConf = HBaseConfiguration.create();
source.init(testConf, null, mockManager, null, mockPeer, null, source.init(testConf, null, mockManager, null, mockPeer, Mockito.mock(Server.class), "testPeer",
"testPeer", null, p -> OptionalLong.empty(), mock(MetricsSource.class)); null, p -> OptionalLong.empty(), mock(MetricsSource.class));
ReplicationSourceWALReader reader = new ReplicationSourceWALReader(null, ReplicationSourceWALReader reader = new ReplicationSourceWALReader(null,
conf, null, 0, null, source, null); conf, null, 0, null, source, null);
ReplicationSourceShipper shipper = ReplicationSourceShipper shipper =