You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/11/21 10:39:18 UTC
[flink-connector-cassandra] branch cas_rewrite created (now 3a1f68a)
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.