diff --git a/service/common/src/main/java/org/apache/polaris/service/events/TestPolarisEventListener.java b/service/common/src/main/java/org/apache/polaris/service/events/TestPolarisEventListener.java index 668edc7fa0..2e2538e890 100644 --- a/service/common/src/main/java/org/apache/polaris/service/events/TestPolarisEventListener.java +++ b/service/common/src/main/java/org/apache/polaris/service/events/TestPolarisEventListener.java @@ -31,7 +31,8 @@ public class TestPolarisEventListener extends PolarisEventListener { private final List history = new ArrayList<>(); public T getLatest(Class type) { - return (T) Streams.findLast(history.stream().filter(type::isInstance)).orElseThrow(); + return (T) + Streams.findLast(history.stream().filter(type::isInstance)).map(type::cast).orElseThrow(); } @Override