arunb2w commented on issue #5000: URL: https://github.com/apache/hudi/issues/5000#issuecomment-1073770671
@nsivabalan When i was searching through the internet, i came across this ticket for partial update payload https://github.com/apache/hudi/issues/2637 so i tried to use that payload class for my above usecase to see how it behaves but am facing below error. Caused by: java.lang.ClassNotFoundException: org.apache.hudi.common.model.PartialUpdatePayload Does this mean this payload class is not yet deployed to production? When i checked the old ticket it was closed so i thought it is already updated and this payload class is available already. This is the way am running my job spark-submit --master local --packages org.apache.hudi:hudi-spark3.1.2-bundle_2.12:0.10.1,org.apache.spark:spark-avro_2.12:3.1.2 --conf 'spark.serializer=org.apache.spark.serializer.KryoSerializer' --driver-memory 1g --executor-memory 1g main.py -f /Users/parunkarthick/samepk_insert_mupdates.json Please let me know whether am doing something wrong and why am getting the class not found exception. Thanks -- 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]
