[FLINK-16638] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.9.1, 1.10.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Eduardo Winpenny Tejedor
• Reporter: Bashar Abdul Jawad
• Created: 18/Mar/20 00:52
• Updated: 07/May/20 15:55
• Resolved: 07/May/20 15:55

Description

StateAssignmentOperation.checkStateMappingCompleteness doesn't check for UserDefinedOperatorIDs (specified using setUidHash), causing the exception:

 java.lang.IllegalStateException: There is no operator for the state {}

to be thrown when a savepoint can't be mapped to an ExecutionJobVertex, even when the operator hash is explicitly specified.

I believe this logic should be extended to also include UserDefinedOperatorIDs as so:

for (ExecutionJobVertex executionJobVertex : tasks) {
  allOperatorIDs.addAll(executionJobVertex.getOperatorIDs());
  allOperatorIDs.addAll(executionJobVertex.getUserDefinedOperatorIDs());
}

Issue Links

• links to: GitHub Pull Request #11952