[
https://issues.apache.org/jira/browse/HUDI-7908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Sumit updated HUDI-7908:
------------------------------
Fix Version/s: 1.0.0
(was: 1.0.0-beta3)
> HoodieFileGroupReader fails if precombine and partition fields are same
> -----------------------------------------------------------------------
>
> Key: HUDI-7908
> URL: https://issues.apache.org/jira/browse/HUDI-7908
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Sagar Sumit
> Assignee: Vova Kolmakov
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.0.0
>
>
> {code:java}
> test(s"Test INSERT INTO with upsert operation type") {
> if (HoodieSparkUtils.gteqSpark3_2) {
> withTempDir { tmp =>
> Seq("mor").foreach { tableType =>
> val tableName = generateTableName
> spark.sql(
> s"""
> |create table $tableName (
> | id int,
> | name string,
> | ts long,
> | price int
> |) using hudi
> |partitioned by (ts)
> |tblproperties (
> | type = '$tableType',
> | primaryKey = 'id',
> | preCombineField = 'ts'
> |)
> |location '${tmp.getCanonicalPath}/$tableName'
> |""".stripMargin
> )
> // Test insert into with upsert operation type
> spark.sql(
> s"""
> | insert into $tableName
> | values (1, 'a1', 1000, 10), (2, 'a2', 2000, 20), (3, 'a3',
> 3000, 30), (4, 'a4', 2000, 10), (5, 'a5', 3000, 20), (6, 'a6', 4000, 30)
> | """.stripMargin
> )
> checkAnswer(s"select id, name, price, ts from $tableName where
> price>3000")(
> Seq(6, "a6", 4000, 30)
> )
> // Test update
> spark.sql(s"update $tableName set price = price + 1 where id = 6")
> checkAnswer(s"select id, name, price, ts from $tableName where
> price>3000")(
> Seq(6, "a6", 4001, 30)
> )
> }
> }
> }
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
