Poorvankbhatia opened a new pull request, #36:
URL: https://github.com/apache/flink-connector-cassandra/pull/36
### Summary
- Copy WriteAheadSinkTestBase locally to fix test compilation after it
became package-private
- Restore write-ahead sink test functionality for
CassandraTupleWriteAheadSink and CassandraRowWriteAheadSink
- All 13 write-ahead sink tests now pass successfully
### Description
During Flink's JUnit 5 migration
([FLINK-25544](https://issues.apache.org/jira/browse/FLINK-25544)),
[WriteAheadSinkTestBase](https://github.com/apache/flink/pull/24483/files#diff-42e96a82636da2fce830f59567fa10ea7e8d116e008d1bf1d1e59ce59e73f976)
in flink became package-private, breaking external connectors that extended it
for testing write-ahead sink functionality.
The Cassandra connector's CassandraConnectorITCase extends
WriteAheadSinkTestBase to test exactly-once semantics and checkpoint recovery
behavior for its write-ahead sink implementations. With the visibility change,
these critical tests could no longer compile (when the Flink version is
upgraded)
### Changes
- Added:
src/test/java/org/apache/flink/streaming/runtime/operators/WriteAheadSinkTestBase.java
- Local copy from Flink 1.16 with JUnit 4 annotations
- Javadoc explaining the copy rationale and FLINK-38034 reference
### Test Results
- All write-ahead sink tests now pass
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
