You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Haihui Xu (Jira)" <ji...@apache.org> on 2021/10/26 08:02:00 UTC
[jira] [Updated] (HUDI-2627) Fix unsupported query instant time
format in quickstart page
[ https://issues.apache.org/jira/browse/HUDI-2627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Haihui Xu updated HUDI-2627:
----------------------------
Summary: Fix unsupported query instant time format in quickstart page (was: Fix unsupported query instant time format in quickstart page demo)
> Fix unsupported query instant time format in quickstart page
> ------------------------------------------------------------
>
> Key: HUDI-2627
> URL: https://issues.apache.org/jira/browse/HUDI-2627
> Project: Apache Hudi
> Issue Type: Improvement
> Reporter: Haihui Xu
> Priority: Major
> Fix For: 0.9.0
>
>
> when run the demo code:
> spark.read.
> format("hudi").
> option("as.of.instant", "2021-07-28 14: 11: 08").
> load(basePath)
> there are exceptions:
> java.lang.IllegalArgumentException: Unsupported query instant time format: 2021-07-28 14: 11: 08,Supported time format are: 'yyyy-MM-dd: HH:mm:ss' or 'yyyy-MM-dd' or 'yyyyMMddHHmmss'
> at org.apache.spark.sql.hudi.HoodieSqlUtils$.formatQueryInstant(HoodieSqlUtils.scala:250)
> at org.apache.hudi.HoodieFileIndex.$anonfun$specifiedQueryInstant$1(HoodieFileIndex.scala:85)
> at scala.Option.map(Option.scala:230)
> at org.apache.hudi.HoodieFileIndex.<init>(HoodieFileIndex.scala:85)
> at org.apache.hudi.DefaultSource.getBaseFileOnlyView(DefaultSource.scala:201)
> at org.apache.hudi.DefaultSource.createRelation(DefaultSource.scala:117)
> at org.apache.hudi.DefaultSource.createRelation(DefaultSource.scala:67)
> at org.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:350)
> at org.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:274)
> at org.apache.spark.sql.DataFrameReader.$anonfun$load$3(DataFrameReader.scala:245)
> at scala.Option.getOrElse(Option.scala:189)
> at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:245)
> at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
> ... 63 elided
--
This message was sent by Atlassian Jira
(v8.3.4#803005)