[
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)