Repository: flink Updated Branches: refs/heads/release-1.3 4ff1f439e -> a390cee33
[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 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a390cee3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a390cee3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a390cee3 Branch: refs/heads/release-1.3 Commit: a390cee333f4bf8f76609cccb7b68883dc2454d8 Parents: 4ff1f43 Author: Nico Kruber <[email protected]> Authored: Wed May 31 14:53:26 2017 +0200 Committer: zentol <[email protected]> Committed: Thu Jun 1 13:45:08 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/a390cee3/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);
