loukey-lj opened a new pull request #2419: URL: https://github.com/apache/hudi/pull/2419
Improvement of failure recovery for HoodieFlinkStreamer. When HoodieFlinkStreamer failure recovery from a checkpoint or savepoint KeyedWriteProcessOperator will get an instant time from flink state, if instant state is INFLIGHT indicate KeyedWriteProcessFunction operator snapshot successed but CommitSink operator do commit failed, so need to get the writeStatus from state and send to sink operator again. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
