You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/02/19 14:08:13 UTC
[20/35] flink git commit: [hotfix][java-docs] Improve
ResultSubpartition java doc
[hotfix][java-docs] Improve ResultSubpartition java doc
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3eb4cc07
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3eb4cc07
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3eb4cc07
Branch: refs/heads/master
Commit: 3eb4cc07ba6a81a733b6466f2e5ae56ab80a6a55
Parents: 91dc1c9
Author: Piotr Nowojski <pi...@gmail.com>
Authored: Thu Jan 25 15:31:01 2018 +0100
Committer: Piotr Nowojski <pi...@gmail.com>
Committed: Mon Feb 19 12:21:30 2018 +0100
----------------------------------------------------------------------
.../flink/runtime/io/network/partition/ResultSubpartition.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3eb4cc07/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
index 7b7b101..572cde7 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
@@ -95,7 +95,7 @@ public abstract class ResultSubpartition {
*
* @param bufferConsumer
* the buffer to add (transferring ownership to this writer)
- *
+ * @return true if operation succeeded and bufferConsumer was enqueued for consumption.
* @throws IOException
* thrown in case of errors while adding the buffer
*/