Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/937#issuecomment-125537856
I can rewrite this of course and create new test classes but in any way the
StreamCheckpointingIT case needs to be changed because it was not well designed
in the first place.
It had uncommented tests, and never checked checkpointing after shuffle
which was in fact broken for some reason I am still not sure (see some notes
above).
My only worry is that if we add new test classes for all the cases,
checkpointed, partitioned, non-partitioned (where the checkpointing actually
happens together with the same logic so I don't see a reason for having
separate test) then we end up with a lot of these pretty heavy tests.
---
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.
---
