You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/09/15 15:28:56 UTC
[flink] branch master updated (e594cf5 -> 3df63de)
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e594cf5 [FLINK-19037] Forward ioExecutor from ClusterEntrypoint to Dispatcher
add 3df63de [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors
No new revisions were added by this update.
Summary of changes:
docs/dev/connectors/kafka.md | 105 +-
docs/dev/connectors/kafka.zh.md | 101 +-
docs/dev/datastream_api.md | 4 +-
docs/dev/datastream_api.zh.md | 4 +-
docs/dev/project-configuration.md | 2 +-
docs/dev/table/connect.md | 2 -
docs/dev/table/connect.zh.md | 2 -
docs/dev/table/connectors/kafka.md | 8 +-
docs/dev/table/connectors/kafka.zh.md | 8 +-
.../flink-connector-kafka-0.10/pom.xml | 316 ----
.../connectors/kafka/FlinkKafkaConsumer010.java | 360 -----
.../connectors/kafka/FlinkKafkaProducer010.java | 433 ------
.../connectors/kafka/Kafka010TableSink.java | 62 -
.../connectors/kafka/Kafka010TableSource.java | 104 --
.../kafka/Kafka010TableSourceSinkFactory.java | 92 --
.../connectors/kafka/internal/Handover.java | 218 ---
.../connectors/kafka/internal/Kafka010Fetcher.java | 254 ----
.../internal/Kafka010PartitionDiscoverer.java | 111 --
.../kafka/internal/KafkaConsumerThread.java | 584 --------
.../kafka/table/Kafka010DynamicSink.java | 83 --
.../kafka/table/Kafka010DynamicSource.java | 114 --
.../kafka/table/Kafka010DynamicTableFactory.java | 104 --
.../org.apache.flink.table.factories.Factory | 16 -
.../org.apache.flink.table.factories.TableFactory | 16 -
.../connectors/kafka/FlinkKafkaProducerTest.java | 72 -
.../streaming/connectors/kafka/Kafka010ITCase.java | 346 -----
.../connectors/kafka/Kafka010ProducerITCase.java | 35 -
.../connectors/kafka/Kafka010SecuredRunITCase.java | 63 -
.../kafka/Kafka010TableSourceSinkFactoryTest.java | 101 --
.../connectors/kafka/KafkaTestEnvironmentImpl.java | 476 ------
.../connectors/kafka/internal/HandoverTest.java | 387 -----
.../kafka/internal/Kafka010FetcherTest.java | 481 -------
.../kafka/internal/KafkaConsumerThreadTest.java | 1124 ---------------
.../table/Kafka010DynamicTableFactoryTest.java | 147 --
.../kafka/table/Kafka010TableITCase.java | 37 -
.../src/test/resources/log4j2-test.properties | 38 -
.../flink-connector-kafka-0.11/pom.xml | 293 ----
.../connectors/kafka/FlinkKafka011ErrorCode.java | 29 -
.../connectors/kafka/FlinkKafka011Exception.java | 46 -
.../connectors/kafka/FlinkKafkaConsumer011.java | 158 --
.../connectors/kafka/FlinkKafkaProducer011.java | 1522 --------------------
.../connectors/kafka/Kafka011TableSink.java | 63 -
.../connectors/kafka/Kafka011TableSource.java | 104 --
.../kafka/Kafka011TableSourceSinkFactory.java | 92 --
.../kafka/internal/FlinkKafkaProducer.java | 394 -----
.../kafka/internal/TransactionalIdsGenerator.java | 96 --
.../metrics/KafkaMetricMutableWrapper.java | 45 -
.../kafka/table/Kafka011DynamicSink.java | 88 --
.../kafka/table/Kafka011DynamicSource.java | 114 --
.../kafka/table/Kafka011DynamicTableFactory.java | 87 --
.../org.apache.flink.table.factories.Factory | 16 -
.../org.apache.flink.table.factories.TableFactory | 16 -
.../kafka/FlinkKafkaProducer011ITCase.java | 682 ---------
.../kafka/FlinkKafkaProducer011MigrationTest.java | 85 --
.../FlinkKafkaProducer011StateSerializerTest.java | 108 --
.../connectors/kafka/FlinkKafkaProducerITCase.java | 230 ---
.../connectors/kafka/FlinkKafkaProducerTest.java | 72 -
.../streaming/connectors/kafka/Kafka011ITCase.java | 355 -----
.../kafka/Kafka011ProducerAtLeastOnceITCase.java | 44 -
.../kafka/Kafka011ProducerExactlyOnceITCase.java | 57 -
.../kafka/Kafka011SerializerUpgradeTest.java | 162 ---
.../kafka/Kafka011TableSourceSinkFactoryTest.java | 101 --
.../connectors/kafka/KafkaTestEnvironmentImpl.java | 501 -------
.../NextTransactionalIdHintSerializerTest.java | 56 -
.../internal/TransactionalIdsGeneratorTest.java | 91 --
.../table/Kafka011DynamicTableFactoryTest.java | 101 --
.../kafka/table/Kafka011TableITCase.java | 37 -
.../serializer-snapshot | Bin 129 -> 0 bytes
.../context-state-serializer-1.11/test-data | Bin 19 -> 0 bytes
...ka-migration-kafka-producer-flink-1.10-snapshot | Bin 2032 -> 0 bytes
...ka-migration-kafka-producer-flink-1.11-snapshot | Bin 2040 -> 0 bytes
...fka-migration-kafka-producer-flink-1.8-snapshot | Bin 2032 -> 0 bytes
...fka-migration-kafka-producer-flink-1.9-snapshot | Bin 2032 -> 0 bytes
.../src/test/resources/log4j2-test.properties | 38 -
.../serializer-snapshot | Bin 137 -> 0 bytes
.../transaction-state-serializer-1.11/test-data | Bin 17 -> 0 bytes
.../flink-sql-connector-kafka-0.10/pom.xml | 91 --
.../src/main/resources/META-INF/NOTICE | 9 -
.../flink-sql-connector-kafka-0.11/pom.xml | 92 --
.../src/main/resources/META-INF/NOTICE | 9 -
flink-connectors/pom.xml | 4 -
.../flink-confluent-schema-registry/pom.xml | 4 +-
.../registry/test/TestAvroConsumerConfluent.java | 16 +-
.../flink-end-to-end-tests-common-kafka/pom.xml | 75 -
.../tests/util/kafka/SQLClientKafkaITCase.java | 2 -
.../tests/util/kafka/StreamingKafkaITCase.java | 2 -
.../flink-sql-client-test/pom.xml | 26 -
.../streaming/kafka/test/base/KafkaEvent.java | 4 +-
.../flink-streaming-kafka010-test/pom.xml | 88 --
.../streaming/kafka/test/Kafka010Example.java | 69 -
.../flink-streaming-kafka011-test/pom.xml | 89 --
.../streaming/kafka/test/Kafka011Example.java | 69 -
flink-end-to-end-tests/pom.xml | 2 -
flink-python/pyflink/datastream/connectors.py | 179 +--
.../pyflink/datastream/tests/test_connectors.py | 11 +-
.../webmonitor/handlers/JarUploadHandlerTest.java | 4 +-
.../org/apache/flink/table/factories/Factory.java | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
pom.xml | 1 -
tools/ci/stage.sh | 6 +-
101 files changed, 79 insertions(+), 13072 deletions(-)
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/pom.xml
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSink.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSource.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSourceSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010PartitionDiscoverer.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSink.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSource.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactory.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ProducerITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010SecuredRunITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSourceSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/HandoverTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010FetcherTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThreadTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010TableITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/pom.xml
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011ErrorCode.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer011.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSink.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSource.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSourceSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/metrics/KafkaMetricMutableWrapper.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSource.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactory.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011ITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011MigrationTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011StateSerializerTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ProducerAtLeastOnceITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011ProducerExactlyOnceITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011SerializerUpgradeTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSourceSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/NextTransactionalIdHintSerializerTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGeneratorTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011TableITCase.java
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/context-state-serializer-1.11/serializer-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/context-state-serializer-1.11/test-data
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.8-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.9-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/transaction-state-serializer-1.11/serializer-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/transaction-state-serializer-1.11/test-data
delete mode 100644 flink-connectors/flink-sql-connector-kafka-0.10/pom.xml
delete mode 100644 flink-connectors/flink-sql-connector-kafka-0.10/src/main/resources/META-INF/NOTICE
delete mode 100644 flink-connectors/flink-sql-connector-kafka-0.11/pom.xml
delete mode 100644 flink-connectors/flink-sql-connector-kafka-0.11/src/main/resources/META-INF/NOTICE
delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka010-test/src/main/java/org/apache/flink/streaming/kafka/test/Kafka010Example.java
delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka011-test/src/main/java/org/apache/flink/streaming/kafka/test/Kafka011Example.java