[ https://issues.apache.org/jira/browse/FLINK-25424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Piotr Nowojski closed FLINK-25424. ---------------------------------- Resolution: Duplicate Hi [~ghandzhipeng]. Thanks for rising this issue. This is a well known limitation and a duplicate of FLINK-17122 ticket. Please check that ticket for more information, as this is unfortunately not an easy change. > Checkpointing is currently not supported for operators that implement > InputSelectable > ------------------------------------------------------------------------------------- > > Key: FLINK-25424 > URL: https://issues.apache.org/jira/browse/FLINK-25424 > Project: Flink > Issue Type: New Feature > Components: Runtime / Checkpointing > Reporter: Zhipeng Zhang > Priority: Major > > Flink DataStream runtime does not support checkpointing for operators that > implements `InputSelectable` interface. > It throws an UnsupportedOperationExcetpion when checking the StreamJobGraph — > "Checkpointing is currently not supported for operators that implement > InputSelectable". > > The machine learning use case is as follows: > We have a two-input operator A. The first input of A is the model parameters, > the second input of A is the training data. > In this case, we have to read the model parameters first, then we read the > training data. That is we need to finish consuming the first input before we > consume the second. -- This message was sent by Atlassian Jira (v8.20.1#820001)