This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git
from cc478e2 [FLINK-26823] [Connector] [Cassandra] Added Cassandra Table
Source Implementation
new ebbc218 [FLINK-37937] Add a node to Cassandra testContainers cluster
new 4441649 [FLINK-37937] Use nodetool refreshsizeestimates in addition
to flush to update size estimates: flush updates the SSTables and
refreshsizeestimates updates the size estimates based on them
new df6a40b [FLINK-37937] change timeouts using cassandra.yaml instead of
java options that are not interpreted by Cassandra cluster
new c8dcb55 [FLINK-37937] upgrade to latest cassandra 4.x. reformat
new eb10f9e [FLINK-37937] Make estimatedTableSize calculated during split
preparation accessible to tests and not call estimate_size during tests. In
refreshSizeEstimates wait until system.size_estimates has at least a row that
has non-null mean_partition_size
new e53d28a [FLINK-37937] Improve start/stop for the 2-container cluster.
new 191e50a [FLINK-37937] Deal with timeouts: put consistency level to
ONE to be coherent between read and write request because CL=ANY in write
requests could lead to hint writes that would be invisible to subsequent read
requests. Raise write request timeout to the same timeout as read request. Put
replication factor to 2 to deal with temporary down cassandra container. But
back sequential start of the 2 containers.
new 84c3fa0 [FLINK-37937] Rebase on main and reference
cassandraContainer1 instead of cassandraContainer
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../dcfaa83d-a12c-48e1-9e51-b8d3808cd287 | 2 +-
.../cassandra/source/split/SplitsGenerator.java | 19 +-
.../cassandra/example/BatchPojoExample.java | 2 +-
.../cassandra/CassandraTestEnvironment.java | 145 +-
.../cassandra/source/CassandraSourceITCase.java | 10 +-
.../cassandra/source/CassandraTestContext.java | 8 +-
.../src/test/resources/cassandra.yaml | 1877 ++++++++++++++++++++
7 files changed, 2004 insertions(+), 59 deletions(-)
create mode 100644 flink-connector-cassandra/src/test/resources/cassandra.yaml
