lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1784] Added print detailed stack log when hbase connection error (#2799)

Browse Source
This commit is contained in:
hj2016
2021-04-12 13:46:06 +08:00
committed by GitHub
parent f3777f44fe
commit 1da16dfd2e
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/exception/HoodieDependentSystemUnavailableException.java
View File

@@ -27,8 +27,8 @@ public class HoodieDependentSystemUnavailableException extends HoodieException {
public static final String HBASE = "HBASE"; public static final String HBASE = "HBASE";
public HoodieDependentSystemUnavailableException(String system, String connectURL) { public HoodieDependentSystemUnavailableException(String system, String connectURL, Throwable t) {
super(getLogMessage(system, connectURL)); super(getLogMessage(system, connectURL), t);
} }
private static String getLogMessage(String system, String connectURL) { private static String getLogMessage(String system, String connectURL) {

2
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java
View File

@@ -151,7 +151,7 @@ public class SparkHoodieHBaseIndex<T extends HoodieRecordPayload> extends SparkH
return ConnectionFactory.createConnection(hbaseConfig); return ConnectionFactory.createConnection(hbaseConfig);
} catch (IOException e) { } catch (IOException e) {
throw new HoodieDependentSystemUnavailableException(HoodieDependentSystemUnavailableException.HBASE, throw new HoodieDependentSystemUnavailableException(HoodieDependentSystemUnavailableException.HBASE,
quorum + ":" + port); quorum + ":" + port, e);
} }
} }