Aditya Goenka

As per latest master code we do upsert for MOR table. Able to reproduce the data duplicate issue similar to @haripriyarhp . Setup Used as per demo - https://github.com/apache/hudi/blob/master/hudi-kafka-connect/README.md ```...

@neeruks @rjmblc Can you please try with later versions of Hudi. I see it is all working seemlesly even with both the settings. ``` from pyspark.sql.types import * from pyspark.sql.functions...

@neeruks @rjmblc Are you getting similar issue with the later version of hudi. If not feel free to close the issue.

Did you confirmed these https://github.com/apache/hudi/issues/6341#issuecomment-1227436935

@sambhav13 We confirmed it works well with spark thrift server. Tried hudi 0.12.3 , 0.13.1 and 0.14.0 and all works good. Sorry for the delay in triaging this. Do you...

@ehurheap Did you tried the same lock configuration with a normal insert on test table to ensure configurations are good?

@ehurheap Sorry for the delay here. Is it possible to provide full implementation of UUIDRecordKeyDeleter.scala

@ehurheap I was trying to reproduce and identify the reason for this Exception. Couldn't reproduce as was not able to run and even not able to identify exact reason. It...

Sure. I will give it a try. On Sat, Dec 23, 2023 at 5:28 AM Liz Hurley ***@***.***> wrote: > @ad1happy2go here is a small repo > with code and...

@ofinchuk-bloomberg Thanks for raising this. I was able to reproduce. Checking it is same as one other known issue which was fixed by https://github.com/apache/hudi/pull/9863 which was later reverted due to...