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
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
