[kylin] branch 2.6.x updated: KYLIN-4022 when Adhoc Push Down then Unrecognized column type: DECIMAL(xx, xx)

[ni...@apache.org]

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 <ja...@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;