[FLINK-34501] In AsyncWaitOperator, ResultHandler.completeExceptionally() triggeres task/job restarts after max retry is reached - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Open
Priority: Major
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: None
Component/s: API / DataStream
Labels:
- pull-request-available

Description

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.

Attachments

Activity

People

Assignee:: Unassigned

Reporter:: Dinesh

Votes:: 0 Vote for this issue

Watchers:: 1 Start watching this issue

Dates

Created:: 22/Feb/24 22:41

Updated:: 28/Feb/24 02:55