Dear all,
QueryableStateClient class is modified a little in the latest flink release
(1.3.1), and I'm having difficulty to understand some of the options. Can
someone explain the below options?
1. How do I set the below options in QueryableStateClient ?
- query.client.network-threads
- query.client.lookup.num-retries
- query.client.lookup.retry-delay
2.
final HighAvailabilityServices highAvailabilityServices =
HighAvailabilityServicesUtils.createHighAvailabilityServices(
config,
Executors.newSingleThreadScheduledExecutor(),
HighAvailabilityServicesUtils.AddressResolution.TRY_ADDRESS_RESOLUTION);
QueryableStateClient client = new QueryableStateClient(config,
highAvailabilityServices);
How does specifying an Executor here works with the server
configuration 'query.server.network-threads'
?
Thanks in advance
Best
Ziyad
