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 <64681310+jibing...@users.noreply.github.com> 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: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org