[
https://issues.apache.org/jira/browse/FLINK-2996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024566#comment-15024566
]
ASF GitHub Bot commented on FLINK-2996:
---------------------------------------
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1394#discussion_r45738417
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ---
@@ -137,12 +139,29 @@ else if
(config.containsKey(ConfigConstants.STATE_BACKEND) &&
this.shutdownHook = null;
}
- // start the server
- try {
- this.serverSocket = new ServerSocket(0, backlog);
+ // ----------------------- start the server -------------------
+
+ String serverPortRange =
config.getString(ConfigConstants.BLOB_SERVER_PORT,
ConfigConstants.DEFAULT_BLOB_SERVER_PORT);
+ Iterator<Integer> ports =
NetUtils.getPortRangeFromString(serverPortRange).iterator();
+
+ ServerSocket socketAttempt = null;
+ while(ports.hasNext()) {
--- End diff --
Thnx, I'll fix that. Stupid mistake
> Add config entry to define BlobServer port
> ------------------------------------------
>
> Key: FLINK-2996
> URL: https://issues.apache.org/jira/browse/FLINK-2996
> Project: Flink
> Issue Type: New Feature
> Components: JobManager
> Affects Versions: 0.10.0
> Reporter: Stephan Ewen
> Assignee: Robert Metzger
> Fix For: 1.0.0, 0.10.1
>
>
> The blob server currently allocates a random port. To work better together
> with firewalled clusters, it must be possible to optionally pre-configure the
> port to a specific value,
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
