echauchot commented on PR #37: URL: https://github.com/apache/flink-connector-cassandra/pull/37#issuecomment-3270172290
> > > Hey @echauchot . Thanks for the diff. It makes sense to me. Added some comments. One issue, when I ran `mvn clean install` on my local Mac (on PR#37) it failed because of (passes on main branch): > > > ``` > > > org.apache.flink.connector.cassandra.source.CassandraSourceITCase.testSourceSingleSplit(TestEnvironment, DataStreamSourceExternalContext, CheckpointingMode)[1] Time elapsed: 0.188 s <<< ERROR! > > > com.datastax.driver.core.exceptions.WriteFailureException: Cassandra failure during write query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed) > > > ``` > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > Typically a timing/cluster-readiness problem in tests, not a logic bug—especially if CI is green. So i am unable to get the test running on my local, but since the CI is green maybe there is an issue with my setup. (I tried giving Docker more CPU/RAM but coudn't get it working). > > > > > > Yes I have this from time to time on my laptop I could raise the configured query timeouts and also see with the new startup conditions. > > One thing strikes me though: the write query uses CL=1 whereas it should use lower CL=ANY as org.apache.flink.connector.cassandra.CassandraTestEnvironment#builderForWriting is configured with CL=ANY. This means that somehow org.apache.flink.connector.cassandra.CassandraTestEnvironment#builderForReading (CL=1) is used for writing as well Ah no, the builders are used for the old connectors tests. It is in org.apache.flink.connector.testframe.external.ExternalSystemSplitDataWriter#writeRecords at the mapper side that it needs to be configured -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
