From b0010bf3b449a9d2e01955b0746b795e22e577db Mon Sep 17 00:00:00 2001
From: Balajee Nagasubramaniam <47542891+nbalajee@users.noreply.github.com>
Date: Wed, 17 Feb 2021 17:34:15 -0800
Subject: [PATCH] [HUDI-1582] Throw an exception when syncHoodieTable() fails,
 with RuntimeException (#2536)

---
 .../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 25d52c57f..140938f70 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 d0541e088..5fd9c9c30 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();
     }