dongtingting commented on issue #11516: URL: https://github.com/apache/hudi/issues/11516#issuecomment-2242061372
> Did you try 0.14.1, it might already be fixed in it. I think 0.14.1 and master neither fix this problem. - upsert and insertoverwrite inflight instant content is generated by BaseSparkCommitActionExecutor.buildprofie, build profile can only get insert/update partition info, could not get fileid here. - TransactionUtils.resolveWriteConflictIfAny getCandidateInstants is also get pending clustering by REPLACE_COMMIT_ACTION. If I am wrong, please correct me. Also in my company, we have demand for multi job insertoverwrite or multi job udpate 、insertoverwrite different partition concurrently. TransactionUtils.resolveWriteConflictIfAny getCandidateInstants function want to get pending clustering. Now get pending clustering instants by REPLACE_COMMIT_ACTION, actually here get both clustering and **insertoverwrite** instants. So, I think we can continue filter by get clusteringplan is present ， it will get only clustering instant。 can we rosolve in this way？ -- 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]
