[ https://issues.apache.org/jira/browse/FLINK-5113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735514#comment-15735514 ]
ASF GitHub Bot commented on FLINK-5113: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2939#discussion_r91721509 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpointedITCase.java --- @@ -47,7 +47,7 @@ * A simple test that runs a streaming topology with checkpointing enabled. * * The test triggers a failure after a while and verifies that, after completion, the - * state defined with either the {@link ValueState} or the {@link Checkpointed} + * state defined with either the {@link ValueState} or the {@link org.apache.flink.streaming.api.checkpoint.ListCheckpointed} --- End diff -- do not use the fully qualified class name here. (it's not required since you import the class anyway ;) ) > Make all Testing Functions implement CheckpointedFunction Interface. > -------------------------------------------------------------------- > > Key: FLINK-5113 > URL: https://issues.apache.org/jira/browse/FLINK-5113 > Project: Flink > Issue Type: Improvement > Components: DataStream API > Affects Versions: 1.2.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Fix For: 1.2.0 > > > Currently stateful functions implement the (old) Checkpointed interface. > This is issue aims at porting all these function to the new > CheckpointedFunction interface, so that they can leverage the new > capabilities by it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)