You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "lvyanquan (Jira)" <ji...@apache.org> on 2023/03/30 04:04:00 UTC
[jira] [Updated] (HUDI-6004) failed to execute Spark procedure for table not in current database
[ https://issues.apache.org/jira/browse/HUDI-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
lvyanquan updated HUDI-6004:
----------------------------
Description:
My current database of Spark session is `default` and when I executed this sql:
{code:java}
call run_clean(table => 'hudi_database.table1', retain_commits => 1)
{code}
I got this error message:
{code:java}
org.apache.spark.sql.catalyst.analysis.NoSuchTableException: Table or view 'table1' not found in database 'default';
at org.apache.spark.sql.catalyst.catalog.SessionCatalog.requireTableExists(SessionCatalog.scala:185)
at org.apache.spark.sql.catalyst.catalog.SessionCatalog.getTableMetadata(SessionCatalog.scala:433)
at org.apache.spark.sql.catalyst.catalog.HoodieCatalogTable$.apply(HoodieCatalogTable.scala:365)
at org.apache.hudi.HoodieCLIUtils$.getHoodieCatalogTable(HoodieCLIUtils.scala:66)
at org.apache.hudi.HoodieCLIUtils$.createHoodieClientFromPath(HoodieCLIUtils.scala:44)
at org.apache.spark.sql.hudi.command.procedures.RunCleanProcedure.call(RunCleanProcedure.scala:86)
at org.apache.spark.sql.hudi.command.CallProcedureHoodieCommand.run(CallProcedureHoodieCommand.scala:33) {code}
was:
My current database of Spark session is `default` and when I executed this sql:
call run_clean(table => 'hudi_database.table1', retain_commits => 1)
I got this error message:
org.apache.spark.sql.catalyst.analysis.NoSuchTableException: Table or view 'table1' not found in database 'default';
at org.apache.spark.sql.catalyst.catalog.SessionCatalog.requireTableExists(SessionCatalog.scala:185)
at org.apache.spark.sql.catalyst.catalog.SessionCatalog.getTableMetadata(SessionCatalog.scala:433)
at org.apache.spark.sql.catalyst.catalog.HoodieCatalogTable$.apply(HoodieCatalogTable.scala:365)
at org.apache.hudi.HoodieCLIUtils$.getHoodieCatalogTable(HoodieCLIUtils.scala:66)
at org.apache.hudi.HoodieCLIUtils$.createHoodieClientFromPath(HoodieCLIUtils.scala:44)
at org.apache.spark.sql.hudi.command.procedures.RunCleanProcedure.call(RunCleanProcedure.scala:86)
at org.apache.spark.sql.hudi.command.CallProcedureHoodieCommand.run(CallProcedureHoodieCommand.scala:33)
> failed to execute Spark procedure for table not in current database
> -------------------------------------------------------------------
>
> Key: HUDI-6004
> URL: https://issues.apache.org/jira/browse/HUDI-6004
> Project: Apache Hudi
> Issue Type: Bug
> Components: cleaning
> Reporter: lvyanquan
> Priority: Major
>
> My current database of Spark session is `default` and when I executed this sql:
> {code:java}
> call run_clean(table => 'hudi_database.table1', retain_commits => 1)
> {code}
> I got this error message:
> {code:java}
> org.apache.spark.sql.catalyst.analysis.NoSuchTableException: Table or view 'table1' not found in database 'default';
> at org.apache.spark.sql.catalyst.catalog.SessionCatalog.requireTableExists(SessionCatalog.scala:185)
> at org.apache.spark.sql.catalyst.catalog.SessionCatalog.getTableMetadata(SessionCatalog.scala:433)
> at org.apache.spark.sql.catalyst.catalog.HoodieCatalogTable$.apply(HoodieCatalogTable.scala:365)
> at org.apache.hudi.HoodieCLIUtils$.getHoodieCatalogTable(HoodieCLIUtils.scala:66)
> at org.apache.hudi.HoodieCLIUtils$.createHoodieClientFromPath(HoodieCLIUtils.scala:44)
> at org.apache.spark.sql.hudi.command.procedures.RunCleanProcedure.call(RunCleanProcedure.scala:86)
> at org.apache.spark.sql.hudi.command.CallProcedureHoodieCommand.run(CallProcedureHoodieCommand.scala:33) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)