flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [FLINK-6570] update queryable state documentation
Date Thu, 01 Jun 2017 11:45:35 GMT
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 <nico@data-artisans.com>
Authored: Wed May 31 14:53:26 2017 +0200
Committer: zentol <chesnay@apache.org>
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);


Mime
View raw message