echauchot commented on PR #19586:
URL: https://github.com/apache/flink/pull/19586#issuecomment-1121051329
> > I could be in that case the uncovered race condition won't be fixed. So
the output formats tests would fail on cassandra 4.0 between the two PR merges.
I guess if we merge the two P
echauchot commented on PR #19586:
URL: https://github.com/apache/flink/pull/19586#issuecomment-1121050292
> Please note that the existing class `CassandraOutputFormatBase` that was
previously used as a base class only for Tuple and Row outputFormats is now
used as a base class for the 3 out
echauchot commented on PR #19586:
URL: https://github.com/apache/flink/pull/19586#issuecomment-1119594598
> Would you mind moving the flushing changes into another PR?
I could be in that case the uncovered race condition won't be fixed. So the
output formats tests would fail on cassan
echauchot commented on PR #19586:
URL: https://github.com/apache/flink/pull/19586#issuecomment-1119360748
@zentol I added the flush mechanism to all Cassandra output formats and the
related tests (vastly inspired from `CassandraSinkBaseTest`) in the 3 last
commits (different ticket). Please
