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. > > >
