You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/05/06 16:02:37 UTC
kylin git commit: fix UI
Repository: kylin
Updated Branches:
refs/heads/KYLIN-2578 e2baef471 -> eff3a3836
fix UI
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/eff3a383
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/eff3a383
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/eff3a383
Branch: refs/heads/KYLIN-2578
Commit: eff3a3836ad124beb558d517b343ef8a3add4019
Parents: e2baef4
Author: Yang Li <li...@apache.org>
Authored: Sun May 7 00:02:08 2017 +0800
Committer: Yang Li <li...@apache.org>
Committed: Sun May 7 00:02:08 2017 +0800
----------------------------------------------------------------------
.../kylin/storage/hbase/util/ZookeeperDistributedLock.java | 2 +-
.../kylin/storage/hbase/util/ZookeeperDistributedLockTest.java | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/eff3a383/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLock.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLock.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLock.java
index 156dbe3..9c6f468 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLock.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLock.java
@@ -134,7 +134,7 @@ public class ZookeeperDistributedLock implements DistributedLock, JobLock {
try {
curator.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).forPath(lockPath, clientBytes);
} catch (KeeperException.NodeExistsException ex) {
- logger.debug(lockPath + " is already locked");
+ logger.debug(client + " see " + lockPath + " is already locked");
} catch (Exception ex) {
throw new RuntimeException("Error while " + client + " trying to lock " + lockPath, ex);
}
http://git-wip-us.apache.org/repos/asf/kylin/blob/eff3a383/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLockTest.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLockTest.java b/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLockTest.java
index 6065e0f..3973434 100644
--- a/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLockTest.java
+++ b/storage-hbase/src/test/java/org/apache/kylin/storage/hbase/util/ZookeeperDistributedLockTest.java
@@ -34,8 +34,11 @@ import org.apache.kylin.common.util.HBaseMetadataTestCase;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class ZookeeperDistributedLockTest extends HBaseMetadataTestCase {
+ private static Logger logger = LoggerFactory.getLogger(ZookeeperDistributedLockTest.class);
static ZookeeperDistributedLock.Factory factory;
@@ -180,6 +183,7 @@ public class ZookeeperDistributedLockTest extends HBaseMetadataTestCase {
for (int i = 0; i < nClients; i++) {
expectedScore += threads[i].counter * clientIds[i];
}
+ logger.info("client side score is {} and watcher score is {}", expectedScore, scoreSum.get());
assertEquals(expectedScore, scoreSum.get());
watch.close();