diff --git a/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCollectOperator.java b/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCollectOperator.java
index 10ddfa6df..9c5a0887e 100644
--- a/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCollectOperator.java
+++ b/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCollectOperator.java
@@ -58,7 +58,7 @@ public Tuple<Collection<ExecutionLineageNode>, Collection<ChannelInstance>> eval
         final StreamChannel.Instance streamChannelInstance = (StreamChannel.Instance) inputs[0];
         final CollectionChannel.Instance collectionChannelInstance = (CollectionChannel.Instance) outputs[0];
 
-        final List<?> collection = streamChannelInstance.provideStream().collect(Collectors.toList());
+        final List<?> collection = streamChannelInstance.provideStream().toList();
         collectionChannelInstance.accept(collection);
 
         return ExecutionOperator.modelEagerExecution(inputs, outputs, operatorContext);