[FLINK-5101] Test CassandraConnectorITCase instable

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3.0, 1.4.0
• Component/s: Connectors / Cassandra
• Assignee: Chesnay Schepler
• Reporter: Stefan Richter
• Created: 18/Nov/16 17:30
• Updated: 12/May/17 21:47
• Resolved: 12/May/17 21:47

Description

I observed this test fail on Travis (very rarely):

Running org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase

Tests run: 7, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 80.843 sec <<< FAILURE! - in org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase
testCassandraBatchFormats(org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase) Time elapsed: 5.82 sec <<< FAILURE!
java.lang.AssertionError: expected:<40> but was:<20>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.testCassandraBatchFormats(CassandraConnectorITCase.java:442)

Issue Links

• links to: GitHub Pull Request #2866
• links to: GitHub Pull Request #3072