Skip to content

Commit

Permalink
[hotfix][checkpointing] Make CheckpointBarrierUnaligner#processEndOfP…
Browse files Browse the repository at this point in the history
…artition always return false

For unaligned checkpoint, no buffer is stored in BufferStorage so CheckpointBarrierUnaligner#processEndOfPartition should always return false.

This closes apache#11351.
  • Loading branch information
wsry authored and zhijiangW committed Apr 27, 2020
1 parent 90a38e8 commit 4540a83
Showing 1 changed file with 0 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -206,7 +206,6 @@ public boolean processEndOfPartition() throws Exception {
new CheckpointException(CheckpointFailureReason.CHECKPOINT_DECLINED_INPUT_END_OF_STREAM));
// no chance to complete this checkpoint
releaseBlocksAndResetBarriers();
return true;
}
return false;
}
Expand Down

0 comments on commit 4540a83

Please sign in to comment.