[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205581#comment-16205581 ] ASF GitHub Bot commented on FLINK-6273: --- Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3688 Thanks! > Client can't connect to jobmanager whose hostname contains capital letters > -- > > Key: FLINK-6273 > URL: https://issues.apache.org/jira/browse/FLINK-6273 > Project: Flink > Issue Type: Bug > Components: Client >Affects Versions: 1.2.0, 1.3.0 >Reporter: Yelei Feng >Assignee: Yelei Feng >Priority: Blocker > Fix For: 1.4.0 > > > In non-HA mode, if we set jobmanager.rpc.address to a hostname with some > capital letters, flink client can't connect to jobmananger. > ERROR | [flink-akka.actor.default-dispatcher-4] | dropping message [class > akka.actor.ActorSelectionMessage] for non-local recipient > [Actor[akka.tcp://flink@szv1000258958:32586/]] arriving at > [akka.tcp://flink@szv1000258958:32586] inbound addresses are > [akka.tcp://flink@SZV1000258958:32586] | akka.remote.EndpointWriter > (Slf4jLogger.scala:65) -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204289#comment-16204289 ] ASF GitHub Bot commented on FLINK-6273: --- Github user barcahead closed the pull request at: https://github.com/apache/flink/pull/3688 > Client can't connect to jobmanager whose hostname contains capital letters > -- > > Key: FLINK-6273 > URL: https://issues.apache.org/jira/browse/FLINK-6273 > Project: Flink > Issue Type: Bug > Components: Client >Affects Versions: 1.2.0, 1.3.0 >Reporter: Yelei Feng >Assignee: Yelei Feng >Priority: Blocker > Fix For: 1.4.0 > > > In non-HA mode, if we set jobmanager.rpc.address to a hostname with some > capital letters, flink client can't connect to jobmananger. > ERROR | [flink-akka.actor.default-dispatcher-4] | dropping message [class > akka.actor.ActorSelectionMessage] for non-local recipient > [Actor[akka.tcp://flink@szv1000258958:32586/]] arriving at > [akka.tcp://flink@szv1000258958:32586] inbound addresses are > [akka.tcp://flink@SZV1000258958:32586] | akka.remote.EndpointWriter > (Slf4jLogger.scala:65) -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203485#comment-16203485 ] ASF GitHub Bot commented on FLINK-6273: --- Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3688 @barcahead could you please close this because it has been superseded by #4812 > Client can't connect to jobmanager whose hostname contains capital letters > -- > > Key: FLINK-6273 > URL: https://issues.apache.org/jira/browse/FLINK-6273 > Project: Flink > Issue Type: Bug > Components: Client >Affects Versions: 1.2.0, 1.3.0 >Reporter: Yelei Feng >Assignee: Yelei Feng >Priority: Blocker > Fix For: 1.4.0 > > > In non-HA mode, if we set jobmanager.rpc.address to a hostname with some > capital letters, flink client can't connect to jobmananger. > ERROR | [flink-akka.actor.default-dispatcher-4] | dropping message [class > akka.actor.ActorSelectionMessage] for non-local recipient > [Actor[akka.tcp://flink@szv1000258958:32586/]] arriving at > [akka.tcp://flink@szv1000258958:32586] inbound addresses are > [akka.tcp://flink@SZV1000258958:32586] | akka.remote.EndpointWriter > (Slf4jLogger.scala:65) -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003125#comment-16003125 ] ASF GitHub Bot commented on FLINK-6273: --- Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3688 @barcahead would it be safer to also normalize the value of `jobmanager.rpc.address`? > Client can't connect to jobmanager whose hostname contains capital letters > -- > > Key: FLINK-6273 > URL: https://issues.apache.org/jira/browse/FLINK-6273 > Project: Flink > Issue Type: Bug > Components: Client >Affects Versions: 1.2.0, 1.3.0 >Reporter: Yelei Feng >Assignee: Yelei Feng > Fix For: 1.3.0 > > > In non-HA mode, if we set jobmanager.rpc.address to a hostname with some > capital letters, flink client can't connect to jobmananger. > ERROR | [flink-akka.actor.default-dispatcher-4] | dropping message [class > akka.actor.ActorSelectionMessage] for non-local recipient > [Actor[akka.tcp://flink@szv1000258958:32586/]] arriving at > [akka.tcp://flink@szv1000258958:32586] inbound addresses are > [akka.tcp://flink@SZV1000258958:32586] | akka.remote.EndpointWriter > (Slf4jLogger.scala:65) -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958860#comment-15958860 ] ASF GitHub Bot commented on FLINK-6273: --- GitHub user barcahead opened a pull request: https://github.com/apache/flink/pull/3688 [FLINK-6273] [core] don't convert hostname to lower cases to prevent akka connection failure For akka `Address`, the host part is case sensitive, So if we build remote jobmanager url with lower case hostname, akka will reject message. I fix this issue by removing `toLowerCase` when building actor url. You can merge this pull request into a Git repository by running: $ git pull https://github.com/barcahead/flink FLINK-6273 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3688.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3688 commit f5f4f5823bb5f3de9484987a849a0a73906732a6 Author: fengyeleiDate: 2017-04-06T12:31:27Z [FLINK-6273] [core] don't convert hostname to lower cases to prevent akka connection failure > Client can't connect to jobmanager whose hostname contains capital letters > -- > > Key: FLINK-6273 > URL: https://issues.apache.org/jira/browse/FLINK-6273 > Project: Flink > Issue Type: Bug > Components: Client >Affects Versions: 1.2.0, 1.3.0 >Reporter: Yelei Feng >Assignee: Yelei Feng > Fix For: 1.3.0 > > > In non-HA mode, if we set jobmanager.rpc.address to a hostname with some > capital letters, flink client can't connect to jobmananger. > ERROR | [flink-akka.actor.default-dispatcher-4] | dropping message [class > akka.actor.ActorSelectionMessage] for non-local recipient > [Actor[akka.tcp://flink@szv1000258958:32586/]] arriving at > [akka.tcp://flink@szv1000258958:32586] inbound addresses are > [akka.tcp://flink@SZV1000258958:32586] | akka.remote.EndpointWriter > (Slf4jLogger.scala:65) -- This message was sent by Atlassian JIRA (v6.3.15#6346)