This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 534624039 [doc] Fix comment syntax errors (#4254)
534624039 is described below
commit 5346240398ecf5ec4e1443296c2b24cfef0aceff
Author: dongsj <[email protected]>
AuthorDate: Thu Sep 26 13:29:06 2024 +0800
[doc] Fix comment syntax errors (#4254)
---
.../main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java
index 4db56601a..541041304 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java
@@ -89,8 +89,8 @@ public class RangeShuffle {
*
-----------------------------BATCH-[ARange,n]-PARTITION->[RRange,m]->
* }</pre>
*
- * <p>The streams except the sample and histogram process stream will been
blocked, so the the
- * sample and histogram process stream does not care about
requiredExchangeMode.
+ * <p>The streams except the sample and histogram process stream will be
blocked, so the sample
+ * and histogram process stream does not care about requiredExchangeMode.
*/
public static <T> DataStream<Tuple2<T, RowData>> rangeShuffleByKey(
DataStream<Tuple2<T, RowData>> inputDataStream,
@@ -324,8 +324,8 @@ public class RangeShuffle {
}
/**
- * This two-input-operator require a input with RangeBoundaries as
broadcast input, and generate
- * Tuple2 which includes range index and record from the other input
itself as output.
+ * This two-input-operator require an input with RangeBoundaries as
broadcast input, and
+ * generate Tuple2 which includes range index and record from the other
input itself as output.
*/
private static class AssignRangeIndexOperator<T>
extends TableStreamOperator<Tuple2<Integer, Tuple2<T, RowData>>>
