[ https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080538#comment-17080538 ]
Yubao Liu edited comment on FLINK-11879 at 4/10/20, 2:52 PM: ------------------------------------------------------------- [~sunhaibotb] I use [https://github.com/apache/flink/blob/release-1.10.0/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/TestSequentialReadingStreamOperator.java] to sequentially read a mysql table snapshot and a Kafka binlog stream, how can I enable checkpointing for operators implementing `InputSelectable` and `BoundedMultiInput` ? was (Author: li...@yahoo-inc.com): [~sunhaibotb] I use [https://github.com/apache/flink/blob/release-1.10.0/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/TestSequentialReadingStreamOperator.java] to sequentially read a mysql table snapshot and a Kafka binlog stream, how can I enable checkpointing for operators implementing `InputSelectable` and `BounedMultiInput` ? > Add JobGraph validators for the uses of InputSelectable, BoundedOneInput and > BoundedMultiInput > ---------------------------------------------------------------------------------------------- > > Key: FLINK-11879 > URL: https://issues.apache.org/jira/browse/FLINK-11879 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task > Reporter: Haibo Sun > Assignee: Haibo Sun > Priority: Major > Labels: pull-request-available > Fix For: 1.10.0 > > Time Spent: 20m > Remaining Estimate: 0h > > - Rejects the jobs containing operators which were implemented > `InputSelectable` in case of enabled checkpointing. > - Rejects the jobs containing operators which were implemented > `BoundedInput` or `BoundedMultiInput` in case of enabled checkpointing. > - Rejects the jobs containing operators which were implemented > `InputSelectable` in case that credit-based flow control is disabled. -- This message was sent by Atlassian Jira (v8.3.4#803005)