From 12d9936228c372333a254075babd747b28549abb Mon Sep 17 00:00:00 2001 From: PoAn Yang Date: Fri, 10 Jan 2025 15:58:07 +0800 Subject: [PATCH] HOTFIX: fix failed case RemoteLogManagerTest#testStopPartitionsWithDeletion Signed-off-by: PoAn Yang --- core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java b/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java index 4e8a320635221..166e58f92175d 100644 --- a/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java +++ b/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java @@ -2150,9 +2150,9 @@ public void testStopPartitionsWithDeletion() throws RemoteStorageException { partitions.add(new StopPartition(followerTopicIdPartition.topicPartition(), true, true, true)); when(remoteLogMetadataManager.listRemoteLogSegments(eq(leaderTopicIdPartition))) - .thenReturn(listRemoteLogSegmentMetadata(leaderTopicIdPartition, 5, 100, 1024, RemoteLogSegmentState.DELETE_SEGMENT_FINISHED).iterator()); + .thenAnswer(invocation -> listRemoteLogSegmentMetadata(leaderTopicIdPartition, 5, 100, 1024, RemoteLogSegmentState.DELETE_SEGMENT_FINISHED).iterator()); when(remoteLogMetadataManager.listRemoteLogSegments(eq(followerTopicIdPartition))) - .thenReturn(listRemoteLogSegmentMetadata(followerTopicIdPartition, 3, 100, 1024, RemoteLogSegmentState.DELETE_SEGMENT_FINISHED).iterator()); + .thenAnswer(invocation -> listRemoteLogSegmentMetadata(followerTopicIdPartition, 3, 100, 1024, RemoteLogSegmentState.DELETE_SEGMENT_FINISHED).iterator()); CompletableFuture dummyFuture = new CompletableFuture<>(); dummyFuture.complete(null); when(remoteLogMetadataManager.updateRemoteLogSegmentMetadata(any()))