Repository: flink Updated Branches: refs/heads/master fa11845b9 -> 2d741d0ca
[FLINK-6570] update queryable state documentation * adapt a left-over "QueryableStateClient client = new QueryableStateClient(config);" * remove use of TestingUtils as it is only available to Flink tests This closes #4028. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d741d0c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2d741d0c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2d741d0c Branch: refs/heads/master Commit: 2d741d0caabc325d0b0e96ffd47eae5609883c1d Parents: fa11845 Author: Nico Kruber <n...@data-artisans.com> Authored: Wed May 31 14:53:26 2017 +0200 Committer: zentol <ches...@apache.org> Committed: Thu Jun 1 13:43:29 2017 +0200 ---------------------------------------------------------------------- docs/dev/stream/queryable_state.md | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2d741d0c/docs/dev/stream/queryable_state.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/queryable_state.md b/docs/dev/stream/queryable_state.md index ceb5f76..234be51 100644 --- a/docs/dev/stream/queryable_state.md +++ b/docs/dev/stream/queryable_state.md @@ -135,7 +135,13 @@ final Configuration config = new Configuration(); config.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, queryAddress); config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, queryPort); -QueryableStateClient client = new QueryableStateClient(config); +final HighAvailabilityServices highAvailabilityServices = + HighAvailabilityServicesUtils.createHighAvailabilityServices( + config, + Executors.newSingleThreadScheduledExecutor(), + HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION); + +QueryableStateClient client = new QueryableStateClient(config, highAvailabilityServices); {% endhighlight %} The query method is this: @@ -214,7 +220,7 @@ config.setInteger(JobManagerOptions.PORT, queryPort); final HighAvailabilityServices highAvailabilityServices = HighAvailabilityServicesUtils.createHighAvailabilityServices( config, - TestingUtils.defaultExecutor(), + Executors.newSingleThreadScheduledExecutor(), HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION); QueryableStateClient client = new QueryableStateClient(config, highAvailabilityServices);