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