[
https://issues.apache.org/jira/browse/FLINK-2996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024492#comment-15024492
]
ASF GitHub Bot commented on FLINK-2996:
---------------------------------------
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1394#discussion_r45733147
--- Diff: flink-core/src/test/java/org/apache/flink/util/NetUtilsTest.java
---
@@ -94,4 +99,53 @@ public void testIPv6URLEncoding() {
fail(e.getMessage());
}
}
+
+ @Test
+ public void testFreePortRangeUtility() {
+ // inspired by Hadoop's example for
"yarn.app.mapreduce.am.job.client.port-range"
+ String rangeDefinition = "50000-50050, 50100-50200,51234 "; //
this also contains some whitespaces
+ Set<Integer> ports =
NetUtils.getPortRangeFromString(rangeDefinition);
+ Assert.assertEquals(51+101+1, ports.size());
+ // check first range
+ Assert.assertThat(ports, hasItems(50000, 50001, 50002, 50050));
--- End diff --
What if `ports` does not contain `50003`?
> 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)
