[
https://issues.apache.org/jira/browse/FLINK-5113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721823#comment-15721823
]
ASF GitHub Bot commented on FLINK-5113:
---------------------------------------
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2939
[FLINK-5113] Ports all functions in the tests to the new checkpointing
interface.
This PR only touches testing code.
It refactors all the tests that were using the `Checkpointed` and
`CheckpointedAsynchronously` interfaces to use the new `ListCheckpointed` and
`CheckpointedFunction` ones.
There is one commit per class, but the changes are very small and easy to
review.
R: @aljoscha @zentol
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink test-func-ref-reb
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2939.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2939
----
commit e8eecc97385b66dccdc31c057591e265e1dfc963
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-22T17:38:54Z
[FLINK-5113] CoStreamCheckpointingITCase refactoring.
commit 588d98175bf14699fca8ef0117ee37f2acdb8c65
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-22T18:23:33Z
[FLINK-5113] EventTimeAllWindowCheckpointingITCase refactoring.
commit 31d642eeafd98587999cd1ec69aff87b6224f941
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-22T18:32:24Z
[FLINK-5113] AbstractEventTimeWindowCheckpointingITCase refactoring.
commit 26a1ffefaf4b7fa01b7df80bd175e98337a0eef0
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-22T18:49:47Z
[FLINK-5113] StreamCheckpointingITCase refactoring.
commit efacdbd5fce6e3ebb590a952da3f8e1b1b7b42ea
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T10:49:24Z
[FLINK-5113] StreamCheckpointNotifierITCase refactoring
commit 9815ee405fa21d875963039cb145eea21025e737
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T10:56:06Z
[FLINK-5113] BucketingSinkFaultToleranceITCase refactoring.
commit b1cc019622fedcb08b0e0a232a3deedd2c4e37c5
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T11:11:11Z
[FLINK-5113] StateCheckpointedITCase refactoring
commit f6e73c2fe6f34953e5029ba79845b720ac5a0c05
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T11:21:24Z
[FLINK-5113] CheckpointingCustomKvStateProgram refactoring.
commit d6c4ad75f7f47c872fb5fb6650c9f3a111a55108
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T11:31:11Z
[FLINK-5113] JobManagerHACheckpointRecoveryITCase refactoring
commit 7a99f7bb186be2a235ba28e3d61d65f60a82b571
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T13:14:40Z
[FLINK-5113] CheckpointedStreamingProgram refactoring.
commit 30096fe6399c8fd3f14bd5c23af4ee1506ca26e2
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T13:24:54Z
[FLINK-5113] WindowCheckpointingITCase refactoring.
commit 02424d0ea88986618cb66d9b5d902e86512981dc
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T13:31:18Z
[FLINK-5113] TaskManagerProcessFailureStreamingRecoveryITCase refactoring.
commit 65eed028ff2af4106b509c55f2cf15c902e6f6d6
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T13:41:58Z
[FLINK-5113] RescalingITCase refactoring
commit f25c387d919eb569fd80abbf3621e3482c9fdb79
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T13:55:02Z
[FLINK-5113] CassandraTupleWriteAheadSinkExample refactoring.
commit 6071795423b3c9bf5143c32c93ce69e159e9bb4f
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T14:02:10Z
[FLINK-5113] SavepointITCase refactoring.
commit 4212d45a5592f83016864d4a588219672797142e
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T14:11:29Z
[FLINK-5113] ChaosMonkeyITCase refactoring.
commit 32738006d4e48ac42985ed2b77b9b6555e352e75
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T14:16:37Z
[FLINK-5113] UdfStreamOperatorCheckpointingITCase refactoring.
commit a7e883ff6d1c56e84be4ed49e0b53acab2bce54d
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T14:19:58Z
[FLINK-5113] InterruptSensitiveRestoreTest refactoring.
commit 6c1acbba4f3bae5c3b5ba812beafa3caeddc4a0f
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T16:08:38Z
[FLINK-5113] KafkaConsumerTestBase refactored.
commit b88d9085ddedff90e68534b84450796d9edd3396
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T16:12:35Z
[FLINK-5113] ValidatingExactlyOnceSink refactoring.
commit a9e2d86177ccd446bc13e353e09cbb5c8c0a7016
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T16:21:19Z
[FLINK-5113] PartitionedStateCheckpointingITCase refactoring.
commit 8161507acf63926e52dcd0952565017aafaa1359
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T16:34:45Z
[FLINK-5113] FailingIdentityMapper refactoring.
commit ff8ee23ccc6b5ba95151dda03f4279cde0e58af1
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T16:48:31Z
[FLINK-5113] SourceStreamTaskTest refactoring.
commit 2ca6348f4802f3ae744aa1bab829a4df85b2ca08
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-23T16:54:03Z
[FLINK-5113] RollingSinkFaultToleranceITCase refactoring.
commit c4b029cd3d30d3bc59715291d7e48da97cca48eb
Author: kl0u <kklou...@gmail.com>
Date: 2016-11-28T19:07:52Z
[FLINK-5113] InterruptSensitiveRestoreTest
----
> 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)
