You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by GitBox <gi...@apache.org> on 2022/06/22 22:13:12 UTC

[GitHub] [hudi] nsivabalan commented on issue #5932: can not delete data when use spark scala code

nsivabalan commented on issue #5932:
URL: https://github.com/apache/hudi/issues/5932#issuecomment-1163662167

   did you verify that 
   ```
   val df = spark.sql("select * from temp_db.hudi_mor_tbl_ts_delete limit 1")
   ```
   above df was valid and did show the full record? bcoz, we do have unit tests around this. So, not sure how this is failing. Are you sure you are setting the operation type correctly to "delete" ? 
   
   Infact our quick start goes through similar example. 
   CC @minihippo @YannByron : Is there anything specific to spark-sql layer that could impact how deletes are done. 
   


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org