GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2866
[FLINK-5101] Refactor CassandraConnectorITCase
This PR refactors the CassandraConnectorITCase to be a bit more stable and
easier to debug.
The following changes were made:
* we no longer run actual flink jobs; all tests directly interact with the
sink to save resources
* every test uses a different table, preventing race conditions related to
truncating the table
* the at-least-once sinks were modified to track pending updates
=> the pojo sink was modified to use a method that returns an actually
useful `Future`
=> since the sink waits in `close()` for pending updates it can no longer
occur that a test checks a condition prematurely, improving stability
* the initial connection is established across a time-span of 30 seconds,
increasing the chance that cassandra has started before the tests are run
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 4177_cass_test
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2866.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 #2866
----
commit e2cb8b9dc1131422dc97c0c08cbacd39cb747a44
Author: zentol <ches...@apache.org>
Date: 2016-11-23T15:59:22Z
[FLINK-5101] Track pending records in CassandraSinkBase
commit 4c74937fac3e112f24a1af62d529153ce3aabb68
Author: zentol <ches...@apache.org>
Date: 2016-11-23T16:29:51Z
[FLINK-5101] Refactor CassandraConnectorITCase
----
---
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.
---
