This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch cas_rewrite in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git
at 3a1f68a [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5 This branch includes the following new commits: new d1f1a99 [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module. new 601c314 [FLINK-5020] Make the GenericWriteAheadSink rescalable. new 6aa83db [build system] Update version to 1.3-SNAPSHOT new cbc7d2c [FLINK-5113] Port functions in tests to new CheckpointedFunction IF. new 3a2776e [FLINK-5480] [savepoints] Add setUidHash method to DataStream API new f02228f [FLINK-6084][Cassandra] Promote transitive dependencies new 46d9595 Update Flink version to 1.4-SNAPSHOT new 5f7e0cf [FLINK-6414] [build] Use scala.binary.version in place of change-scala-version.sh new d4db106 [FLINK-5101] Track pending records in CassandraSinkBase new a043b28 [FLINK-5101] Refactor CassandraConnectorITCase new 11eda4a [FLINK-4497] [cassandra] Scala Case Classes / Tuple support new fcecb60 [hotfix] Fix CassandraConnectorITCase new d497c07 [hotfix] Really fix CassandraConnectorITCase new a7c8bb6 [FLINK-6711] Activate strict checkstyle for flink-connector-cassandra new 8b8b8fa [FLINK-6868][build] Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` new 8424127 [FLINK-7149] [connectors] Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink new 867b28f [FLINK-7253] [tests] Remove CommonTestUtils#assumeJava8 new 5f02a5c [FLINK-7415] [cassandra] Add example instructions for creating keyspace new 2a9e0c2 [FLINK-7552] Extend SinkFunction interface with SinkContext new d22b511 [FLINK-6805] [cassandra] Shade indirect netty4 dependency new c193f91 [hotfix] Fix typo in CassandraSink new 7224606 [FLINK-6314] [cassandra] Support user-defined Mapper options new c865b11 [FLINK-6225] [cassandra] Add a CassandraAppendTableSink. new 0bd5f9b Update version to 1.5-SNAPSHOT new 453700c [FLINK-4500] CassandraSinkBase implements CheckpointedFunction new 96e66a4 [FLINK-8113][build] Bump maven-shade-plugin to 3.0.0 new a313f96 [FLINK-8295] [cassandra] [build] Properly shade netty for the datastax driver new 0dc855d [FLINK-8122] [table] Name all built-in table sinks and sources new 90022e5 [FLINK-8397] [cassandra] Add CassandraRowOutputFormat. new e6ec8fb [FLINK-8401] [cassandra] Add callback methods for failed and successful writes to CassandraOutputFormatBase. new 30dce17 [FLINK-8520][cassandra] Fix race condition new c06ce64 Update version to 1.6-SNAPSHOT new 77f4aa2 [hotfix][cassandra] Add no-org constructor to example POJO new 155e076 [FLINK-8655][cassandra] Support default keyspace for POJOs new 7544a64 Update version to 1.7-SNAPSHOT new cfc3855 [FLINK-6670][tests] Remove CommonTestUtils#createTempDirectory new 890c2de [FLINK-9126][cassandra] Add Pojo InputFormat new e77579a [FLINK-9126][cassandra] Finalize Pojo InputFormat new df8ea81 [hotfix][cassandra][tests] Close sources/sinks in finally block new 5627ae0 [FLINK-10310] Cassandra Sink - Handling failing requests. new 0f152a0 [FLINK-10156][table] Deprecate Table.writeToSink(). new c093e38 [FLINK-10528][table] Remove methods that were deprecated in Flink 1.4.0. new 8a7915b [FLINK-10440][cassandra] Add CassandraPojoOutputFormat new a2d388c [hotfix][javadocs] Replace odd single quotes new da4d4d6 Update version to 1.8-SNAPSHOT new 098c721 [FLINK-9083][cassandra] Restructure CassandraSinkBase new 5052824 [FLINK-9083][cassandra] Refactor CassandraSinkBaseTest new 33ab529 [FLINK-9083][cassandra] Add async backpressure support new 132ab88 [FLINK-11023] Add LICENSE & NOTICE files for flink-connector-cassandra new 0e658a7 [FLINK-11064] [table] Setup a new flink-table module structure new e3d9f23 [FLINK-11445][table] Deprecate static methods in TableEnvironment new 6e5c34b [FLINK-11450][table] Port and move TableSource and TableSink related classes to flink-table-common new b75918c Update version to 1.9-SNAPSHOT new 518aa3d [FLINK-11901][build] Update NOTICE files with year 2019 new d07225a [FLINK-12117][cassandra] Disable tests on Java 9 new 4310bb3 [FLINK-11067][table] Convert TableEnvironments to interfaces new fc46c0a [FLINK-12297] Make Java ClosureCleaner recursive to handle nested functions new 28f37c3 [FLINK-12985][core][streaming] Rename StreamTransformation to org.apache.flink.api.dag.Transformation new 31a8dd5 [FLINK-12820] [Connectors / Cassandra] Support ignoring writing nulls for tuple types new 718f52f [FLINK-12602][travis] Correct the flink pom `artifactId` config and s… (#8563) new 39174ab Update version to 1.10-SNAPSHOT new f81d85d [FLINK-13341][table][connectors] StreamTableSink#consumeDataStream returns DataStreamSink when using blink planner. new 600e787 [FLINK-13544][connectors] Set parallelism of table sink operator to input transformation parallelism new ef8fabb [FLINK-13533][cassandra] Disable tests on Java 11 new 3048a05 [FLINK-13059][cassandra] Release semaphore on exception in send() new 55ffe5c [FLINK-13457][build][travis] Remove JDK 9 support new 0e4e062 [hotfix] Remove .toDelete from flink-connector-cassandra new 707def0 [FLINK-14076] Ensure CheckpointException can be deserialized on JobManager new 1c016d4 [FLINK-14334][es][docs] Use ExceptionUtils#findThrowable new ac0b720 [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() new ad1bcaf Update version to 1.11-SNAPSHOT new 2e7336c [FLINK-15672][build][tests] Migrate test log4j configurations to log4j2 new 878d023 [FLINK-16362][table] Remove deprecated `emitDataStream` method in StreamTableSink new 75efa6e [FLINK-16363][table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment new efff105 [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files new ca8a881 [FLINK-16035] Updated Stream/BatchTableEnvironment.java to use Java's Expression DSL new d079dd3 [FLINK-16961][cassandra] Bump Netty to 4.1.44 new 5667a0d [FLINK-17339][misc] Update tests due to default planner changing. new 2e55df9 [FLINK-16364][table] Deprecate the methods in TableEnvironment & Table proposed by FLIP-84 new d9735b9 [FLINK-17748][table] Remove registration of TableSource/TableSink in table env new c67aa86 Update version to 1.12-SNAPSHOT new 9841217 [FLINK-15947] Fix table implicit conversions structure new 520e229 [FLINK-18607][build] Give the maven module a human readable name new a6b9b1c [FLINK-18337][table] Introduce TableResult#await method to block until data is ready or job finished new 26064e7 [FLINK-19511] Rename the 'SinkTransformation' to 'LegacySinkTransformation' new 01d6696 Update version to 1.13-SNAPSHOT new 3d68796 Revert "[FLINK-14076] Ensure CheckpointException can be deserialized on JobManager" new 91569fb [FLINK-20651] Fix formatting that doesn't work with google-java-format/checkstyle new 9f36685 [FLINK-20651] Format code with Spotless/google-java-format new 8e489f0 [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files. new be87ccc [FLINK-21019][cassandra] Bump Netty to 4.1.46 new 8c6fc60 Update version to 1.14-SNAPSHOT new 0de0f2f [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException new d45b5e8 [FLINK-22560][build] Move generic filters/transformers into general shade-plugin configuration new a71da3c [FLINK-23085] Move FutureUtils to flink-core new 2de556c [FLINK-22879][table] Rename flink-table-planner-blink to flink-table-planner new 37bba3a [FLINK-18783] Load Akka with separate classloader new 0b57261 Revert "[FLINK-18783] Load Akka with separate classloader" new d854cde [FLINK-18783] Load Akka with separate classloader new 88b4564 [FLINK-23329][build] Bump flink-shaded to 14.0 new 1a4d4bd Update version to 1.15-SNAPSHOT new 20c4173 [FLINK-23859] Fix typos new db6d439 [FLINK-24018][build] Remove Scala dependencies from Java APIs new 36d64dd [FLINK-22775][cassandra][tests] Lower write consistency level to ANY new d8aa8c9 [FLINK-24596][table] Allow using unified Sinks with the DataStreamSinkProvider new 4466fb6 [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers new 0b27e38 [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed. new 9766929 [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests. new 63bf7cb [FLINK-25415] Add retries to CasandraConnectorITCase new 856b242 [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings new f451317 [FLINK-25674][connectors][cassandra][tests] Add drop tables to be idempotent in case of retrials and the related test new 2d9ed6b [FLINK-25674][connectors][cassandra][tests] use constants instead of string literals to avoid copy/paste new bb58c6a [FLINK-25776][build] sync netty versions new 7192ad3 [FLINK-25147][connectors][Cassandra][test] Use parent test containers version new 932ceb2 [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts new 651c3b6 [FLINK-25771][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container. new b7178bd [FLINK-25892][cassandra][test] add ArchUnit tests for test code new d770a3e [FLINK-26054][build] Add enforcer rule to forbid direct dependency on table planner new 241c91e [hotfix][build] Move one-off properties into using modules new bc2f491 [hotfix] Fix JUnit 5 mini cluster arch unit rules new e6b1341 [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos new ad74ef5 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules new 2e6975b [FLINK-26252][tests] Refactor MiniClusterExtension to support JUnit 5 parallel tests new ddeb9b1 [FLINK-25771][cassandra][tests] Raise client timeouts new 906b2fc Update version to 1.16-SNAPSHOT new 152b7b2 [FLINK-25771][cassandra][tests] Remove keyspace drop new 1fa08a9 [FLINK-27024][build] Cleanup surefire configuration new 556cbf9 [FLINK-27225][build] Remove redundant reuseForks settings new ebf5950 [FLINK-27253][cassandra][build] Remove custom surefire config new 44d07ac [FLINK-27229][cassandra][build] Remove test netty dependency new 7d1343e [FLINK-27390][build] Remove unused flink-tests dependencies new 13d0fb4 [FLINK-24721][build] Remove unnecessary relativePath to parent new f04863e [FLINK-27185][connector] Convert connector-cassandra module to assertj new 9233d79 [FLINK-27779][connectors/cassandra] Remove `flink-table-planner` in favor of `flink-table-test-utils` new 8a601b0 [FLINK-27457][cassandra] Implement flush() logic in output formats new e3355ad [FLINK-26824][cassandra] Upgrade driver to 3.11.2 new 6400d67 [FLINK-27964][python] Support Cassandra connector in Python DataStream API new aceddce [FLINK-26793][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format. new f1fcc32 [FLINK-27884][connectors] Move OutputFormatBase to flink-core new ccac3dc [FLINK-28198][connectors][cassandra] raise driver timeouts per session request and raise it higher than cluster side timetouts (#20184) new 579c037 [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files new b9225aa Update version to 1.17-SNAPSHOT new a9972f7 [hotfix][cassandra][tests] Use CassandraTupleOutputFormat new 3a1f68a [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5 The 144 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.