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.