Dear all,
Query the sql in kylin, it shows error. Do you have any ideas?
```
Error while compiling generated Java code: public static class Record2_0
implements java.io.Serializable { public long f0; public boolean f1; public
Record2_0() {} public boolean equals(Object o) { if (this == o) { return true;
} if (!(o instanceof Record2_0)) { return false; } return this.f0 ==
((Record2_0) o).f0 && this.f1 == ((Record2_0) o).f1; } public int hashCode() {
int h = 0; h = org.apache.calcite.runtime.Utilities.hash(h, this.f0); h =
org.apache.calcite.runtime.Utilities.hash(h, this.f1); return h; } public int
compareTo(Record2_0 that) { int c; c =
org.apache.calcite.runtime.Utilities.compare(this.f0, that.f0); if (c != 0) {
return c; } c = org.apache.calcite.runtime.Utilities.compare(this.f1, that.f1);
if (c != 0) { return c; } return 0; } public String toString() { return "{f0="
+ this.f0 + ", f1=" + this.f1 + "}"; } } org.apache.calcite.DataContext root;
public org.apache.calcite.linq4j.Enumerable bind(final
org.apache.calcite.DataContext root0) { root = root0; final
org.apache.calcite.linq4j.Enumerable _inputEnumerable =
((org.apache.kylin.query.schema.OLAPTable)
root.getRootSchema().getSubSchema("ADS_DAMAI").getTable("ADS_DAMAI_ORG_SAL_DS")).executeOLAPQuery(root,
0); final org.apache.calcite.linq4j.AbstractEnumerable child = new
org.apache.calcite.linq4j.AbstractEnumerable(){ public
org.apache.calcite.linq4j.Enumerator enumerator() { return new
org.apache.calcite.linq4j.Enumerator(){ public final
org.apache.calcite.linq4j.Enumerator inputEnumerator =
_inputEnumerable.enumerator(); public void reset() { inputEnumerator.reset(); }
public boolean moveNext() { return inputEnumerator.moveNext(); } public void
close() { inputEnumerator.close(); } public Object current() { final Object[]
current = (Object[]) inputEnumerator.current(); return new Object[] {
current[11], current[6], current[60], current[201]}; } }; } }; return
child.groupBy(new org.apache.calcite.linq4j.function.Function1() { public
java.util.List apply(Object[] a0) { return
org.apache.calcite.runtime.FlatLists.of(a0[0] == null ? (String) null :
a0[0].toString(), a0[1] == null ? (String) null : a0[1].toString()); } public
Object apply(Object a0) { return apply( (Object[]) a0); } } , new
org.apache.calcite.linq4j.function.Function0() { public Object apply() { long
a0s0; boolean a0s1; a0s1 = false; a0s0 = 0; Record2_0 record0; record0 = new
Record2_0(); record0.f0 = a0s0; record0.f1 = a0s1; return record0; } } , new
org.apache.calcite.linq4j.function.Function2() { public Record2_0
apply(Record2_0 acc, Object[] in) { final java.math.BigDecimal inp3_ = in[3] ==
null ? (java.math.BigDecimal) null :
org.apache.calcite.runtime.SqlFunctions.toBigDecimal(in[3]); if (inp3_ != null)
{ acc.f1 = true; acc.f0 = acc.f0 + ((Long) inp3_).longValue(); } return acc; }
public Record2_0 apply(Object acc, Object in) { return apply( (Record2_0) acc,
(Object[]) in); } } , new org.apache.calcite.linq4j.function.Function2() {
public Object[] apply(org.apache.calcite.runtime.FlatLists.ComparableList key,
Record2_0 acc) { return new Object[] { key.get(0) == null ? (String) null :
key.get(0).toString(), key.get(1) == null ? (String) null :
key.get(1).toString(), acc.f1 ? Long.valueOf(acc.f0) : (Long) null}; } public
Object[] apply(Object key, Object acc) { return apply(
(org.apache.calcite.runtime.FlatLists.ComparableList) key, (Record2_0) acc); }
} ); } public Class getElementType() { return java.lang.Object[].class; } while
executing SQL: "SELECT STORE_NEW_NO, BRAND_DETAIL_NO, sum(cust_sal_qty) AS
custQty FROM ads_damai_org_sal_ds T GROUP BY STORE_NEW_NO, BRAND_DETAIL_NO”
```
Sql :
```
SELECT
STORE_NEW_NO,
BRAND_DETAIL_NO,
sum(cust_sal_qty) AS custQty
FROM
ads_damai_org_sal_ds T
GROUP BY
STORE_NEW_NO,
BRAND_DETAIL_NO
```
ENV:
Kylin version: 2.6.1
Hadoop version: 3.0.0+cdh6.0.0
Best Regards,
Shylin Zhang