This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 41a7a4ffa95 [fix](regression)Add log for iceberg stats case. (#41301)
41a7a4ffa95 is described below
commit 41a7a4ffa95dd7543f9f8bf98dc322a93cd6a160
Author: Jibing-Li <[email protected]>
AuthorDate: Thu Sep 26 07:47:20 2024 +0800
[fix](regression)Add log for iceberg stats case. (#41301)
Add log for iceberg stats case.
---
.../src/main/java/org/apache/doris/common/proc/CatalogsProcDir.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java | 1 +
regression-test/plugins/plugins_get_ids_from_proc.groovy | 1 +
.../suites/external_table_p0/iceberg/test_iceberg_statistics.groovy | 4 +++-
4 files changed, 6 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/proc/CatalogsProcDir.java
b/fe/fe-core/src/main/java/org/apache/doris/common/proc/CatalogsProcDir.java
index e6163645c28..bbb6bf44dac 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/proc/CatalogsProcDir.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/proc/CatalogsProcDir.java
@@ -69,7 +69,7 @@ public class CatalogsProcDir implements ProcDirInterface {
CatalogIf catalog = env.getCatalogMgr().getCatalog(catalogId);
if (catalog == null) {
- throw new AnalysisException("Catalog " + catalogIdStr + " does not
exist");
+ throw new AnalysisException("Catalog " + catalogIdStr + " does not
exist. Id " + catalogId);
}
return new DbsProcDir(env, catalog);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java
index c3ffd208d55..b77374e3094 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java
@@ -134,6 +134,7 @@ public class CatalogMgr implements Writable,
GsonPostProcessable {
private CatalogIf removeCatalog(long catalogId) {
CatalogIf catalog = idToCatalog.remove(catalogId);
+ LOG.info("Removed catalog with id {}, name {}", catalogId, catalog ==
null ? "N/A" : catalog.getName());
if (catalog != null) {
catalog.onClose();
nameToCatalog.remove(catalog.getName());
diff --git a/regression-test/plugins/plugins_get_ids_from_proc.groovy
b/regression-test/plugins/plugins_get_ids_from_proc.groovy
index 74a4d4d2010..94dc701a038 100644
--- a/regression-test/plugins/plugins_get_ids_from_proc.groovy
+++ b/regression-test/plugins/plugins_get_ids_from_proc.groovy
@@ -27,6 +27,7 @@ Suite.metaClass.get_catalog_id = {String catalog_name /*
param */ ->
}
}
log.info("get catalogid: " + catalog_id)
+ log.info("show proc info: " + catalogs)
return catalog_id
}
diff --git
a/regression-test/suites/external_table_p0/iceberg/test_iceberg_statistics.groovy
b/regression-test/suites/external_table_p0/iceberg/test_iceberg_statistics.groovy
index 24b27eb70b4..75e8ab37642 100644
---
a/regression-test/suites/external_table_p0/iceberg/test_iceberg_statistics.groovy
+++
b/regression-test/suites/external_table_p0/iceberg/test_iceberg_statistics.groovy
@@ -36,6 +36,9 @@ suite("test_iceberg_statistics",
"p0,external,doris,external_docker,external_doc
"s3.region" = "us-east-1"
);"""
+ def result = sql """show frontends;"""
+ logger.info("Frontends info: " + result)
+
def table_id_mor = get_table_id(catalog_name, db_name,
"sample_mor_parquet")
def table_id_cow = get_table_id(catalog_name, db_name,
"sample_cow_parquet")
@@ -54,4 +57,3 @@ suite("test_iceberg_statistics",
"p0,external,doris,external_docker,external_doc
}
}
}
-
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
