You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/09/05 20:23:48 UTC
[flink] branch master updated: [hotfix][streaming] Remove redundant
word in javadocs
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 200d86b [hotfix][streaming] Remove redundant word in javadocs
200d86b is described below
commit 200d86b469cece1035fb8d28d6931aab1669e7ba
Author: Jun Zhang <zh...@163.com>
AuthorDate: Thu Sep 6 04:23:43 2018 +0800
[hotfix][streaming] Remove redundant word in javadocs
---
.../flink/streaming/api/functions/source/ParallelSourceFunction.java | 2 +-
.../streaming/api/functions/source/RichParallelSourceFunction.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.java
index d3ad0f9..591ebcce 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.java
@@ -21,7 +21,7 @@ import org.apache.flink.annotation.Public;
/**
* A stream data source that is executed in parallel. Upon execution, the runtime will
- * execute as many parallel instances of this function function as configured parallelism
+ * execute as many parallel instances of this function as configured parallelism
* of the source.
*
* <p>This interface acts only as a marker to tell the system that this source may
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java
index 94b85b6..46c1443 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java
@@ -22,7 +22,7 @@ import org.apache.flink.api.common.functions.AbstractRichFunction;
/**
* Base class for implementing a parallel data source. Upon execution, the runtime will
- * execute as many parallel instances of this function function as configured parallelism
+ * execute as many parallel instances of this function as configured parallelism
* of the source.
*
* <p>The data source has access to context information (such as the number of parallel