flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2996) Add config entry to define BlobServer port
Date Tue, 24 Nov 2015 13:19:11 GMT

    [ 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)

Mime
View raw message