This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f6d6fa5 [FLINK-21740][sql-client] Fix unstable
CliTableauResultViewTest (#15211)
add b77afd0 [FLINK-19667] Add AWS Glue Schema Registry integration
(#14737)
No new revisions were added by this update.
Summary of changes:
azure-pipelines.yml | 2 +
.../flink-glue-schema-registry-test/pom.xml | 259 ++++++++++++
.../registry/test/GSRKinesisPubsubClient.java | 184 +++++++++
.../registry/test/GlueSchemaRegistryExample.java | 112 ++++++
.../test/GlueSchemaRegistryExampleTest.java | 143 +++++++
.../src/main/resources/avro/user.avsc | 27 ++
flink-end-to-end-tests/pom.xml | 1 +
flink-end-to-end-tests/run-nightly-tests.sh | 4 +
flink-end-to-end-tests/test-scripts/common.sh | 2 +
.../test-scripts/test_glue_schema_registry.sh | 78 ++++
.../flink-avro-glue-schema-registry/pom.xml | 182 +++++++++
...lueSchemaRegistryAvroDeserializationSchema.java | 88 +++++
.../GlueSchemaRegistryAvroSchemaCoder.java | 84 ++++
.../GlueSchemaRegistryAvroSchemaCoderProvider.java | 51 +++
.../GlueSchemaRegistryAvroSerializationSchema.java | 131 +++++++
.../GlueSchemaRegistryInputStreamDeserializer.java | 87 +++++
.../GlueSchemaRegistryOutputStreamSerializer.java | 89 +++++
...chemaRegistryAvroDeserializationSchemaTest.java | 74 ++++
.../GlueSchemaRegistryAvroSchemaCoderTest.java | 235 +++++++++++
...eSchemaRegistryAvroSerializationSchemaTest.java | 178 +++++++++
...eSchemaRegistryInputStreamDeserializerTest.java | 283 ++++++++++++++
...ueSchemaRegistryOutputStreamSerializerTest.java | 134 +++++++
.../formats/avro/glue/schema/registry/User.java | 434 +++++++++++++++++++++
.../src/test/java/resources/avro/user.avsc | 27 ++
flink-formats/pom.xml | 1 +
tools/azure-pipelines/build-apache-repo.yml | 2 +
tools/azure-pipelines/jobs-template.yml | 4 +
tools/maven/suppressions.xml | 3 +
28 files changed, 2899 insertions(+)
create mode 100644
flink-end-to-end-tests/flink-glue-schema-registry-test/pom.xml
create mode 100644
flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/java/org/apache/flink/glue/schema/registry/test/GSRKinesisPubsubClient.java
create mode 100644
flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/java/org/apache/flink/glue/schema/registry/test/GlueSchemaRegistryExample.java
create mode 100644
flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/java/org/apache/flink/glue/schema/registry/test/GlueSchemaRegistryExampleTest.java
create mode 100644
flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/resources/avro/user.avsc
create mode 100755
flink-end-to-end-tests/test-scripts/test_glue_schema_registry.sh
create mode 100644 flink-formats/flink-avro-glue-schema-registry/pom.xml
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroDeserializationSchema.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSchemaCoder.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSchemaCoderProvider.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSerializationSchema.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryInputStreamDeserializer.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryOutputStreamSerializer.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroDeserializationSchemaTest.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSchemaCoderTest.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSerializationSchemaTest.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryInputStreamDeserializerTest.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryOutputStreamSerializerTest.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/User.java
create mode 100644
flink-formats/flink-avro-glue-schema-registry/src/test/java/resources/avro/user.avsc
