ad1happy2go commented on issue #11138:
URL: https://github.com/apache/hudi/issues/11138#issuecomment-2100184808

   @pravin1406 
   We already had the JIRA Open for this . This is thhe issue with MERGE INTO 
for MOR tables - https://issues.apache.org/jira/browse/HUDI-6737
   
   @jonvex Did we got a chance to fix it?
   
   Code to reproduce - 
   
   ```
   CREATE TABLE merge_source (
       ts BIGINT,
       uuid STRING,
       rider STRING,
       driver STRING,
       fare DOUBLE,
       city STRING
   ) USING PARQUET;
   
   INSERT INTO merge_source
   VALUES
   
(1695159649087,'334e26e9-8355-45cc-97c6-c31daf0df330','rider-A','driver-K',19.10,'san_francisco'),
   
(1695091554788,'e96c4396-3fad-413a-a942-4cb36106d721','rider-C','driver-M',27.70
 ,'san_francisco'),
   
(1695046462179,'9909a8b1-2d15-4d3d-8ec9-efc48c536a00','rider-D','driver-L',33.90
 ,'san_francisco'),
   
(1695332066204,'1dced545-862b-4ceb-8b43-d2a568f6616b','rider-E','driver-O',93.50,'san_francisco'),
   
(1695516137016,'e3cf430c-889d-4015-bc98-59bdce1e530c','rider-F','driver-P',34.15,'sao_paulo'
    ),
   
(1695376420876,'7a84095f-737f-40bc-b62f-6b69664712d2','rider-G','driver-Q',43.40
 ,'sao_paulo'    ),
   
(1695173887231,'3eeb61f7-c2b0-4636-99bd-5d7a5a1d2c04','rider-I','driver-S',41.06
 ,'chennai'      ),
   
(1695115999911,'c8abbe79-8d89-47ea-b4ce-4d224bae5bfa','rider-J','driver-T',17.85,'chennai');
   
   CREATE TABLE hudi_table (
       ts BIGINT,
       uuid STRING,
       rider STRING,
       driver STRING,
       fare DOUBLE,
       city STRING
   ) USING HUDI
   PARTITIONED BY (city)
   OPTIONS ( 
     primaryKey 'uuid', 
     hoodie.datasource.write.operation 'upsert', 
     hoodie.datasource.write.precombine.field 'ts', 
     hoodie.datasource.write.recordkey.field 'uuid',
     hoodie.table.name 'issue_11138',
     hoodie.datasource.write.table.type 'MERGE_ON_READ'
   );
   
   insert into hudi_table 
   select * from merge_source;
   
   merge into hudi_table as target 
   using merge_source as source 
   on target.uuid = source.uuid
   when matched then update set target.city =  source.city , 
   target.fare = source.fare, target.ts = source.ts;
   ```


-- 
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]

Reply via email to