YannByron commented on code in PR #6264:
URL: https://github.com/apache/hudi/pull/6264#discussion_r943050236
##########
hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/HoodieSpark3CatalystPlanUtils.scala:
##########
@@ -52,8 +57,56 @@ abstract class HoodieSpark3CatalystPlanUtils extends
HoodieCatalystPlansUtils {
}
}
- override def toTableIdentifier(relation: UnresolvedRelation):
TableIdentifier = {
- relation.multipartIdentifier.asTableIdentifier
+ override def resolve(spark: SparkSession, relation: UnresolvedRelation):
Option[CatalogTable] = {
Review Comment:
> Moreover this part is not even affected by your changes. Your changes only
affect Time Travel queries, and not Insert Into statement.
not just insert statement. If you run `select * from
spark_catalog.default.hudi_tbl timestamp as of 111111` in the master branch, it
also throws the same exception. This pr can also solve this case.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
