From 62ecb2da62117e65117f7f6070469ac27a3ea5dd Mon Sep 17 00:00:00 2001
From: Thinking Chen <744417972@qq.com>
Date: Tue, 9 Jul 2019 07:13:22 +0800
Subject: [PATCH] when column type is decimal, should add precision and scale
 (#753)

---
 .../src/main/java/com/uber/hoodie/hive/HoodieHiveClient.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/hoodie-hive/src/main/java/com/uber/hoodie/hive/HoodieHiveClient.java b/hoodie-hive/src/main/java/com/uber/hoodie/hive/HoodieHiveClient.java
index c25200726..746d600b4 100644
--- a/hoodie-hive/src/main/java/com/uber/hoodie/hive/HoodieHiveClient.java
+++ b/hoodie-hive/src/main/java/com/uber/hoodie/hive/HoodieHiveClient.java
@@ -285,6 +285,11 @@ public class HoodieHiveClient {
       while (result.next()) {
         String columnName = result.getString(4);
         String columnType = result.getString(6);
+        if ("DECIMAL".equals(columnType)) {
+          int columnSize = result.getInt("COLUMN_SIZE");
+          int decimalDigits = result.getInt("DECIMAL_DIGITS");
+          columnType += String.format("(%s,%s)", columnSize, decimalDigits);
+        }
         schema.put(columnName, columnType);
       }
       return schema;