[hudi] branch master updated: [HUDI-1582] Throw an exception when syncHoodieTable() fails, with RuntimeException (#2536)

[nagarwal]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b0010bf  [HUDI-1582] Throw an exception when syncHoodieTable() fails, 
with RuntimeException (#2536)
b0010bf is described below

commit b0010bf3b449a9d2e01955b0746b795e22e577db
Author: Balajee Nagasubramaniam <47542891+nbala...@users.noreply.github.com>
AuthorDate: Wed Feb 17 17:34:15 2021 -0800

    [HUDI-1582] Throw an exception when syncHoodieTable() fails, with 
RuntimeException (#2536)
---
 .../hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncTool.java   | 2 +-
 .../src/main/java/org/apache/hudi/hive/HiveSyncTool.java               | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncTool.java 
b/hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncTool.java
index 25d52c5..140938f 100644
--- a/hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncTool.java
+++ b/hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncTool.java
@@ -102,7 +102,7 @@ public class DLASyncTool extends AbstractSyncTool {
           throw new InvalidTableException(hoodieDLAClient.getBasePath());
       }
     } catch (RuntimeException re) {
-      LOG.error("Got runtime exception when dla syncing", re);
+      throw new HoodieException("Got runtime exception when dla syncing " + 
cfg.tableName, re);
     } finally {
       hoodieDLAClient.close();
     }
diff --git 
a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java 
b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java
index d0541e0..5fd9c9c 100644
--- 
a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java
+++ 
b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java
@@ -21,6 +21,7 @@ package org.apache.hudi.hive;
 import org.apache.hudi.common.fs.FSUtils;
 import org.apache.hudi.common.model.HoodieFileFormat;
 import org.apache.hudi.common.util.Option;
+import org.apache.hudi.exception.HoodieException;
 import org.apache.hudi.exception.InvalidTableException;
 import org.apache.hudi.hadoop.utils.HoodieInputFormatUtils;
 import org.apache.hudi.sync.common.AbstractSyncHoodieClient.PartitionEvent;
@@ -104,7 +105,7 @@ public class HiveSyncTool extends AbstractSyncTool {
           throw new InvalidTableException(hoodieHiveClient.getBasePath());
       }
     } catch (RuntimeException re) {
-      LOG.error("Got runtime exception when hive syncing", re);
+      throw new HoodieException("Got runtime exception when hive syncing " + 
cfg.tableName, re);
     } finally {
       hoodieHiveClient.close();
     }