Vishal Ranjan created SAMZA-2681:
------------------------------------

             Summary: Malformed URL exception while deploying Samza on a pure 
IPv6 VM
                 Key: SAMZA-2681
                 URL: https://issues.apache.org/jira/browse/SAMZA-2681
             Project: Samza
          Issue Type: Bug
         Environment: Pure IPv6 deployment
            Reporter: Vishal Ranjan


In our product we are expanding our support for IPv6 environment. 
We earlier tested deploying Samza in a dual stack environment, and it worked 
fine.
Recently we got our hands on a pure IPv6 lab, and while testing we came across 
an issue when starting Samza.
 
Looking at the stack trace it seems like the url is not formed correctly for 
IPv6 deployment. The IPv6 address should have been decorated inside '[ ]’, but 
that isn’t the case.
Here is the stack trace. The ip of the VM where Samza is deployed is 
'fc00:192:168:22::14’.
 
{color:#0747a6}2021-08-26T07:28:52.232Z INFO jetty.server.AbstractConnector 
main doStart:331 Started ServerConnector@6c1cfa53\{HTTP/1.1, 
(http/1.1)}{[0.0.0.0:44843|http://0.0.0.0:44843/]}{color}
{color:#0747a6}2021-08-26T07:28:52.232Z INFO jetty.server.Server main 
doStart:415 Started @5524ms{color}
{color:#0747a6}2021-08-26T07:28:52.235Z ERROR 
samza.clustermanager.ClusterBasedJobCoordinator main run:314 Exception thrown 
in the JobCoordinator loop{color}
{color:#0747a6}java.net.MalformedURLException: Error at index 3 in: 
"192:168:22:0:0:0:14:44843"{color}
{color:#0747a6}        at java.base/java.net.URL.<init>(URL.java:679){color}
{color:#0747a6}        at java.base/java.net.URL.<init>(URL.java:541){color}
{color:#0747a6}        at java.base/java.net.URL.<init>(URL.java:488){color}
{color:#0747a6}        at 
org.apache.samza.coordinator.server.HttpServer.getUrl(HttpServer.scala:134){color}
{color:#0747a6}        at 
org.apache.samza.coordinator.server.HttpServer.$anonfun$start$4(HttpServer.scala:113){color}
{color:#0747a6}        at 
[org.apache.samza.util.Logging.info|http://org.apache.samza.util.logging.info/](Logging.scala:63){color}
{color:#0747a6}        at 
[org.apache.samza.util.Logging.info|http://org.apache.samza.util.logging.info/]$(Logging.scala:61){color}
{color:#0747a6}        at 
[org.apache.samza.coordinator.server.HttpServer.info|http://org.apache.samza.coordinator.server.httpserver.info/](HttpServer.scala:39){color}
{color:#0747a6}        at 
org.apache.samza.coordinator.server.HttpServer.start(HttpServer.scala:113){color}
{color:#0747a6}        at 
org.apache.samza.job.yarn.SamzaYarnAppMasterService.onInit(SamzaYarnAppMasterService.scala:53){color}
{color:#0747a6}        at 
org.apache.samza.job.yarn.YarnClusterResourceManager.start(YarnClusterResourceManager.java:212){color}
{color:#0747a6}        at 
org.apache.samza.clustermanager.ContainerProcessManager.start(ContainerProcessManager.java:230){color}
{color:#0747a6}        at 
org.apache.samza.clustermanager.ClusterBasedJobCoordinator.run(ClusterBasedJobCoordinator.java:289){color}
{color:#0747a6}        at 
org.apache.samza.clustermanager.ClusterBasedJobCoordinator.runClusterBasedJobCoordinator(ClusterBasedJobCoordinator.java:547){color}
{color:#0747a6}        at 
org.apache.samza.clustermanager.ClusterBasedJobCoordinator.main(ClusterBasedJobCoordinator.java:473){color}
{color:#0747a6}Caused by: java.lang.NumberFormatException: Error at index 3 in: 
"192:168:22:0:0:0:14:44843"{color}
{color:#0747a6}        at 
java.base/java.lang.NumberFormatException.forCharSequence(NumberFormatException.java:81){color}
{color:#0747a6}        at 
java.base/java.lang.Integer.parseInt(Integer.java:735){color}
{color:#0747a6}        at 
java.base/java.net.URLStreamHandler.parseURL(URLStreamHandler.java:223){color}
{color:#0747a6} {color}
This is the problematic line of code: 
~l/.m2/repository/org/apache/samza/samza-core_2.12/1.5.1-arkin-jdk11/samza-core_2.12-1.5.1-arkin-jdk11-sources.jar!/org/apache/samza/coordinator/server/HttpServer.scala:134
 {color:#f28931}new {color}{color:#4a5c6e}URL({color}{color:#a6ca91}"http://"; 
{color}{color:#4a5c6e}+ 
Util.{color}{color:#4a5c6e}getLocalHost{color}{color:#4a5c6e}.getHostName + 
{color}{color:#a6ca91}":" {color}{color:#4a5c6e}+ runningPort + rootPath){color}
 
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to