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)