abhishekmjain commented on code in PR #4118:
URL: https://github.com/apache/gobblin/pull/4118#discussion_r2209725355
##########
gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ProcessWorkUnitsWorkflowImpl.java:
##########
@@ -104,7 +126,18 @@ private CommitStats
performCommitIfAnyWorkUnitsProcessed(WUProcessingSpec workSp
return CommitStats.createEmpty();
}
CommitStepWorkflow commitWorkflow =
createCommitStepWorkflow(searchAttributes);
+ Map<String, String> attributes = new HashMap<>();
+ attributes.put(CURR_STATE, COMMIT_STEP_START);
Review Comment:
If we are doing this here then let's remove the one added in
`CommitStepWorkflowImpl.java`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
