Skip to content
Permalink
Browse files
[FLINK-22438][metrics] Add numRecordsOut metric for Async IO
This closes #15791.
  • Loading branch information
zhangzhengqi3 authored and tillrohrmann committed Apr 29, 2021
1 parent c593209 commit 56c61dd58b26596331575cac85812d36b3c4a383
Showing 1 changed file with 1 addition and 1 deletion.
@@ -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

0 comments on commit 56c61dd

Please sign in to comment.