This is an automated email from the ASF dual-hosted git repository. nic pushed a commit to branch 2.6.x-hadoop3.1 in repository https://gitbox.apache.org/repos/asf/kylin.git
commit 7e64394fbfdd4b6c05d5a418bc341e9013540c58 Author: sickcate <iamzhu...@gmail.com> AuthorDate: Tue Apr 23 17:08:14 2019 +0800 fix beeline meta data parser on partition information --- .../org/apache/kylin/source/hive/BeelineHiveClient.java | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java b/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java index 7e81dc0..fc71d10 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java @@ -182,14 +182,15 @@ public class BeelineHiveClient implements IHiveClient { resultSet.next(); Preconditions.checkArgument("# col_name".equals(resultSet.getString(1).trim())); resultSet.next(); - Preconditions.checkArgument("".equals(resultSet.getString(1).trim())); - while (resultSet.next()) { - if ("".equals(resultSet.getString(1).trim())) { - break; - } - partitionColumns.add(new HiveTableMeta.HiveTableColumnMeta(resultSet.getString(1).trim(), - resultSet.getString(2).trim(), resultSet.getString(3).trim())); - } + if ("".equals(resultSet.getString(1).trim())) + resultSet.next(); + do { + if ("".equals(resultSet.getString(1).trim())) { + break; + } + partitionColumns.add(new HiveTableMeta.HiveTableColumnMeta(resultSet.getString(1).trim(), + resultSet.getString(2).trim(), resultSet.getString(3).trim())); + } while (resultSet.next()); builder.setPartitionColumns(partitionColumns); }