(flink-connector-cassandra) branch main updated (986fda5 -> 19bca45)

[ec...@apache.org]

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 986fda5  [FLINK-37513] Test that fields and table names can contain prohibited string literals as we are validating queries regexp using function calls now.
     add 7b03ece  [FLINK-38048] Remove java 8 from ci workflows
     add 19bca45  [FLINK-38042] Warn the user on full table scans: introduce QueryValidator and migrate unit test in integration test to use the cluster.

No new revisions were added by this update.

Summary of changes:
 .github/workflows/push_pr.yml                      |   2 +-
 .github/workflows/weekly.yml                       |   2 +-
 .../dcfaa83d-a12c-48e1-9e51-b8d3808cd287           |  19 ++-
 .../cassandra/source/CassandraSource.java          |  20 +--
 .../source/reader/CassandraSourceReader.java       |   5 +-
 .../reader/CassandraSourceReaderFactory.java       |   6 +-
 .../source/reader/CassandraSplitReader.java        |  23 +--
 ...SerializationUtils.java => CassandraUtils.java} |  31 ++--
 .../cassandra/source/utils/QueryValidator.java     | 123 ++++++++++++++
 .../cassandra/CassandraTestEnvironment.java        |  32 +++-
 .../cassandra/source/CassandraSourceITCase.java    | 188 +++++++++++++++++++--
 .../source/reader/CassandraQueryTest.java          | 124 --------------
 12 files changed, 373 insertions(+), 202 deletions(-)
 copy flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/utils/{BigIntegerSerializationUtils.java => CassandraUtils.java} (54%)
 create mode 100644 flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/utils/QueryValidator.java
 delete mode 100644 flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/source/reader/CassandraQueryTest.java