This is an automated email from the ASF dual-hosted git repository. nic pushed a commit to branch 3.0.x-hadoop3.1 in repository https://gitbox.apache.org/repos/asf/kylin.git
commit b7a353bedde185e94bc3862b915dde54f8cf02cb Author: sickcate <iamzhu...@gmail.com> AuthorDate: Tue Apr 23 17:08:14 2019 +0800 fix beeline meta data parser on partition information --- .../apache/kylin/source/hive/BeelineHiveClient.java | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 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 29538aa..333e281 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 @@ -213,20 +213,21 @@ public class BeelineHiveClient implements IHiveClient { } } - private void parseResultEntry(ResultSet resultSet, HiveTableMetaBuilder builder) throws SQLException { + private void parseResultEntry(ResultSet resultSet, HiveTableMetaBuilder builder) throws SQLException{ List<HiveTableMeta.HiveTableColumnMeta> partitionColumns = Lists.newArrayList(); if ("# Partition Information".equals(resultSet.getString(1).trim())) { 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); }