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/
