Hi! Is this Flink 1.0.0 ?
Stephan On Thu, Mar 10, 2016 at 6:02 AM, Deepak Jha <dkjhan...@gmail.com> wrote: > Hi All, > > I'm trying to setup Flink 1.0.0 cluster on Docker (separate containers for > jobmanager and taskmanager) inside AWS (Using AWS ECS service). I tested it > locally and its working fine but on AWS Docker, I am running into following > issue > > *2016-03-09 18:04:12,114 PST [INFO] ec2-52-3-248-202.compute-1.ama [main] > o.a.f.runtime.jobmanager.JobManager - Starting JobManager with > high-availability* > *2016-03-09 18:04:12,118 PST [INFO] ec2-52-3-248-202.compute-1.ama [main] > o.a.f.runtime.jobmanager.JobManager - Starting JobManager on > 172.31.63.152:8079 <http://172.31.63.152:8079> with execution mode CLUSTER* > *2016-03-09 18:04:12,172 PST [INFO] ec2-52-3-248-202.compute-1.ama [main] > o.a.f.runtime.jobmanager.JobManager - Security is not enabled. Starting > non-authenticated JobManager.* > *2016-03-09 18:04:12,174 PST [DEBUG] ec2-52-3-248-202.compute-1.ama [main] > org.apache.flink.util.NetUtils - Trying to open socket on port 8079* > *2016-03-09 18:04:12,176 PST [DEBUG] ec2-52-3-248-202.compute-1.ama [main] > org.apache.flink.util.NetUtils - Unable to allocate socket on port* > *java.net.BindException: Cannot assign requested address* > * at java.net.PlainSocketImpl.socketBind(Native Method)* > * at > java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:387)* > * at java.net.ServerSocket.bind(ServerSocket.java:375)* > * at java.net.ServerSocket.<init>(ServerSocket.java:237)* > * at > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2$$anon$3.createSocket(JobManager.scala:1722)* > * at > org.apache.flink.util.NetUtils.createSocketFromPorts(NetUtils.java:237)* > * at > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply$mcV$sp(JobManager.scala:1719)* > * at > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply(JobManager.scala:1717)* > * at > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$2.apply(JobManager.scala:1717)* > * at scala.util.Try$.apply(Try.scala:192)* > * at > org.apache.flink.runtime.jobmanager.JobManager$.retryOnBindException(JobManager.scala:1772)* > * at > org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:1717)* > * at > org.apache.flink.runtime.jobmanager.JobManager$.main(JobManager.scala:1653)* > * at > org.apache.flink.runtime.jobmanager.JobManager.main(JobManager.scala)* > *2016-03-09 18:04:12,180 PST [ERROR] ec2-52-3-248-202.compute-1.ama [main] > o.a.f.runtime.jobmanager.JobManager - Failed to run JobManager.* > *java.lang.RuntimeException: Unable to do further retries starting the > actor system* > * at > org.apache.flink.runtime.jobmanager.JobManager$.retryOnBindException(JobManager.scala:1777)* > * at > org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:1717)* > * at > org.apache.flink.runtime.jobmanager.JobManager$.main(JobManager.scala:1653)* > * at > org.apache.flink.runtime.jobmanager.JobManager.main(JobManager.scala)* > *2016-03-09 18:04:12,991 PST [DEBUG] ec2-52-3-248-202.compute-1.ama [main] > o.a.h.m.lib.MutableMetricsFactory - field > org.apache.hadoop.metrics2.lib.MutableRate > org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginSuccess > with annotation @org.apache.hadoop.metrics2.annotation.Metric(about=, > sampleName=Ops, always=false, type=DEFAULT, value=[Rate of successful > kerberos logins and latency (milliseconds)], valueName=Time)* > > > Initially Jobmanager tries to bind to port 0 which did not work. On > looking further into it, I tried using recovery jobmanager port using > different port combinations, but it does not seems to be working... I've > exposed the ports in the docker compose file as well.... > > > PFA the jobmanager log file for details also the jobmanager config file... > -- > Thanks, > Deepak Jha > >
