Hi,
In your case the jobmanager binds itself to localhost and that's what it
writes to zookeeper. Try starting the jobmanager manually with
jobmanager.rpc.address set to the ip of machine you are running the
jobmanager.  In other words make sure the jobmanager binds itself to the
right ip.

Regards
Dawid

On Tue, 21 Aug 2018 at 15:32, mozer <mehmet.a.o...@externe.bnpparibas.com>
wrote:

> FQD or full ip; tried all of them, still no changes ...
> For ssh connection, I can connect to each machine without passwords.
>
>
> Do you think that the problem can come from :
>
> *high-availability.storageDir: file:///shareflink/recovery* ?
>
> I don't use a HDFS storage but NAS file system which is common for two
> machines.
>
> I also added ;
>
>
> state.backend: filesystem
> state.checkpoints.fs.dir: file:///shareflink/recovery/checkpoint
> blob.storage.directory: file:///shareflink/recovery/blob
>
> Logs for zookeeper file :
>
> 2018-08-21 14:59:32,652 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.ZooKeeperServer
>
> - tickTime set to 2000
> 2018-08-21 14:59:32,653 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.ZooKeeperServer
>
> - minSessionTimeout set to -1
> 2018-08-21 14:59:32,653 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.ZooKeeperServer
>
> - maxSessionTimeout set to -1
> 2018-08-21 14:59:32,661 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.NIOServerCnxnFactory
>
> - binding to port 0.0.0.0/0.0.0.0:2181
> 2018-08-21 14:59:39,940 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.NIOServerCnxnFactory
>
> - Accepted socket connection from /Machine1:60186
> 2018-08-21 14:59:40,015 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.NIOServerCnxnFactory
>
> - Accepted socket connection from /Machine2:54466
> 2018-08-21 14:59:40,017 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.ZooKeeperServer
>
> - Client attempting to establish new session at /Machine1:60186
> 2018-08-21 14:59:40,017 INFO
> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.server.ZooKeeperServer
>
> - Client attempting to establish new session at /Machine2:54466
>
> Log for Job Manager :
>
> 2018-08-21 14:59:39,327 INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Trying to
> start actor system at 127.0.0.1:50101
> 2018-08-21 14:59:39,723 INFO  akka.event.slf4j.Slf4jLogger
>
> - Slf4jLogger started
> 2018-08-21 14:59:39,766 INFO  akka.remote.Remoting
>
> - Starting remoting
> 2018-08-21 14:59:39,859 INFO  akka.remote.Remoting
>
> - Remoting started; listening on addresses
> :[akka.tcp://flink@127.0.0.1:50101]
> 2018-08-21 14:59:39,865 INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Actor
> system
> started at akka.tcp://flink@127.0.0.1:50101
> 2018-08-21 14:59:39,872 INFO
> org.apache.flink.runtime.blob.FileSystemBlobStore             - Creating
> highly available BLOB storage directory at
> file:///shareflink/recovery///blob
> 2018-08-21 14:59:39,876 INFO
> org.apache.flink.runtime.util.ZooKeeperUtils
> - Enforcing default ACL for ZK connections
> 2018-08-21 14:59:39,876 INFO
> org.apache.flink.runtime.util.ZooKeeperUtils
> - Using '/usr/flink-1.5.1/' as Zookeeper namespace.
> 2018-08-21 14:59:39,919 INFO
> org.apache.flink.shaded.curator.org.apache.curator.framework.imps.CuratorFrameworkImpl
>
> - Starting
>
>
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>

Reply via email to