You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by qh...@apache.org on 2015/05/18 13:19:41 UTC
[1/2] incubator-kylin git commit: KYLIN-770
Repository: incubator-kylin
Updated Branches:
refs/heads/0.8.0 8b31638b4 -> 8bcaf651f
KYLIN-770
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/8bcaf651
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/8bcaf651
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/8bcaf651
Branch: refs/heads/0.8.0
Commit: 8bcaf651f112937cdd9133ddeb93d8f862551608
Parents: 83680be
Author: qianhao.zhou <qi...@ebay.com>
Authored: Mon May 18 19:17:00 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Mon May 18 19:19:03 2015 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/rest/service/CacheService.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/8bcaf651/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/service/CacheService.java b/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
index 6ce8b83..913ae35 100644
--- a/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
+++ b/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
@@ -26,6 +26,9 @@ import org.apache.kylin.invertedindex.IIManager;
import org.apache.kylin.metadata.project.ProjectInstance;
import org.apache.kylin.metadata.project.ProjectManager;
import org.apache.kylin.metadata.realization.RealizationType;
+import org.apache.kylin.rest.controller.QueryController;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Caching;
import org.springframework.stereotype.Component;
import java.io.IOException;
@@ -36,6 +39,7 @@ import java.util.List;
@Component("cacheService")
public class CacheService extends BasicService {
+ @Caching(evict = { @CacheEvict(value = QueryController.SUCCESS_QUERY_CACHE, allEntries = true), @CacheEvict(value = QueryController.EXCEPTION_QUERY_CACHE, allEntries = true) })
public void rebuildCache(Broadcaster.TYPE cacheType, String cacheKey) {
final String log = "rebuild cache type: " + cacheType + " name:" + cacheKey;
try {
@@ -93,6 +97,7 @@ public class CacheService extends BasicService {
}
}
+ @Caching(evict = { @CacheEvict(value = QueryController.SUCCESS_QUERY_CACHE, allEntries = true), @CacheEvict(value = QueryController.EXCEPTION_QUERY_CACHE, allEntries = true) })
public void removeCache(Broadcaster.TYPE cacheType, String cacheKey) {
final String log = "remove cache type: " + cacheType + " name:" + cacheKey;
try {
[2/2] incubator-kylin git commit: optimize log
Posted by qh...@apache.org.
optimize log
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/83680be1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/83680be1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/83680be1
Branch: refs/heads/0.8.0
Commit: 83680be1038620c2ea6bac0da1c4bd749873f734
Parents: 8b31638
Author: qianhao.zhou <qi...@ebay.com>
Authored: Fri May 15 13:01:20 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Mon May 18 19:19:03 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/metadata/serializer/BigDecimalSerializer.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/83680be1/metadata/src/main/java/org/apache/kylin/metadata/serializer/BigDecimalSerializer.java
----------------------------------------------------------------------
diff --git a/metadata/src/main/java/org/apache/kylin/metadata/serializer/BigDecimalSerializer.java b/metadata/src/main/java/org/apache/kylin/metadata/serializer/BigDecimalSerializer.java
index cf146fb..af67112 100644
--- a/metadata/src/main/java/org/apache/kylin/metadata/serializer/BigDecimalSerializer.java
+++ b/metadata/src/main/java/org/apache/kylin/metadata/serializer/BigDecimalSerializer.java
@@ -38,6 +38,7 @@ public class BigDecimalSerializer extends DataTypeSerializer<BigDecimal> {
final DataType type;
final int maxLength;
+ int counter = 0;
public BigDecimalSerializer(DataType type) {
this.type = type;
@@ -48,7 +49,9 @@ public class BigDecimalSerializer extends DataTypeSerializer<BigDecimal> {
@Override
public void serialize(BigDecimal value, ByteBuffer out) {
if (value.scale() > type.getScale()) {
- logger.warn("value's scale has exceeded the " + type.getScale() +", cut it off, to ensure encoded value do not exceed maxLength " + maxLength);
+ if (counter % 10000 == 0) {
+ logger.warn("value's scale has exceeded the " + type.getScale() + ", cut it off, to ensure encoded value do not exceed maxLength " + maxLength + " times:" + (counter++));
+ }
value = value.setScale(type.getScale(), BigDecimal.ROUND_HALF_EVEN);
}
byte[] bytes = value.unscaledValue().toByteArray();