orpiske commented on issue #67: Flaky test: CamelSinkCassandraITCase URL: https://github.com/apache/camel-kafka-connector/issues/67#issuecomment-573396777 > @orpiske any idea on this one? I think so. It looks like I inadvertently added a time-of-check-time-of-use kind of bug. I was looking at the [hasData](https://github.com/apache/camel-kafka-connector/blob/master/tests/src/test/java/org/apache/camel/kafkaconnector/clients/cassandra/dao/TestDataDao.java#L82) and I am only checking if some amount of data is in the table and not if the right amount of data is there. This could cause the wait to release too early and the subsequent check for the right amount of messages to fail. I'll send a PR to fix this.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services