yuzhaojing created HUDI-1954:
--------------------------------
Summary: StreamWriterFunction only reset when flush success
Key: HUDI-1954
URL: https://issues.apache.org/jira/browse/HUDI-1954
Project: Apache Hudi
Issue Type: Improvement
Components: Flink Integration
Reporter: yuzhaojing
Assignee: yuzhaojing
Now StreamWriterFunction flush bucket is unsafe. When instant is null,
flushBucket will return immediately, and then reset this bucket resulting in
data loss.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
