[
https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087906#comment-17087906
]
Piotr Nowojski edited comment on FLINK-16638 at 4/20/20, 4:25 PM:
------------------------------------------------------------------
Hey [~basharaj], could we get another estimate when could you work on this
ticket? Sorry for putting a pressure, but it's relatively easy to be fixed, so
we would like it to be fixed for 1.11 release. If you can not work on it in the
next week or so, someone might need to take it over.
was (Author: pnowojski):
Hey [~basharaj], could we get another estimate when could you work on this
ticket? It's relatively easy to be fixed, so we would like it to be fixed for
1.11 release. If you can not work on it in the next week or so, someone might
need to take it over.
> Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs
> --------------------------------------------------------------------------
>
> Key: FLINK-16638
> URL: https://issues.apache.org/jira/browse/FLINK-16638
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.9.1, 1.10.0
> Reporter: Bashar Abdul Jawad
> Assignee: Bashar Abdul Jawad
> Priority: Critical
> Fix For: 1.11.0
>
>
> [StateAssignmentOperation.checkStateMappingCompleteness|https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java#L555]
> doesn't check for UserDefinedOperatorIDs (specified using setUidHash),
> causing the exception:
> {code}
> java.lang.IllegalStateException: There is no operator for the state {}
> {code}
> 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:
> {code:java}
> for (ExecutionJobVertex executionJobVertex : tasks) {
> allOperatorIDs.addAll(executionJobVertex.getOperatorIDs());
> allOperatorIDs.addAll(executionJobVertex.getUserDefinedOperatorIDs());
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
