reswqa commented on code in PR #22432:
URL: https://github.com/apache/flink/pull/22432#discussion_r1178600568
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/BroadcastingOutputCollector.java:
##########
@@ -31,12 +32,19 @@
class BroadcastingOutputCollector<T> implements
WatermarkGaugeExposingOutput<StreamRecord<T>> {
+ protected final OutputWithRecordsCountCheck<StreamRecord<T>>[]
outputWithRecordsCountChecks;
protected final Output<StreamRecord<T>>[] outputs;
private final Random random = new XORShiftRandom();
private final WatermarkGauge watermarkGauge = new WatermarkGauge();
+ protected final Counter numRecordsOutForTask;
- public BroadcastingOutputCollector(Output<StreamRecord<T>>[] outputs) {
+ public BroadcastingOutputCollector(
+ OutputWithRecordsCountCheck<StreamRecord<T>>[]
outputWithRecordsCountChecks,
+ Output<StreamRecord<T>>[] outputs,
+ Counter numRecordsOutForTask) {
this.outputs = outputs;
+ this.outputWithRecordsCountChecks = outputWithRecordsCountChecks;
Review Comment:
The reason why `output` is not removed is that some methods are still on the
`Output` interface, such as `emitLatencyMarker`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
