[FLINK-4131] Confusing error for out dated RequestPartitionState - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Closed
Priority: Major
Resolution: Duplicate
Affects Version/s: None
Fix Version/s: None
Component/s: None
Labels:
None

Description

When a consumer requests a partition state for an old job or execution attempt (e.g. failed job or attempt), the JobManager answers with a null state, which fails the requesting task with the following cause: IllegalStateException("Received unexpected partition state null for partition request. This is a bug.").

This is confusing to the user as one might think that this is the root failure cause.

I propose to either ignore the null state at the Task or not respond on the JobManager side if the job or execution attempt has been cleared (see RequestPartitionState in JobManager.scala).