pnowojski commented on a change in pull request #13234:
URL: https://github.com/apache/flink/pull/13234#discussion_r478510256
##########
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:
Nope. Main operator is as explained in the java doc above. First
operator can be either it, or some chained source operator (if present) - added
a java doc with this explanation.
----------------------------------------------------------------
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]
