diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedQueue.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedQueue.java
index d8af9e64bd..5f69fde87b 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedQueue.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedQueue.java
@@ -91,7 +91,7 @@ public class DefaultDistributedQueue<E>  implements DistributedQueue<E> {
                        .whenComplete((r, e) -> timer.stop(e))
                        .thenCompose(v -> {
                            if (v != null) {
-                               return CompletableFuture.completedFuture(serializer.decode(v));
+                               return CompletableFuture.<E>completedFuture(serializer.decode(v));
                            }
                            CompletableFuture<E> newPendingFuture = new CompletableFuture<>();
                            pendingFutures.add(newPendingFuture);