flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [FLINK-6570] QueryableStateClient docs with matching constructor signature
Date Thu, 18 May 2017 07:55:26 GMT
Repository: flink
Updated Branches:
  refs/heads/master d8a467b01 -> 85e281be3


[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/85e281be
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85e281be
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/85e281be

Branch: refs/heads/master
Commit: 85e281be3835fe8bb0a5bcaede072e5f26b7f087
Parents: d8a467b
Author: gosubpl <github@gosub.pl>
Authored: Wed May 17 02:03:45 2017 +0200
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Thu May 18 09:55:09 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/85e281be/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());


Mime
View raw message