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 2015/11/27 06:02:11 UTC

incubator-kylin git commit: Incease 4096 column length limit to 16384 in BaseCuboidMapper

Repository: incubator-kylin
Updated Branches:
  refs/heads/1.x-staging 0f5b15617 -> 6f93a4d62


Incease 4096 column length limit to 16384 in BaseCuboidMapper


Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/6f93a4d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/6f93a4d6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/6f93a4d6

Branch: refs/heads/1.x-staging
Commit: 6f93a4d6272d1063a12813221a2174fddae3bd09
Parents: 0f5b156
Author: Li, Yang <ya...@ebay.com>
Authored: Fri Nov 27 13:02:02 2015 +0800
Committer: Li, Yang <ya...@ebay.com>
Committed: Fri Nov 27 13:02:02 2015 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/job/hadoop/cube/BaseCuboidMapper.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/6f93a4d6/job/src/main/java/org/apache/kylin/job/hadoop/cube/BaseCuboidMapper.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/cube/BaseCuboidMapper.java b/job/src/main/java/org/apache/kylin/job/hadoop/cube/BaseCuboidMapper.java
index bedd726..470225e 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/cube/BaseCuboidMapper.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/cube/BaseCuboidMapper.java
@@ -107,7 +107,7 @@ public class BaseCuboidMapper<KEYIN> extends KylinMapper<KEYIN, Text, Text, Text
 
         intermediateTableDesc = new CubeJoinedFlatTableDesc(cube.getDescriptor(), cubeSegment);
 
-        bytesSplitter = new BytesSplitter(200, 4096);
+        bytesSplitter = new BytesSplitter(200, 16384);
         rowKeyEncoder = AbstractRowKeyEncoder.createInstance(cubeSegment, baseCuboid);
 
         measureCodec = new MeasureCodec(cubeDesc.getMeasures());