[flink] branch release-1.13 updated: [FLINK-22438][metrics] Add numRecordsOut metric for Async IO

[trohrmann]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 87b1831  [FLINK-22438][metrics] Add numRecordsOut metric for Async IO
87b1831 is described below

commit 87b1831df9135382057b887f58d3f6ebf6e05f6b
Author: zhangzhengqi3 <zhangzheng...@jd.com>
AuthorDate: Wed Apr 28 10:56:08 2021 +0800

    [FLINK-22438][metrics] Add numRecordsOut metric for Async IO
    
    This closes #15791.
---
 .../apache/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 ee81685..e18a225 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 class AsyncWaitOperator<IN, OUT>
                 throw new IllegalStateException("Unknown async mode: " + 
outputMode + '.');
         }
 
-        this.timestampedCollector = new TimestampedCollector<>(output);
+        this.timestampedCollector = new TimestampedCollector<>(super.output);
     }
 
     @Override