Skip to content

Commit

Permalink
Update javadoc
Browse files Browse the repository at this point in the history
  • Loading branch information
Urmi Mustafi committed Oct 17, 2023
1 parent 627e7ec commit afaedbe
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,6 @@ public static DagActionStore.DagAction updateFlowExecutionId(DagActionStore.DagA
return new DagActionStore.DagAction(flowAction.getFlowGroup(), flowAction.getFlowName(),
String.valueOf(eventTimeMillis), flowAction.getFlowActionType());
}

}


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,8 +89,7 @@ class LeaseObtainedStatus extends LeaseAttemptStatus {
private final long leaseAcquisitionTimestamp;

/**
* Returns event time in millis since epoch for the event of this lease acquisition.
* @return
* @return event time in millis since epoch for the event of this lease acquisition
*/
public long getEventTimeMillis() {
return Long.parseLong(flowAction.getFlowExecutionId());
Expand All @@ -99,8 +98,8 @@ public long getEventTimeMillis() {

/*
This flow action event already has a valid lease owned by another participant.
`Flow action`'s flow execution id is the timestamp the lease is associated with, which may be a different timestamp
for the same flow action corresponding to the same instance of the event or a distinct one.
`Flow action`'s flow execution id is the timestamp the lease is associated with, however the flow action event it
corresponds to may be a different and distinct occurrence of the same event.
`minimumLingerDurationMillis` is the minimum amount of time to wait before this participant should return to check if
the lease has completed or expired
*/
Expand Down

0 comments on commit afaedbe

Please sign in to comment.