[jira] [Created] (FLINK-2766) Bad ipv6 jomanager url

["Arsenii Krasikov (JIRA)" <ji...@apache.org>]

Arsenii Krasikov created FLINK-2766:
---------------------------------------

             Summary: Bad ipv6 jomanager url
                 Key: FLINK-2766
                 URL: https://issues.apache.org/jira/browse/FLINK-2766
             Project: Flink
          Issue Type: Bug
            Reporter: Arsenii Krasikov


There is error with ipv6 addresses in:
```
  /**
   * Builds the akka actor path for the JobManager actor, given the socket address
   * where the JobManager's actor system runs.
   *
   * @param address The address of the JobManager's actor system.
   * @return The akka URL of the JobManager actor.
   */
  def getRemoteJobManagerAkkaURL(address: InetSocketAddress): String = {
    val hostPort = address.getAddress().getHostAddress() + ":" + address.getPort()
    s"akka.tcp://flink@$hostPort/user/$JOB_MANAGER_NAME"
  }
```
that leads to 
```
19:02:10,451 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Trying to register at JobManager akka.tcp://flink@2a02:6b8:0:1a39:0:0:12c:1:6123/user/jobmanager (attempt 31, timeout: 30 seconds)
19:02:40,470 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Trying to register at JobManager akka.tcp://flink@2a02:6b8:0:1a39:0:0:12c:1:6123/user/jobmanager (attempt 32, timeout: 30 seconds)
```



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)