[FLINK-25424] Checkpointing is currently not supported for operators that implement InputSelectable

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Runtime / Checkpointing
• Assignee: Unassigned
• Reporter: Zhipeng Zhang
• Created: 23/Dec/21 06:15
• Updated: 30/Dec/21 15:13
• Resolved: 30/Dec/21 15:13

Description

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.

Issue Links

• duplicates: FLINK-17122 Support InputSelectable and BoundedMultiInput operators with checkpointing