[
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)
