eaglewatcherwb closed pull request #7461: [FLINK-11295][configuration] Rename
configuration options of queryable-state from query.x to queryable-state.x
URL: https://github.com/apache/flink/pull/7461
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/docs/_includes/generated/queryable_state_configuration.html
b/docs/_includes/generated/queryable_state_configuration.html
index 5940fdc82299..91eaf912a0ce 100644
--- a/docs/_includes/generated/queryable_state_configuration.html
+++ b/docs/_includes/generated/queryable_state_configuration.html
@@ -8,44 +8,44 @@
</thead>
<tbody>
<tr>
- <td><h5>query.client.network-threads</h5></td>
+ <td><h5>queryable-state.client.network-threads</h5></td>
<td style="word-wrap: break-word;">0</td>
<td>Number of network (Netty's event loop) Threads for queryable
state client.</td>
</tr>
<tr>
- <td><h5>query.proxy.network-threads</h5></td>
+ <td><h5>queryable-state.enable</h5></td>
+ <td style="word-wrap: break-word;">false</td>
+ <td>Option whether the queryable state proxy and server should be
enabled where possible and configurable.</td>
+ </tr>
+ <tr>
+ <td><h5>queryable-state.proxy.network-threads</h5></td>
<td style="word-wrap: break-word;">0</td>
<td>Number of network (Netty's event loop) Threads for queryable
state proxy.</td>
</tr>
<tr>
- <td><h5>query.proxy.ports</h5></td>
+ <td><h5>queryable-state.proxy.ports</h5></td>
<td style="word-wrap: break-word;">"9069"</td>
<td>The port range of the queryable state proxy. The specified
range can be a single port: "9123", a range of ports: "50100-50200", or a list
of ranges and ports: "50100-50200,50300-50400,51234".</td>
</tr>
<tr>
- <td><h5>query.proxy.query-threads</h5></td>
+ <td><h5>queryable-state.proxy.query-threads</h5></td>
<td style="word-wrap: break-word;">0</td>
<td>Number of query Threads for queryable state proxy. Uses the
number of slots if set to 0.</td>
</tr>
<tr>
- <td><h5>query.server.network-threads</h5></td>
+ <td><h5>queryable-state.server.network-threads</h5></td>
<td style="word-wrap: break-word;">0</td>
<td>Number of network (Netty's event loop) Threads for queryable
state server.</td>
</tr>
<tr>
- <td><h5>query.server.ports</h5></td>
+ <td><h5>queryable-state.server.ports</h5></td>
<td style="word-wrap: break-word;">"9067"</td>
<td>The port range of the queryable state server. The specified
range can be a single port: "9123", a range of ports: "50100-50200", or a list
of ranges and ports: "50100-50200,50300-50400,51234".</td>
</tr>
<tr>
- <td><h5>query.server.query-threads</h5></td>
+ <td><h5>queryable-state.server.query-threads</h5></td>
<td style="word-wrap: break-word;">0</td>
<td>Number of query Threads for queryable state server. Uses the
number of slots if set to 0.</td>
</tr>
- <tr>
- <td><h5>queryable-state.enable</h5></td>
- <td style="word-wrap: break-word;">false</td>
- <td>Option whether the queryable state proxy and server should be
enabled where possible and configurable.</td>
- </tr>
</tbody>
</table>
diff --git
a/flink-core/src/main/java/org/apache/flink/configuration/QueryableStateOptions.java
b/flink-core/src/main/java/org/apache/flink/configuration/QueryableStateOptions.java
index 20c6b53a2090..253d4f391b1f 100644
---
a/flink-core/src/main/java/org/apache/flink/configuration/QueryableStateOptions.java
+++
b/flink-core/src/main/java/org/apache/flink/configuration/QueryableStateOptions.java
@@ -51,23 +51,26 @@
* <p><b>The default port is 9069.</b>
*/
public static final ConfigOption<String> PROXY_PORT_RANGE =
- key("query.proxy.ports")
+ key("queryable-state.proxy.ports")
.defaultValue("9069")
.withDescription("The port range of the queryable state
proxy. The specified range can be a single " +
"port: \"9123\", a range of ports:
\"50100-50200\", " +
- "or a list of ranges and ports:
\"50100-50200,50300-50400,51234\".");
+ "or a list of ranges and ports:
\"50100-50200,50300-50400,51234\".")
+ .withDeprecatedKeys("query.proxy.ports");
/** Number of network (event loop) threads for the client proxy (0 =>
#slots). */
public static final ConfigOption<Integer> PROXY_NETWORK_THREADS =
- key("query.proxy.network-threads")
+ key("queryable-state.proxy.network-threads")
.defaultValue(0)
- .withDescription("Number of network (Netty's event
loop) Threads for queryable state proxy.");
+ .withDescription("Number of network (Netty's event
loop) Threads for queryable state proxy.")
+ .withDeprecatedKeys("query.proxy.network-threads");
/** Number of async query threads for the client proxy (0 => #slots). */
public static final ConfigOption<Integer> PROXY_ASYNC_QUERY_THREADS =
- key("query.proxy.query-threads")
+ key("queryable-state.proxy.query-threads")
.defaultValue(0)
- .withDescription("Number of query Threads for queryable
state proxy. Uses the number of slots if set to 0.");
+ .withDescription("Number of query Threads for queryable
state proxy. Uses the number of slots if set to 0.")
+ .withDeprecatedKeys("query.proxy.query-threads");
/**
* The config parameter defining the server port range of the queryable
state server.
@@ -88,23 +91,26 @@
* <p><b>The default port is 9067.</b>
*/
public static final ConfigOption<String> SERVER_PORT_RANGE =
- key("query.server.ports")
+ key("queryable-state.server.ports")
.defaultValue("9067")
.withDescription("The port range of the queryable state
server. The specified range can be a single " +
"port: \"9123\", a range of ports:
\"50100-50200\", " +
- "or a list of ranges and ports:
\"50100-50200,50300-50400,51234\".");
+ "or a list of ranges and ports:
\"50100-50200,50300-50400,51234\".")
+ .withDeprecatedKeys("query.server.ports");
/** Number of network (event loop) threads for the KvState server (0 =>
#slots). */
public static final ConfigOption<Integer> SERVER_NETWORK_THREADS =
- key("query.server.network-threads")
+ key("queryable-state.server.network-threads")
.defaultValue(0)
- .withDescription("Number of network (Netty's event
loop) Threads for queryable state server.");
+ .withDescription("Number of network (Netty's event
loop) Threads for queryable state server.")
+ .withDeprecatedKeys("query.server.network-threads");
/** Number of async query threads for the KvStateServerHandler (0 =>
#slots). */
public static final ConfigOption<Integer> SERVER_ASYNC_QUERY_THREADS =
- key("query.server.query-threads")
+ key("queryable-state.server.query-threads")
.defaultValue(0)
- .withDescription("Number of query Threads for queryable
state server. Uses the number of slots if set to 0.");
+ .withDescription("Number of query Threads for queryable
state server. Uses the number of slots if set to 0.")
+ .withDeprecatedKeys("query.server.query-threads");
/** Option whether the queryable state proxy and server should be
enabled where possible and configurable.
*
@@ -122,9 +128,10 @@
/** Number of network (event loop) threads for the KvState client (0 =>
Use number of available cores). */
public static final ConfigOption<Integer> CLIENT_NETWORK_THREADS =
- key("query.client.network-threads")
+ key("queryable-state.client.network-threads")
.defaultValue(0)
- .withDescription("Number of network (Netty's event
loop) Threads for queryable state client.");
+ .withDescription("Number of network (Netty's event
loop) Threads for queryable state client.")
+ .withDeprecatedKeys("query.client.network-threads");
//
------------------------------------------------------------------------
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
