Re: [I] flink stream write reuse abort instant will lead to coordinator delete file not right. [hudi]

["nsivabalan (via GitHub)" <gi...@apache.org>]

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

   This looks fixed on current `master`. The racy `instantToWrite` path that could reuse an older aborted instant was rewritten in [`e34a7ab8` — `[HUDI-9381] Async instant time generation of Flink writers (#13285)`](https://github.com/apache/hudi/commit/e34a7ab8152e725222aa6f7a76ccbce6cee0dae7). Write tasks no longer derive the instant from `lastPendingInstant()`/`CkpMetadata`; instead `AbstractStreamWriteFunction#instantToWrite` RPCs the coordinator (`Correspondent.requestInstantTime(checkpointId)`), and the coordinator maintains a single `ckp-id → instant` mapping under a global lock. That removes the window where a task and the coordinator could disagree on the active instant. Closing as fixed — please reopen with a current-master repro if you still see this.


-- 
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