[FLINK-22438][metrics] Add numRecordsOut metric for Async IO

This closes #15791.
apache · Apr 29, 2021 · 87b1831 · 87b1831
1 parent 6a0d44d
commit 87b1831
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java b/...-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
@@ -154,7 +154,7 @@ public void setup(
                 throw new IllegalStateException("Unknown async mode: " + outputMode + '.');
         }
 
-        this.timestampedCollector = new TimestampedCollector<>(output);
+        this.timestampedCollector = new TimestampedCollector<>(super.output);
     }
 
     @Override