twosom commented on code in PR #641:
URL: https://github.com/apache/flink-agents/pull/641#discussion_r3208707689
##########
runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java:
##########
@@ -411,6 +442,8 @@ private void processEvent(Object key, Event event) throws
Exception {
// If the event is an InputEvent, we submit a new mail to try
processing the actions.
mailboxExecutor.submit(() -> tryProcessActionTaskForKey(key),
"process action task");
}
+
+ notifyEventProcessed(event);
Review Comment:
Hi @wenjin272
I've updated the PR as suggested. Could you take another look? Thanks!
--
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]
