[hudi] branch master updated: [HUDI-1784] Added print detailed stack log when hbase connection error (#2799)

[vinoyang]

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

vinoyang 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 1da16df  [HUDI-1784]  Added print detailed stack log when hbase 
connection error (#2799)
1da16df is described below

commit 1da16dfd2e4c0277ecfab8a5f0928757c3005bb1
Author: hj2016 <hj3245...@163.com>
AuthorDate: Mon Apr 12 13:46:06 2021 +0800

    [HUDI-1784]  Added print detailed stack log when hbase connection error 
(#2799)
---
 .../hudi/exception/HoodieDependentSystemUnavailableException.java     | 4 ++--
 .../main/java/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 4c83ebc..f221f36 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 c55e5e7..579e2b3 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<T extends 
HoodieRecordPayload> extends SparkH
       return ConnectionFactory.createConnection(hbaseConfig);
     } catch (IOException e) {
       throw new 
HoodieDependentSystemUnavailableException(HoodieDependentSystemUnavailableException.HBASE,
-          quorum + ":" + port);
+          quorum + ":" + port, e);
     }
   }