This is an automated email from the ASF dual-hosted git repository.

nic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit 372f4ddf324dde8b1bc430710f7c3a09e7f30151
Author: Zhong, Yanghong <nju_y...@apache.org>
AuthorDate: Tue Mar 10 14:17:15 2020 +0800

    KYLIN-4325 fix TypeFlag for global dictionary field in SelfDefineSortableKey
---
 .../org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 2c3bc8d..0fa12f9 100755
--- 
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
@@ -285,7 +285,11 @@ public class FactDistinctColumnsMapper<KEYIN> extends 
FactDistinctColumnsMapperB
         tmpbuf.put(Bytes.toBytes(reducerIndex)[3]);
         tmpbuf.put(valueBytes);
         outputKey.set(tmpbuf.array(), 0, tmpbuf.position());
-        sortableKey.init(outputKey, type);
+        if (cubeDesc.getDictionaryBuilderClass(allCols.get(colIndex)) == null) 
{
+            sortableKey.init(outputKey, type);
+        } else {
+            sortableKey.init(outputKey, (byte) 0);
+        }
         context.write(sortableKey, EMPTY_TEXT);
         // log a few rows for troubleshooting
         if (rowCount < 10) {

Reply via email to