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 <[email protected]> Authored: Mon Feb 20 16:11:17 2017 +0100 Committer: Till Rohrmann <[email protected]> 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
