Incease 4096 column length limit to 16384 in BaseCuboidMapper
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/6f93a4d6 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/6f93a4d6 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/6f93a4d6 Branch: refs/heads/master Commit: 6f93a4d6272d1063a12813221a2174fddae3bd09 Parents: 0f5b156 Author: Li, Yang <yang...@ebay.com> Authored: Fri Nov 27 13:02:02 2015 +0800 Committer: Li, Yang <yang...@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/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());
