[kylin] 03/16: 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 3.0.x-hadoop3.1
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit 595ca1983a7389cdcf6525c6df2bf4c12e1f85dc
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);
         }