minor, add some log in FactDistinctColumnsMapper
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/a1ad1eb2 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/a1ad1eb2 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/a1ad1eb2 Branch: refs/heads/master-hadoop3.0 Commit: a1ad1eb2d8f1e0fe4f4a5cdc2fd93f35ea82b2d4 Parents: bb1517b Author: xiefan46 <[email protected]> Authored: Tue Apr 18 15:30:59 2017 +0800 Committer: xiefan46 <[email protected]> Committed: Tue Apr 18 15:30:59 2017 +0800 ---------------------------------------------------------------------- .../apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/a1ad1eb2/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java index 993dafa..d36ae18 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java @@ -103,7 +103,6 @@ public class FactDistinctColumnsMapper<KEYIN> extends FactDistinctColumnsMapperB } - TblColRef partitionColRef = cubeDesc.getModel().getPartitionDesc().getPartitionDateColumnRef(); if (partitionColRef != null) { partitionColumnIndex = intermediateTableDesc.getColumnIndex(partitionColRef); @@ -124,10 +123,12 @@ public class FactDistinctColumnsMapper<KEYIN> extends FactDistinctColumnsMapperB row_hashcodes[i] = new ByteArray(); } hf = Hashing.murmur3_32(); + logger.info("Found KylinVersion : {}. Use old algorithm for cuboid sampling.", cubeDesc.getVersion()); } else { isUsePutRowKeyToHllNewAlgorithm = true; rowHashCodesLong = new long[nRowKey]; hf = Hashing.murmur3_128(); + logger.info("Found KylinVersion : {}. Use new algorithm for cuboid sampling. About the details of the new algorithm, please refer to KYLIN-2518", cubeDesc.getVersion()); } }
