From 87b1831df9135382057b887f58d3f6ebf6e05f6b Mon Sep 17 00:00:00 2001
From: zhangzhengqi3 <zhangzhengqi5@jd.com>
Date: Wed, 28 Apr 2021 10:56:08 +0800
Subject: [PATCH] [FLINK-22438][metrics] Add numRecordsOut metric for Async IO

This closes #15791.
---
 .../flink/streaming/api/operators/async/AsyncWaitOperator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
index ee81685daecc1..e18a225ef4bdc 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
+++ b/flink-streaming-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