This is an automated email from the ASF dual-hosted git repository. nic pushed a commit to branch 2.6.x in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.6.x by this push: new 2b8d28f KYLIN-4022 when Adhoc Push Down then Unrecognized column type: DECIMAL(xx,xx) 2b8d28f is described below commit 2b8d28f111b4619068d4d4e6c53a081ff3d85e5f Author: javalife0312 <javalife0...@126.com> AuthorDate: Wed May 29 17:03:03 2019 +0800 KYLIN-4022 when Adhoc Push Down then Unrecognized column type: DECIMAL(xx,xx) --- .../main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java b/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java index de73327..315a3c1 100644 --- a/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java +++ b/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java @@ -32,6 +32,7 @@ import java.sql.Statement; import java.sql.Types; import java.util.LinkedList; import java.util.List; +import java.util.Locale; public class PushDownRunnerJdbcImpl extends AbstractPushdownRunner { @@ -247,7 +248,7 @@ public class PushDownRunnerJdbcImpl extends AbstractPushdownRunner { return Types.DATE; } else if ("timestamp".equalsIgnoreCase(type)) { return Types.TIMESTAMP; - } else if ("decimal".equalsIgnoreCase(type)) { + } else if (type.toLowerCase(Locale.ROOT).startsWith("decimal")) { return Types.DECIMAL; } else if ("binary".equalsIgnoreCase(type)) { return Types.BINARY;