Skip to content

Commit c3bc374

Browse files
committed
fix ConsumerCoordinatorTest unit test
1 parent 11e8f54 commit c3bc374

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pinot-core/src/test/java/org/apache/pinot/core/data/manager/realtime/ConsumerCoordinatorTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ public FakeRealtimeTableDataManager(Semaphore segmentBuildSemaphore,
4646
boolean useIdealStateToCalculatePreviousSegment) {
4747
super(segmentBuildSemaphore);
4848
super._recentlyDeletedSegments = CacheBuilder.newBuilder().build();
49+
super._tableNameWithType = "testTable";
4950
StreamIngestionConfig streamIngestionConfig = new StreamIngestionConfig(List.of(new HashMap<>()));
5051
streamIngestionConfig.setEnforceConsumptionInOrder(true);
5152
if (useIdealStateToCalculatePreviousSegment) {
@@ -147,7 +148,6 @@ public void testFirstConsumer()
147148
FakeConsumerCoordinator consumerCoordinator = new FakeConsumerCoordinator(true, realtimeTableDataManager);
148149
realtimeTableDataManager.setConsumerCoordinator(consumerCoordinator);
149150
ReentrantLock lock = (ReentrantLock) consumerCoordinator.getLock();
150-
RealtimeSegmentDataManager mockedRealtimeSegmentDataManager = getMockedRealtimeSegmentDataManager();
151151
Map<String, String> serverSegmentStatusMap = new HashMap<>() {{
152152
put("server_1", "ONLINE");
153153
put("server_3", "ONLINE");

0 commit comments

Comments
 (0)