Repository: flink Updated Branches: refs/heads/release-1.2 e3e3c2a7f -> 21777fdd7
[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/21777fdd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/21777fdd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/21777fdd Branch: refs/heads/release-1.2 Commit: 21777fdd734a475767d4685c7bb5124c4aebe586 Parents: e3e3c2a Author: Till Rohrmann <[email protected]> Authored: Mon Feb 20 16:11:17 2017 +0100 Committer: Till Rohrmann <[email protected]> Committed: Mon Feb 20 16:13:02 2017 +0100 ---------------------------------------------------------------------- docs/dev/stream/asyncio.md | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/21777fdd/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
