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