diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDependentSystemUnavailableException.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDependentSystemUnavailableException.java index 4c83ebc84..f221f3637 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDependentSystemUnavailableException.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDependentSystemUnavailableException.java @@ -27,8 +27,8 @@ public class HoodieDependentSystemUnavailableException extends HoodieException { public static final String HBASE = "HBASE"; - public HoodieDependentSystemUnavailableException(String system, String connectURL) { - super(getLogMessage(system, connectURL)); + public HoodieDependentSystemUnavailableException(String system, String connectURL, Throwable t) { + super(getLogMessage(system, connectURL), t); } private static String getLogMessage(String system, String connectURL) { diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java index c55e5e7c9..579e2b3b2 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java @@ -151,7 +151,7 @@ public class SparkHoodieHBaseIndex extends SparkH return ConnectionFactory.createConnection(hbaseConfig); } catch (IOException e) { throw new HoodieDependentSystemUnavailableException(HoodieDependentSystemUnavailableException.HBASE, - quorum + ":" + port); + quorum + ":" + port, e); } }