This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 398f464f201e3a16e9a14daf2fcf0687dc2c6cc1 Author: Nico Kruber <[email protected]> AuthorDate: Thu Aug 2 15:14:47 2018 +0200 [hotfix][checkstyle] fix comments in SingleInputGate --- .../runtime/io/network/partition/consumer/SingleInputGate.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java index b6380af..dbef46f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java @@ -62,10 +62,10 @@ import static org.apache.flink.util.Preconditions.checkState; /** * An input gate consumes one or more partitions of a single produced intermediate result. * - * <p> Each intermediate result is partitioned over its producing parallel subtasks; each of these + * <p>Each intermediate result is partitioned over its producing parallel subtasks; each of these * partitions is furthermore partitioned into one or more subpartitions. * - * <p> As an example, consider a map-reduce program, where the map operator produces data and the + * <p>As an example, consider a map-reduce program, where the map operator produces data and the * reduce operator consumes the produced data. * * <pre>{@code @@ -74,7 +74,7 @@ import static org.apache.flink.util.Preconditions.checkState; * +-----+ +---------------------+ +--------+ * }</pre> * - * <p> When deploying such a program in parallel, the intermediate result will be partitioned over its + * <p>When deploying such a program in parallel, the intermediate result will be partitioned over its * producing parallel subtasks; each of these partitions is furthermore partitioned into one or more * subpartitions. * @@ -95,7 +95,7 @@ import static org.apache.flink.util.Preconditions.checkState; * +-----------------------------------------+ * }</pre> * - * <p> In the above example, two map subtasks produce the intermediate result in parallel, resulting + * <p>In the above example, two map subtasks produce the intermediate result in parallel, resulting * in two partitions (Partition 1 and 2). Each of these partitions is further partitioned into two * subpartitions -- one for each parallel reduce subtask. */
