Zouxxyy commented on issue #6452: URL: https://github.com/apache/hudi/issues/6452#issuecomment-1225307072
I tried to solve the problem by just deleting `fs.delete(tablePath, true)` in `HoodieSparkSqlWriter`. But after that, execute the query, the old data is not overwritten By looking at the code, I found that the `WriteOperationType` of bulk insert overwrite is `BULK_INSERT`, not `INSERT_OVERWRITE`. At this time, only commit will be executed, but replace will not be executed. I don't know good way to solve this problem, maybe add a new type `BULK_INSERT_OVERWRITE`? Or first determine whether it is `OVERWRITE`, and then determine the type of insert operation? -- 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]
