I'm running into an issue where I am starting a standalone flink cluster in an lxc container. When my TaskManager starts up, the queryable state proxy starts listening on 127.0.1.1:9069. Attempting to connect to that port from outside the container fails. I'm totally willing to believe this is a configuration problem within my container, so, I just wanted to verify that it was expected behaviour to listen on that IP address. As far as I can tell, when the TaskManagerRunner creates an RpcService, it finds the task manager address in ConnectionUtls.findConnectingAddress by:
(1) Using AkkaUtils.getInetSocketAddressFromAkkaURL to find the target address (this resolves to 127.0.0.1) (2) Uses the LOCAL_HOST address detection strategy to find the proper address, this calls InetAddress.getLocalHost which resolves to 127.0.1.1 (as per the default /etc/hosts file on the container) (3) Determines that a connection can be made from 127.0.1.1 to 127.0.0.1, so uses 127.0.1.1 as the task manager address. If you can let me know if this is then intended behaviour, that would be great. If you have any suggestions as to how I can connect to the server from outside my container, that would also be great. Thanks. -- *Andrew Kowpak P.Eng* *Sr. Software Engineer* (519) 489 2688 | SSIMWAVE Inc. 402-140 Columbia Street West, Waterloo ON
