From 1da16dfd2e4c0277ecfab8a5f0928757c3005bb1 Mon Sep 17 00:00:00 2001 From: hj2016 Date: Mon, 12 Apr 2021 13:46:06 +0800 Subject: [PATCH] [HUDI-1784] Added print detailed stack log when hbase connection error (#2799) --- .../exception/HoodieDependentSystemUnavailableException.java | 4 ++-- .../org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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); } }