[HUDI-2542] AppendWriteFunction throws NPE when checkpointing without written data (#3777)
This commit is contained in:
@@ -122,6 +122,10 @@ public class AppendWriteFunction<I> extends AbstractStreamWriteFunction<I> {
|
||||
}
|
||||
|
||||
private void flushData(boolean endInput) {
|
||||
if (this.writerHelper == null) {
|
||||
// does not process any inputs, returns early.
|
||||
return;
|
||||
}
|
||||
final List<WriteStatus> writeStatus = this.writerHelper.getWriteStatuses(this.taskID);
|
||||
final WriteMetadataEvent event = WriteMetadataEvent.builder()
|
||||
.taskID(taskID)
|
||||
|
||||
Reference in New Issue
Block a user