[flink] branch master updated: [hotfix] Fix ASCII art in the OperatorChain JavaDoc

[pn...@apache.org]

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

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 91cc308  [hotfix] Fix ASCII art in the OperatorChain JavaDoc
91cc308 is described below

commit 91cc3082c23b38513250d78bbb385271bd223df3
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Thu Feb 11 17:01:07 2021 +0100

    [hotfix] Fix ASCII art in the OperatorChain JavaDoc
---
 .../flink/streaming/runtime/tasks/OperatorChain.java    | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
index 8c59f75..b2f9050 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
@@ -104,10 +104,19 @@ public class OperatorChain<OUT, OP extends StreamOperator<OUT>>
      * <p>Usually first operator in the chain is the same as {@link #mainOperatorWrapper}, but
      * that's not the case if there are chained source inputs. In this case, one of the source
      * inputs will be the first operator. For example the following operator chain is possible:
-     * first \ main (multi-input) -> ... -> tail / second Where "first" and "second" (there can be
-     * more) are chained source operators. When it comes to things like closing, stat initialisation
-     * or state snapshotting, the operator chain is traversed: first, second, main, ..., tail or in
-     * reversed order: tail, ..., main, second, first
+     *
+     * <pre>
+     * first
+     *      \
+     *      main (multi-input) -> ... -> tail
+     *      /
+     * second
+     * </pre>
+     *
+     * <p>Where "first" and "second" (there can be more) are chained source operators. When it comes
+     * to things like closing, stat initialisation or state snapshotting, the operator chain is
+     * traversed: first, second, main, ..., tail or in reversed order: tail, ..., main, second,
+     * first
      */
     @Nullable private final StreamOperatorWrapper<OUT, OP> mainOperatorWrapper;