database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[improvement](multi-catalog) return root cause of exception (#14708)

Browse Source
This commit is contained in:
Mingyu Chen
2022-12-01 14:58:05 +08:00
committed by GitHub
parent 176f519fa1
commit f496d1972a
3 changed files with 17 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fe/fe-core/src/main/java/org/apache/doris/common/util/Util.java
View File

@ -556,4 +556,14 @@ public class Util {
logger.warn(msg, e);
throw new RuntimeException(msg, e);
}
public static String getRootCauseMessage(Throwable t) {
String rootCause = "unknown";
Throwable p = t;
while (p != null) {
rootCause = p.getClass().getName() + ": " + p.getMessage();
p = p.getCause();
}
return rootCause;
}
}

4
fe/fe-core/src/main/java/org/apache/doris/datasource/ExternalSchemaCache.java
View File

@ -19,6 +19,7 @@ package org.apache.doris.datasource;
import org.apache.doris.catalog.Column;
import org.apache.doris.common.Config;
import org.apache.doris.common.util.Util;
import org.apache.doris.metric.GaugeMetric;
import org.apache.doris.metric.Metric;
import org.apache.doris.metric.MetricLabel;
@ -89,7 +90,8 @@ public class ExternalSchemaCache {
try {
return schemaCache.get(key);
} catch (ExecutionException e) {
throw new CacheException("failed to get schema for %s in catalog %s", e, key, catalog.getName());
throw new CacheException("failed to get schema for %s in catalog %s. err: %s",
e, key, catalog.getName(), Util.getRootCauseMessage(e));
}
}

5
fe/fe-core/src/main/java/org/apache/doris/planner/external/HiveScanProvider.java vendored
View File

@ -33,6 +33,7 @@ import org.apache.doris.common.DdlException;
import org.apache.doris.common.FeConstants;
import org.apache.doris.common.MetaNotFoundException;
import org.apache.doris.common.UserException;
import org.apache.doris.common.util.Util;
import org.apache.doris.datasource.HMSExternalCatalog;
import org.apache.doris.datasource.hive.HiveMetaStoreCache;
import org.apache.doris.datasource.hive.HiveMetaStoreCache.HivePartitionValues;
@ -188,7 +189,9 @@ public class HiveScanProvider extends HMSTableScanProvider {
return allFiles;
} catch (Throwable t) {
LOG.warn("get file split failed for table: {}", hmsTable.getName(), t);
throw new UserException("get file split failed for table: " + hmsTable.getName(), t);
throw new UserException(
"get file split failed for table: " + hmsTable.getName() + ", err: " + Util.getRootCauseMessage(t),
t);
}
}