From e6474835a469c5feb13712bf3d49203f38f74b96 Mon Sep 17 00:00:00 2001 From: Zoi Kaoudi Date: Tue, 17 Feb 2026 09:49:57 +0100 Subject: [PATCH] update to return an immutable list based on newer Java version --- .../org/apache/wayang/java/operators/JavaCollectOperator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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> 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);