[kylin] 04/06: fix beeline meta data parser on partition information

[nic]

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 552062405f3ed3322f9bd7e9fc43c3dd536749d9
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 6ad8593..16b12f7 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);
             }