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 362e08ea69
commit c4f546041e
1 changed files with 2 additions and 2 deletions

View File

@ -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 =