[gobblin] branch master updated: [GOBBLIN-1389] Ensuring exception being propagated in Hive-Reg code path

[lesun]

This is an automated email from the ASF dual-hosted git repository.

lesun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new ca26354  [GOBBLIN-1389] Ensuring exception being propagated in 
Hive-Reg code path
ca26354 is described below

commit ca2635401875550e8977341e3fd761b8ec64cdaf
Author: Lei Sun <autumn...@gmail.com>
AuthorDate: Wed Feb 17 14:37:04 2021 -0800

    [GOBBLIN-1389] Ensuring exception being propagated in Hive-Reg code path
    
    Closes #3228 from autumnust/exception_hive_reg
---
 .../apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
 
b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
index 5caf494..26ad94a 100644
--- 
a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
+++ 
b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
@@ -278,6 +278,7 @@ public class HiveMetaStoreBasedRegister extends 
HiveRegister {
           log.info(String.format("Created Hive table %s in db %s", tableName, 
dbName));
           return true;
         } catch (AlreadyExistsException e) {
+          log.debug("Table {}.{} already existed", table.getDbName(), 
table.getTableName());
         }
       }catch (TException e) {
         log.error(
@@ -377,7 +378,7 @@ public class HiveMetaStoreBasedRegister extends 
HiveRegister {
           }
         });
       } catch (ExecutionException ee) {
-        throw new IOException("Database existence checking throwing execution 
exception.");
+        throw new IOException("Database existence checking throwing execution 
exception.", ee);
       }
       return retVal;
     } else {
@@ -476,7 +477,7 @@ public class HiveMetaStoreBasedRegister extends 
HiveRegister {
           }
         });
       } catch (ExecutionException ee) {
-        throw new IOException("Table existence checking throwing execution 
exception.");
+        throw new IOException("Table existence checking throwing execution 
exception.", ee);
       }
     } else {
       this.ensureHiveTableExistenceBeforeAlternation(tableName, dbName, 
client, table, spec);