From 8364a2bec8b3c4fb08413df27a07b1637852db27 Mon Sep 17 00:00:00 2001
From: Youssef-Khogaly <yossefibrahem8@gmail.com>
Date: Sat, 28 Feb 2026 08:47:22 +0200
Subject: [PATCH] remove unused size variable , getMeasuredCardinality() method
 always delegated to the parent class

---
 .../org/apache/wayang/flink/channels/DataStreamChannel.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataStreamChannel.java b/wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataStreamChannel.java
index 7ed041a19..e39a1a384 100644
--- a/wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataStreamChannel.java
+++ b/wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataStreamChannel.java
@@ -39,8 +39,6 @@ public class Instance extends AbstractChannelInstance {
 
         private DataStream<?> dataStream;
 
-        // TODO: this.size is currently always 0
-        private long size;
 
         public Instance(final FlinkExecutor executor,
                 final OptimizationContext.OperatorContext producerOperatorContext,
@@ -59,7 +57,7 @@ public <T> DataStream<T> provideDataStream() {
 
         @Override
         public OptionalLong getMeasuredCardinality() {
-            return this.size == 0 ? super.getMeasuredCardinality() : OptionalLong.of(this.size);
+            return super.getMeasuredCardinality();
         }
 
         @Override