This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 20a1b88 [FLINK-26089][table-api-java] Introduce TablePipeline add 8db43d7 [FLINK-25701][kafka] Add Flink API annotation to all connector classes based on the new Source/Sink design add be5a6b2 [FLINK-25701][kafka] reduce architectural violation No new revisions were added by this update. Summary of changes: .../archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 3 +-- .../kafka/sink/KafkaRecordSerializationSchemaBuilder.java | 2 ++ .../java/org/apache/flink/connector/kafka/source/KafkaSource.java | 8 ++++++++ .../apache/flink/connector/kafka/source/KafkaSourceBuilder.java | 2 ++ .../apache/flink/connector/kafka/source/KafkaSourceOptions.java | 2 ++ .../connector/kafka/source/enumerator/KafkaSourceEnumState.java | 3 +++ .../kafka/source/enumerator/KafkaSourceEnumStateSerializer.java | 2 ++ .../kafka/source/enumerator/subscriber/KafkaSubscriber.java | 3 +++ .../connector/kafka/source/metrics/KafkaSourceReaderMetrics.java | 2 ++ .../connector/kafka/source/reader/KafkaPartitionSplitReader.java | 2 ++ .../flink/connector/kafka/source/reader/KafkaRecordEmitter.java | 2 ++ .../flink/connector/kafka/source/reader/KafkaSourceReader.java | 2 ++ .../reader/deserializer/KafkaRecordDeserializationSchema.java | 3 +-- .../kafka/source/reader/fetcher/KafkaSourceFetcherManager.java | 2 ++ .../flink/connector/kafka/source/split/KafkaPartitionSplit.java | 2 ++ .../kafka/source/split/KafkaPartitionSplitSerializer.java | 2 ++ .../connector/kafka/source/split/KafkaPartitionSplitState.java | 3 +++ 17 files changed, 41 insertions(+), 4 deletions(-)