HBASE-26833 Addendum fix NPE in TestReplicationSource.testTerminateClearsBuffer

This commit is contained in:
Duo Zhang 2022-03-17 23:13:41 +08:00
parent caea843e94
commit bd65ad42a2
1 changed files with 2 additions and 2 deletions

View File

@ -289,8 +289,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 =