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