This is an automated email from the ASF dual-hosted git repository. amaliujia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 21feb59 Merge pull request #14173: [BEAM-11941] Upgrade Flink runner to Flink version 1.12.2 add 4e7d645 [BEAM-11659] Allow Kafka sql table provider to have a nested mode and raw binary payloads (#14016) No new revisions were added by this update. Summary of changes: .../sql/meta/provider/kafka/BeamKafkaCSVTable.java | 37 ++- .../sql/meta/provider/kafka/BeamKafkaTable.java | 15 +- .../meta/provider/kafka/KafkaTableProvider.java | 46 ++-- .../provider/kafka/NestedPayloadKafkaTable.java | 181 +++++++++++++ .../kafka/PayloadSerializerKafkaTable.java | 25 +- .../sql/meta/provider/kafka/Schemas.java | 107 ++++++++ .../provider/kafka/BeamKafkaTableAvroTest.java | 3 +- .../meta/provider/kafka/BeamKafkaTableCSVTest.java | 2 +- .../provider/kafka/BeamKafkaTableJsonTest.java | 3 +- .../provider/kafka/BeamKafkaTableProtoTest.java | 9 +- .../meta/provider/kafka/BeamKafkaTableTest.java | 42 ++- .../provider/kafka/BeamKafkaTableThriftTest.java | 9 +- .../meta/provider/kafka/KafkaTableProviderIT.java | 61 +++++ .../provider/kafka/KafkaTableProviderTest.java | 69 ++++- .../sql/meta/provider/kafka/KafkaTestTable.java | 9 +- .../kafka/NestedPayloadKafkaTableTest.java | 290 +++++++++++++++++++++ .../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 4 +- 17 files changed, 843 insertions(+), 69 deletions(-) create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/NestedPayloadKafkaTable.java create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/Schemas.java create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/NestedPayloadKafkaTableTest.java