You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/05/10 11:53:10 UTC
flink git commit: [FLINK-9317][docs] Fix variable name in scala Async
I/O API Example
Repository: flink
Updated Branches:
refs/heads/release-1.4 910d9d44c -> 695b95a6d
[FLINK-9317][docs] Fix variable name in scala Async I/O API Example
This closes #5968.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/695b95a6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/695b95a6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/695b95a6
Branch: refs/heads/release-1.4
Commit: 695b95a6dfbee8a707b155e187a49467538e931f
Parents: 910d9d4
Author: Yazdan.JS <y_...@yahoo.com>
Authored: Wed May 9 01:47:34 2018 -0400
Committer: zentol <ch...@apache.org>
Committed: Thu May 10 13:53:06 2018 +0200
----------------------------------------------------------------------
docs/dev/stream/operators/asyncio.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/695b95a6/docs/dev/stream/operators/asyncio.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/operators/asyncio.md b/docs/dev/stream/operators/asyncio.md
index 702d2ae..37148a2 100644
--- a/docs/dev/stream/operators/asyncio.md
+++ b/docs/dev/stream/operators/asyncio.md
@@ -145,11 +145,11 @@ class AsyncDatabaseRequest extends AsyncFunction[String, (String, String)] {
override def asyncInvoke(str: String, resultFuture: ResultFuture[(String, String)]): Unit = {
// issue the asynchronous request, receive a future for the result
- val resultFuture: Future[String] = client.query(str)
+ val resultFutureRequested: Future[String] = client.query(str)
// set the callback to be executed once the request by the client is complete
// the callback simply forwards the result to the result future
- resultFuture.onSuccess {
+ resultFutureRequested.onSuccess {
case result: String => resultFuture.complete(Iterable((str, result)))
}
}