GitHub user kkrugler opened a pull request:
https://github.com/apache/flink/pull/5848
Minor cleanup of Java example code for AsyncFunctions
Use `CompletableFuture` correctly, via `.supplyAsync()` wrapping
`Future.get()`
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kkrugler/flink
kkrugler_completablefuture-asyncio-doc
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5848.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #5848
----
commit a10756a40791cd4729e27c11d31a5f10330caf99
Author: Ken Krugler <ken@...>
Date: 2018-04-14T19:57:22Z
Add new flink-batch-connectors
commit 26fcfffe95e12cec48e84ec91a2c738f6995d772
Author: Ken Krugler <ken@...>
Date: 2018-04-14T20:00:32Z
Fix use of Future in Java doc
commit 257304528d3a87aee4672beeebc9db5ba44fdd0f
Author: Ken Krugler <ken@...>
Date: 2018-04-14T20:06:16Z
Remove accidentally added files that are generated
----
---