Skip to content

Commit

Permalink
fix doc style
Browse files Browse the repository at this point in the history
  • Loading branch information
binjie yang committed Jan 7, 2025
1 parent becc6b0 commit 1671c86
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -199,10 +199,9 @@ protected void pushGiantRecord(int partitionId, byte[] buffer, int numBytes) thr
}

/**
* This method will push the remaining data and close these pushers.
* It's important, will send Mapper End RPC to LifecycleManager to update
* the attempt of the corresponding task.
* We should only call this method when the task is successfully completed.
* This method will push the remaining data and close these pushers. It's important, will send
* Mapper End RPC to LifecycleManager to update the attempt of the corresponding task. We should
* only call this method when the task is successfully completed.
*/
protected void close() throws IOException, InterruptedException {
long pushMergedDataTime = System.nanoTime();
Expand Down

0 comments on commit 1671c86

Please sign in to comment.