Thanks a lot for reporting this potential issue. The ticket looks good.

I would suggest to keep the discussion on the ticket. Otherwise,
information will potentially be split between this list and the ticket.
I'm sure a committer will soon look at it.

On Wed, Mar 18, 2020 at 5:19 AM Bashar Abdul-Jawad <amma...@gmail.com>
wrote:

> 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:
>
>  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());
> }
>
> I filed https://issues.apache.org/jira/browse/FLINK-16638, please let me
> know if I am missing something here.
>
>
>

Reply via email to