Repository: flink Updated Branches: refs/heads/release-1.3 8b5ba676f -> a30a8be98
[FLINK-6570] QueryableStateClient docs with matching constructor signature This closes #3926. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a30a8be9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a30a8be9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a30a8be9 Branch: refs/heads/release-1.3 Commit: a30a8be98c4a7416e4621c48e961dd8a802b56b4 Parents: 8b5ba67 Author: gosubpl <[email protected]> Authored: Wed May 17 02:03:45 2017 +0200 Committer: Till Rohrmann <[email protected]> Committed: Thu May 18 09:55:45 2017 +0200 ---------------------------------------------------------------------- docs/dev/stream/queryable_state.md | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a30a8be9/docs/dev/stream/queryable_state.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/queryable_state.md b/docs/dev/stream/queryable_state.md index 62d6a33..ceb5f76 100644 --- a/docs/dev/stream/queryable_state.md +++ b/docs/dev/stream/queryable_state.md @@ -208,10 +208,16 @@ Once used in a job, you can retrieve the job ID and then query any key's current {% highlight java %} final Configuration config = new Configuration(); -config.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, queryAddress); -config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, queryPort); +config.setString(JobManagerOptions.ADDRESS, queryAddress); +config.setInteger(JobManagerOptions.PORT, queryPort); -QueryableStateClient client = new QueryableStateClient(config); +final HighAvailabilityServices highAvailabilityServices = + HighAvailabilityServicesUtils.createHighAvailabilityServices( + config, + TestingUtils.defaultExecutor(), + HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION); + +QueryableStateClient client = new QueryableStateClient(config, highAvailabilityServices); final TypeSerializer<Long> keySerializer = TypeInformation.of(new TypeHint<Long>() {}).createSerializer(new ExecutionConfig());
