This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4c67f8fca52 [FLINK-30189][runtime] HsSubpartitionFileReader may load
data that has been consumed from memory
new 7bb75ab6d96 [hotfix][python] Depend on externalized ES connector
new 12cb2212f78 [FLINK-30312][cassandra] Remove Cassandra connector
The 2 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 -------
docs/setup_docs.sh | 1 +
.../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 4 +-
.../b8900323-6aab-4e7e-9b17-f53b3c3dca46 | 3 -
.../flink-architecture-tests-production/pom.xml | 5 -
flink-architecture-tests/pom.xml | 7 -
.../b7279bb1-1eb7-40c0-931d-f6db7971d126 | 0
.../dc1ba6f4-3d84-498c-a085-e02ba5936201 | 6 -
.../archunit-violations/stored.rules | 4 -
flink-connectors/flink-connector-cassandra/pom.xml | 218 -----
.../CassandraColumnarOutputFormatBase.java | 68 --
.../connectors/cassandra/CassandraInputFormat.java | 68 --
.../cassandra/CassandraInputFormatBase.java | 102 ---
.../cassandra/CassandraOutputFormat.java | 35 -
.../cassandra/CassandraOutputFormatBase.java | 129 ---
.../cassandra/CassandraPojoInputFormat.java | 81 --
.../cassandra/CassandraPojoOutputFormat.java | 97 ---
.../cassandra/CassandraRowOutputFormat.java | 52 --
.../cassandra/CassandraTupleOutputFormat.java | 54 --
.../cassandra/AbstractCassandraTupleSink.java | 72 --
.../cassandra/CassandraAppendTableSink.java | 103 ---
.../connectors/cassandra/CassandraCommitter.java | 160 ----
.../cassandra/CassandraFailureHandler.java | 62 --
.../connectors/cassandra/CassandraPojoSink.java | 125 ---
.../connectors/cassandra/CassandraRowSink.java | 60 --
.../cassandra/CassandraRowWriteAheadSink.java | 170 ----
.../cassandra/CassandraScalaProductSink.java | 55 --
.../connectors/cassandra/CassandraSink.java | 663 ---------------
.../connectors/cassandra/CassandraSinkBase.java | 194 -----
.../cassandra/CassandraSinkBaseConfig.java | 125 ---
.../connectors/cassandra/CassandraTupleSink.java | 53 --
.../cassandra/CassandraTupleWriteAheadSink.java | 170 ----
.../connectors/cassandra/ClusterBuilder.java | 43 -
.../connectors/cassandra/MapperOptions.java | 37 -
.../cassandra/NoOpCassandraFailureHandler.java | 35 -
.../connectors/cassandra/SimpleMapperOptions.java | 121 ---
.../src/main/resources/META-INF/NOTICE | 11 -
.../architecture/TestCodeArchitectureTest.java | 43 -
.../connectors/cassandra/example/BatchExample.java | 88 --
.../cassandra/example/BatchPojoExample.java | 93 ---
.../batch/connectors/cassandra/example/Pojo.java | 72 --
.../cassandra/utils/ResultSetFutures.java | 103 ---
.../cassandra/CassandraConnectorITCase.java | 912 ---------------------
.../cassandra/CassandraSinkBaseTest.java | 453 ----------
.../CassandraTupleWriteAheadSinkTest.java | 150 ----
.../flink/streaming/connectors/cassandra/Pojo.java | 70 --
.../example/CassandraPojoSinkExample.java | 68 --
.../example/CassandraTupleSinkExample.java | 68 --
.../CassandraTupleWriteAheadSinkExample.java | 118 ---
.../connectors/cassandra/example/Message.java | 62 --
.../org.junit.jupiter.api.extension.Extension | 16 -
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
flink-connectors/pom.xml | 1 -
flink-python/pom.xml | 4 +-
.../org/apache/flink/util/DockerImageVersions.java | 2 -
tools/azure-pipelines/cache_docker_images.sh | 2 +-
tools/ci/stage.sh | 1 -
59 files changed, 5 insertions(+), 6149 deletions(-)
delete mode 100644 docs/content.zh/docs/connectors/datastream/cassandra.md
delete mode 100644 docs/content/docs/connectors/datastream/cassandra.md
delete mode 100644
flink-connectors/flink-connector-cassandra/archunit-violations/b7279bb1-1eb7-40c0-931d-f6db7971d126
delete mode 100644
flink-connectors/flink-connector-cassandra/archunit-violations/dc1ba6f4-3d84-498c-a085-e02ba5936201
delete mode 100644
flink-connectors/flink-connector-cassandra/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-cassandra/pom.xml
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraColumnarOutputFormatBase.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormat.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormatBase.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoInputFormat.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoOutputFormat.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/AbstractCassandraTupleSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraFailureHandler.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraScalaProductSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseConfig.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/MapperOptions.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/NoOpCassandraFailureHandler.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/SimpleMapperOptions.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/main/resources/META-INF/NOTICE
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchPojoExample.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/Pojo.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/connectors/cassandra/utils/ResultSetFutures.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSinkTest.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/Pojo.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/Message.java
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/resources/archunit.properties
delete mode 100644
flink-connectors/flink-connector-cassandra/src/test/resources/log4j2-test.properties
