rkhachatryan commented on a change in pull request #13234:
URL: https://github.com/apache/flink/pull/13234#discussion_r482281944
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
##########
@@ -90,16 +91,19 @@
private final RecordWriterOutput<?>[] streamOutputs;
- private final WatermarkGaugeExposingOutput<StreamRecord<OUT>>
chainEntryPoint;
+ private final WatermarkGaugeExposingOutput<StreamRecord<OUT>>
mainOperatorOutput;
/**
* For iteration, {@link StreamIterationHead} and {@link
StreamIterationTail} used for executing
- * feedback edges do not contain any operators, in which case, {@code
headOperatorWrapper} and
+ * feedback edges do not contain any operators, in which case, {@code
mainOperatorWrapper} and
* {@code tailOperatorWrapper} are null.
*/
- @Nullable private final StreamOperatorWrapper<OUT, OP>
headOperatorWrapper;
+ @Nullable private final StreamOperatorWrapper<OUT, OP>
mainOperatorWrapper;
+ @Nullable private final StreamOperatorWrapper<?, ?>
firstOperatorWrapper;
Review comment:
Thanks!
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
