[flink] branch master updated (20a1b88 -> be5a6b2)

[fp...@apache.org]

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(-)