Skip to content

Commit

Permalink
[FLINK-33204][doc] Add JM/TM bind-adddress and RPC bind-port to relev…
Browse files Browse the repository at this point in the history
…ant sections in documentation.

This closes #23493
  • Loading branch information
X-czh authored and xintongsong committed Oct 9, 2023
1 parent d652238 commit 011b6b4
Show file tree
Hide file tree
Showing 5 changed files with 64 additions and 0 deletions.
12 changes: 12 additions & 0 deletions docs/layouts/shortcodes/generated/all_jobmanager_section.html
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,12 @@
<td>String</td>
<td>Directory for JobManager to store the archives of completed jobs.</td>
</tr>
<tr>
<td><h5>jobmanager.bind-host</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>The local address of the network interface that the job manager binds to. If not configured, '0.0.0.0' will be used.</td>
</tr>
<tr>
<td><h5>jobmanager.execution.attempts-history-size</h5></td>
<td style="word-wrap: break-word;">16</td>
Expand Down Expand Up @@ -86,6 +92,12 @@
<td>String</td>
<td>The config parameter defining the network address to connect to for communication with the job manager. This value is only interpreted in setups where a single JobManager with static name or address exists (simple standalone setups, or container setups with dynamic service name resolution). It is not used in many high-availability setups, when a leader-election service (like ZooKeeper) is used to elect and discover the JobManager leader from potentially multiple standby JobManagers.</td>
</tr>
<tr>
<td><h5>jobmanager.rpc.bind-port</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Integer</td>
<td>The local RPC port that the JobManager binds to. If not configured, the external port (configured by 'jobmanager.rpc.port') will be used.</td>
</tr>
<tr>
<td><h5>jobmanager.rpc.port</h5></td>
<td style="word-wrap: break-word;">6123</td>
Expand Down
12 changes: 12 additions & 0 deletions docs/layouts/shortcodes/generated/all_taskmanager_section.html
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,12 @@
<td>Long</td>
<td>Time we wait for the timers in milliseconds to finish all pending timer threads when the stream task is cancelled.</td>
</tr>
<tr>
<td><h5>taskmanager.bind-host</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>The local address of the network interface that the task manager binds to. If not configured, '0.0.0.0' will be used.</td>
</tr>
<tr>
<td><h5>taskmanager.data.bind-port</h5></td>
<td style="word-wrap: break-word;">(none)</td>
Expand Down Expand Up @@ -105,6 +111,12 @@
<td>String</td>
<td>The TaskManager's ResourceID. If not configured, the ResourceID will be generated with the "RpcAddress:RpcPort" and a 6-character random string. Notice that this option is not valid in Yarn and Native Kubernetes mode.</td>
</tr>
<tr>
<td><h5>taskmanager.rpc.bind-port</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Integer</td>
<td>The local RPC port that the TaskManager binds to. If not configured, the external port (configured by 'taskmanager.rpc.port') will be used.</td>
</tr>
<tr>
<td><h5>taskmanager.rpc.port</h5></td>
<td style="word-wrap: break-word;">"0"</td>
Expand Down
24 changes: 24 additions & 0 deletions docs/layouts/shortcodes/generated/common_host_port_section.html
Original file line number Diff line number Diff line change
Expand Up @@ -8,12 +8,24 @@
</tr>
</thead>
<tbody>
<tr>
<td><h5>jobmanager.bind-host</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>The local address of the network interface that the job manager binds to. If not configured, '0.0.0.0' will be used.</td>
</tr>
<tr>
<td><h5>jobmanager.rpc.address</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>The config parameter defining the network address to connect to for communication with the job manager. This value is only interpreted in setups where a single JobManager with static name or address exists (simple standalone setups, or container setups with dynamic service name resolution). It is not used in many high-availability setups, when a leader-election service (like ZooKeeper) is used to elect and discover the JobManager leader from potentially multiple standby JobManagers.</td>
</tr>
<tr>
<td><h5>jobmanager.rpc.bind-port</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Integer</td>
<td>The local RPC port that the JobManager binds to. If not configured, the external port (configured by 'jobmanager.rpc.port') will be used.</td>
</tr>
<tr>
<td><h5>jobmanager.rpc.port</h5></td>
<td style="word-wrap: break-word;">6123</td>
Expand Down Expand Up @@ -56,6 +68,12 @@
<td>Integer</td>
<td>The port that the client connects to. If rest.bind-port has not been specified, then the REST server will bind to this port. Attention: This option is respected only if the high-availability configuration is NONE.</td>
</tr>
<tr>
<td><h5>taskmanager.bind-host</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>The local address of the network interface that the task manager binds to. If not configured, '0.0.0.0' will be used.</td>
</tr>
<tr>
<td><h5>taskmanager.data.bind-port</h5></td>
<td style="word-wrap: break-word;">(none)</td>
Expand All @@ -74,6 +92,12 @@
<td>String</td>
<td>The external address of the network interface where the TaskManager is exposed. Because different TaskManagers need different values for this option, usually it is specified in an additional non-shared TaskManager-specific config file.</td>
</tr>
<tr>
<td><h5>taskmanager.rpc.bind-port</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Integer</td>
<td>The local RPC port that the TaskManager binds to. If not configured, the external port (configured by 'taskmanager.rpc.port') will be used.</td>
</tr>
<tr>
<td><h5>taskmanager.rpc.port</h5></td>
<td style="word-wrap: break-word;">"0"</td>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,10 @@ public class JobManagerOptions {
+ " leader from potentially multiple standby JobManagers.");

/** The local address of the network interface that the job manager binds to. */
@Documentation.Section({
Documentation.Sections.COMMON_HOST_PORT,
Documentation.Sections.ALL_JOB_MANAGER
})
public static final ConfigOption<String> BIND_HOST =
key("jobmanager.bind-host")
.stringType()
Expand Down Expand Up @@ -105,6 +109,10 @@ public class JobManagerOptions {
+ " leader from potentially multiple standby JobManagers.");

/** The local port that the job manager binds to. */
@Documentation.Section({
Documentation.Sections.COMMON_HOST_PORT,
Documentation.Sections.ALL_JOB_MANAGER
})
public static final ConfigOption<Integer> RPC_BIND_PORT =
key("jobmanager.rpc.bind-port")
.intType()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -126,6 +126,10 @@ public class TaskManagerOptions {
+ " additional non-shared TaskManager-specific config file.");

/** The local address of the network interface that the task manager binds to. */
@Documentation.Section({
Documentation.Sections.COMMON_HOST_PORT,
Documentation.Sections.ALL_TASK_MANAGER
})
public static final ConfigOption<String> BIND_HOST =
key("taskmanager.bind-host")
.stringType()
Expand All @@ -152,6 +156,10 @@ public class TaskManagerOptions {
+ " range of ports to avoid collisions when multiple TaskManagers are running on the same machine.");

/** The local port that the task manager binds to. */
@Documentation.Section({
Documentation.Sections.COMMON_HOST_PORT,
Documentation.Sections.ALL_TASK_MANAGER
})
public static final ConfigOption<Integer> RPC_BIND_PORT =
key("taskmanager.rpc.bind-port")
.intType()
Expand Down

0 comments on commit 011b6b4

Please sign in to comment.