You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/02/20 15:12:25 UTC

flink git commit: [hotfix] [doc] Document that the `AsyncCollector` can only be completed once

Repository: flink
Updated Branches:
  refs/heads/master b820fd3ca -> 50fd1a36d


[hotfix] [doc] Document that the `AsyncCollector` can only be completed once


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50fd1a36
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50fd1a36
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/50fd1a36

Branch: refs/heads/master
Commit: 50fd1a36d5eb672f3ebc8c7ecfce36dee8a293cc
Parents: b820fd3
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Feb 20 16:11:17 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Feb 20 16:11:17 2017 +0100

----------------------------------------------------------------------
 docs/dev/stream/asyncio.md | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/50fd1a36/docs/dev/stream/asyncio.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/asyncio.md b/docs/dev/stream/asyncio.md
index abc0b24..dbf2b9c 100644
--- a/docs/dev/stream/asyncio.md
+++ b/docs/dev/stream/asyncio.md
@@ -166,6 +166,9 @@ val resultStream: DataStream[(String, String)] =
 </div>
 </div>
 
+**Important note**: The `AsyncCollector` is completed with the first call of `AsyncCollector.collect`.
+All subsequent `collect` calls will be ignored.
+
 The following two parameters control the asynchronous operations:
 
   - **Timeout**: The timeout defines how long an asynchronous request may take before it is considered failed. This parameter