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