public class ZookeeperJobLock implements JobLock {
    private Logger logger = LoggerFactory.getLogger(ZookeeperJobLock.class);

    private static final String ZOOKEEPER_LOCK_PATH =
"/kylin/job_engine/lock";

    // 一直停留在这行代码
    hasLock = sharedLock.acquire(3, TimeUnit.SECONDS);

问题原因是 zookeeper创建分布式锁的时候,系统目录不存在,代码停留在锁的那一行了,导致整个任务调度线程没有启动

解决:
sudo mkdir /kylin/
sudo mkdir /kylin/job_engine/
sudo mkdir /kylin/job_engine/lock
sudo chown kangjiao:kangjiao /kylin/job_engine/lock/


--
View this message in context: 
http://apache-kylin.74782.x6.nabble.com/kylin2-0-0-streaming-build-pending-tp8202p8206.html
Sent from the Apache Kylin mailing list archive at Nabble.com.

Reply via email to