Dinesh created FLINK-34501:
------------------------------
Summary: In AsyncWaitOperator,
ResultHandler.completeExceptionally() triggeres task/job restarts after max
retry is reached
Key: FLINK-34501
URL: https://issues.apache.org/jira/browse/FLINK-34501
Project: Flink
Issue Type: Improvement
Components: API / DataStream
Reporter: Dinesh
In AsyncWaitOperator, ResultHandler.completeExceptionally() triggeres task/job
restarts after max retry is reached.
Instead can we allow user to decide on how to handle the exception to avoid job
restarts.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)