MartijnVisser commented on a change in pull request #17463:
URL: https://github.com/apache/flink/pull/17463#discussion_r755184904
##########
File path:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGenerator.java
##########
@@ -34,6 +34,6 @@
*/
default void open() {}
- /** Generate index name according the the given row. */
+ /** Generate index name according the given row. */
Review comment:
```suggestion
/** Generate index name according to the given row. */
```
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ResultPartitionWriter.java
##########
@@ -38,7 +38,7 @@
* ResultPartitionWriter#fail(Throwable)} or {@link
ResultPartitionWriter#finish()}, it abruptly
* triggers failure and cancellation of production. In this case {@link
* ResultPartitionWriter#fail(Throwable)} still needs to be called afterwards
to fully release all
- * resources associated the the partition and propagate failure cause to the
consumer if possible.
+ * resources associated the partition and propagate failure cause to the
consumer if possible.
Review comment:
```suggestion
* resources associated with the partition and propagate failure cause to
the consumer if possible.
```
##########
File path:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGenerator.java
##########
@@ -33,6 +33,6 @@
*/
default void open() {}
- /** Generate index name according the the given row. */
+ /** Generate index name according the given row. */
Review comment:
```suggestion
/** Generate index name according to the given row. */
```
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/MergingWindowSet.java
##########
@@ -145,8 +145,8 @@ public void retireWindow(W window) {
*
* @param newWindow The new {@code Window} to add.
* @param mergeFunction The callback to be invoked in case a merge occurs.
- * @return The {@code Window} that new new {@code Window} ended up in.
This can also be the the
- * new {@code Window} itself in case no merge occurred.
+ * @return The {@code Window} that new new {@code Window} ended up in.
This can also be the new
+ * {@code Window} itself in case no merge occurred.
Review comment:
```suggestion
* @return The {@code Window} that new {@code Window} ended up in. This
can also be the new
* {@code Window} itself in case no merge occurred.
```
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
