[kylin] 31/37: KYLIN-5583 Minor bug fix, and do optimization when computing query digest

[xxyu]

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

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

commit 3075031c16d76ce381d68a80c616642768abbcd7
Author: DorrisRuixuanZhang <dorriszh...@hotmail.com>
AuthorDate: Thu Mar 23 11:52:44 2023 +0800

    KYLIN-5583 Minor bug fix, and do optimization when computing query digest
---
 .../java/org/apache/kylin/query/relnode/OLAPProjectRel.java | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git 
a/src/query-common/src/main/java/org/apache/kylin/query/relnode/OLAPProjectRel.java
 
b/src/query-common/src/main/java/org/apache/kylin/query/relnode/OLAPProjectRel.java
index 35e40017ad..74ab0a38bb 100644
--- 
a/src/query-common/src/main/java/org/apache/kylin/query/relnode/OLAPProjectRel.java
+++ 
b/src/query-common/src/main/java/org/apache/kylin/query/relnode/OLAPProjectRel.java
@@ -22,6 +22,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.stream.Collectors;
 
 import org.apache.calcite.adapter.enumerable.EnumerableCalc;
 import org.apache.calcite.adapter.enumerable.EnumerableConvention;
@@ -46,12 +47,11 @@ import org.apache.calcite.rex.RexOver;
 import org.apache.calcite.rex.RexProgram;
 import org.apache.calcite.sql.fun.SqlCaseOperator;
 import org.apache.calcite.tools.RelUtils;
-import org.apache.kylin.metadata.model.TblColRef;
-import org.apache.kylin.query.util.RexToTblColRefTranslator;
-
 import org.apache.kylin.guava30.shaded.common.base.Preconditions;
 import org.apache.kylin.guava30.shaded.common.collect.Lists;
 import org.apache.kylin.guava30.shaded.common.collect.Sets;
+import org.apache.kylin.metadata.model.TblColRef;
+import org.apache.kylin.query.util.RexToTblColRefTranslator;
 
 /**
  */
@@ -288,10 +288,9 @@ public class OLAPProjectRel extends Project implements 
OLAPRel {
             pw.item("ctx", String.valueOf(context.id) + "@" + 
context.realization);
             if (context.getGroupByColumns() != null && context.returnTupleInfo 
!= null
                     && context.returnTupleInfo.getColumnMap() != null) {
-                context.getGroupByColumns().forEach(colRef -> {
-                    Integer colId = 
context.returnTupleInfo.getColumnMap().get(colRef);
-                    pw.item("groupByColumns", String.valueOf(colId));
-                });
+                List<Integer> colIds = context.getGroupByColumns().stream()
+                        .map(colRef -> 
context.returnTupleInfo.getColumnMap().get(colRef)).collect(Collectors.toList());
+                pw.item("groupByColumns", colIds);
             }
         } else {
             pw.item("ctx", "");