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:56:14 UTC
[flink-connector-cassandra] branch cas_rewrite updated (3a1f68a -> 9787ed9)
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
discard 3a1f68a [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5
discard a9972f7 [hotfix][cassandra][tests] Use CassandraTupleOutputFormat
discard b9225aa Update version to 1.17-SNAPSHOT
discard 579c037 [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files
discard ccac3dc [FLINK-28198][connectors][cassandra] raise driver timeouts per session request and raise it higher than cluster side timetouts (#20184)
discard f1fcc32 [FLINK-27884][connectors] Move OutputFormatBase to flink-core
discard aceddce [FLINK-26793][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format.
discard 6400d67 [FLINK-27964][python] Support Cassandra connector in Python DataStream API
discard e3355ad [FLINK-26824][cassandra] Upgrade driver to 3.11.2
discard 8a601b0 [FLINK-27457][cassandra] Implement flush() logic in output formats
discard 9233d79 [FLINK-27779][connectors/cassandra] Remove `flink-table-planner` in favor of `flink-table-test-utils`
discard f04863e [FLINK-27185][connector] Convert connector-cassandra module to assertj
discard 13d0fb4 [FLINK-24721][build] Remove unnecessary relativePath to parent
discard 7d1343e [FLINK-27390][build] Remove unused flink-tests dependencies
discard 44d07ac [FLINK-27229][cassandra][build] Remove test netty dependency
discard ebf5950 [FLINK-27253][cassandra][build] Remove custom surefire config
discard 556cbf9 [FLINK-27225][build] Remove redundant reuseForks settings
discard 1fa08a9 [FLINK-27024][build] Cleanup surefire configuration
discard 152b7b2 [FLINK-25771][cassandra][tests] Remove keyspace drop
discard 906b2fc Update version to 1.16-SNAPSHOT
discard ddeb9b1 [FLINK-25771][cassandra][tests] Raise client timeouts
discard 2e6975b [FLINK-26252][tests] Refactor MiniClusterExtension to support JUnit 5 parallel tests
discard ad74ef5 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules
discard e6b1341 [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos
discard bc2f491 [hotfix] Fix JUnit 5 mini cluster arch unit rules
discard 241c91e [hotfix][build] Move one-off properties into using modules
discard d770a3e [FLINK-26054][build] Add enforcer rule to forbid direct dependency on table planner
discard b7178bd [FLINK-25892][cassandra][test] add ArchUnit tests for test code
discard 651c3b6 [FLINK-25771][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container.
discard 932ceb2 [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts
discard 7192ad3 [FLINK-25147][connectors][Cassandra][test] Use parent test containers version
discard bb58c6a [FLINK-25776][build] sync netty versions
discard 2d9ed6b [FLINK-25674][connectors][cassandra][tests] use constants instead of string literals to avoid copy/paste
discard f451317 [FLINK-25674][connectors][cassandra][tests] Add drop tables to be idempotent in case of retrials and the related test
discard 856b242 [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings
discard 63bf7cb [FLINK-25415] Add retries to CasandraConnectorITCase
discard 9766929 [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests.
discard 0b27e38 [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.
discard 4466fb6 [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers
discard d8aa8c9 [FLINK-24596][table] Allow using unified Sinks with the DataStreamSinkProvider
discard 36d64dd [FLINK-22775][cassandra][tests] Lower write consistency level to ANY
discard db6d439 [FLINK-24018][build] Remove Scala dependencies from Java APIs
discard 20c4173 [FLINK-23859] Fix typos
discard 1a4d4bd Update version to 1.15-SNAPSHOT
discard 88b4564 [FLINK-23329][build] Bump flink-shaded to 14.0
discard d854cde [FLINK-18783] Load Akka with separate classloader
discard 0b57261 Revert "[FLINK-18783] Load Akka with separate classloader"
discard 37bba3a [FLINK-18783] Load Akka with separate classloader
discard 2de556c [FLINK-22879][table] Rename flink-table-planner-blink to flink-table-planner
discard a71da3c [FLINK-23085] Move FutureUtils to flink-core
discard d45b5e8 [FLINK-22560][build] Move generic filters/transformers into general shade-plugin configuration
discard 0de0f2f [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException
discard 8c6fc60 Update version to 1.14-SNAPSHOT
new 6ed2584 [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo
new e6fdba1 [hotfix][docs] Correct rendering of maven modules
new c7a8674 Update version to 1.14-SNAPSHOT
new 7cdfaf2 [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException
new a5e44c6 [FLINK-22560][build] Move generic filters/transformers into general shade-plugin configuration
new 9e26c3b [FLINK-22947][docs] Consolidate DataTypes and Serialization under DataStream
new 5c136c9 Apply suggestions from code review
new 1155a63 [FLINK-23085] Move FutureUtils to flink-core
new 67c65c9 [FLINK-22879][table] Rename flink-table-planner-blink to flink-table-planner
new 7249c79 [hotfix][docs][cassandra] Added missing cluster builder arg for cassandra sink (#16365)
new 37232cd [FLINK-18783] Load Akka with separate classloader
new 3e89da0 Revert "[FLINK-18783] Load Akka with separate classloader"
new da93e22 [FLINK-18783] Load Akka with separate classloader
new b90e17f [FLINK-23329][build] Bump flink-shaded to 14.0
new f076c85 Update version to 1.15-SNAPSHOT
new f0781b7 [FLINK-23859] Fix typos
new 41aeaef [hotfix][docs] Adding new sources on overview pages
new 6129aa4 [FLINK-24018][build] Remove Scala dependencies from Java APIs
new a9a95dc [FLINK-22775][cassandra][tests] Lower write consistency level to ANY
new ed755c2 [FLINK-24596][table] Allow using unified Sinks with the DataStreamSinkProvider
new ed88db8 [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers
new 1c648bb [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.
new f780eec [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests.
new 2b5d51c [FLINK-25415] Add retries to CasandraConnectorITCase
new 2c7c0cc [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings
new 833dd28 [FLINK-25674][connectors][cassandra][tests] Add drop tables to be idempotent in case of retrials and the related test
new 510a0ec [FLINK-25674][connectors][cassandra][tests] use constants instead of string literals to avoid copy/paste
new 63b3371 [FLINK-25776][build] sync netty versions
new 3184a18 [FLINK-25147][connectors][Cassandra][test] Use parent test containers version
new 15f763d [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts
new 188ce49 [FLINK-25771][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container.
new c82c848 [FLINK-25129][docs] Restructure project configuation pages
new 5f757c9 [FLINK-25892][cassandra][test] add ArchUnit tests for test code
new 6ccf2f2 [FLINK-26054][build] Add enforcer rule to forbid direct dependency on table planner
new 8f844df [hotfix][build] Move one-off properties into using modules
new fb2f7df [hotfix] Fix JUnit 5 mini cluster arch unit rules
new 79979be [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos
new c563310 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules
new 1428745 [FLINK-26252][tests] Refactor MiniClusterExtension to support JUnit 5 parallel tests
new b2ac7da [FLINK-25771][cassandra][tests] Raise client timeouts
new 80609a0 Update version to 1.16-SNAPSHOT
new 95c6d51 [FLINK-25771][cassandra][tests] Remove keyspace drop
new c2407ee [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese. This closes #19100
new b299dd3 [FLINK-27024][build] Cleanup surefire configuration
new 52b14a6 [FLINK-27225][build] Remove redundant reuseForks settings
new 89ccb88 [FLINK-27253][cassandra][build] Remove custom surefire config
new 9d320a8 [FLINK-27229][cassandra][build] Remove test netty dependency
new 3fa34ba [FLINK-27390][build] Remove unused flink-tests dependencies
new 0554080 [FLINK-24721][build] Remove unnecessary relativePath to parent
new 3c27753 [FLINK-27185][connector] Convert connector-cassandra module to assertj
new a87ee8a [FLINK-27779][connectors/cassandra] Remove `flink-table-planner` in favor of `flink-table-test-utils`
new af99357 [FLINK-27457][cassandra] Implement flush() logic in output formats
new 8c44c64 [FLINK-26824][cassandra] Upgrade driver to 3.11.2
new 3e5a127 [FLINK-27964][python] Support Cassandra connector in Python DataStream API
new bde00ba [FLINK-26793][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format.
new ef65080 [FLINK-27884][connectors] Move OutputFormatBase to flink-core
new 8b60735 [FLINK-28198][connectors][cassandra] raise driver timeouts per session request and raise it higher than cluster side timetouts (#20184)
new f174f67 [FLINK-29017][docs] Replace all links to github master with shortcode
new be2c97d [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files
new 303295a Update version to 1.17-SNAPSHOT
new b4f91b5 [hotfix][cassandra][tests] Use CassandraTupleOutputFormat
new 9787ed9 [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3a1f68a)
\
N -- N -- N refs/heads/cas_rewrite (9787ed9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 62 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:
.../docs/connectors/datastream/cassandra.md | 288 +++++++++++++++++++++
.../docs/connectors/datastream/cassandra.md | 288 +++++++++++++++++++++
2 files changed, 576 insertions(+)
create mode 100644 docs/content.zh/docs/connectors/datastream/cassandra.md
create mode 100644 docs/content/docs/connectors/datastream/cassandra.md