Skip to content

Commit 53d0976

Browse files
committed
fix broken embedded tests
1 parent ef93c44 commit 53d0976

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

services/src/test/java/org/apache/druid/testing/embedded/EmbeddedClusterApis.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,8 +52,8 @@
5252

5353
import java.io.Closeable;
5454
import java.util.ArrayList;
55-
import java.util.Collection;
5655
import java.util.Comparator;
56+
import java.util.Iterator;
5757
import java.util.List;
5858
import java.util.Map;
5959
import java.util.Objects;
@@ -236,7 +236,7 @@ public TaskStatus waitForTaskToFinish(String taskId, LatchableEmitter emitter)
236236
*/
237237
public int getTaskCount(String status, String dataSource)
238238
{
239-
return ImmutableList.copyOf((Collection<?>) onLeaderOverlord(o -> o.taskStatuses(status, dataSource, 100))).size();
239+
return ImmutableList.copyOf((Iterator<?>) onLeaderOverlord(o -> o.taskStatuses(status, dataSource, 100))).size();
240240
}
241241

242242
/**

0 commit comments

Comments
 (0)