This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 01d8f99 [FLINK-20302] Recommend DataStream API with BATCH execution
mode in DataSet docs
add 9abe38e [hotfix] Shade avro in sql-avro jars
add efc12ca [FLINK-20175] Avro Confluent Registry SQL format does not
support adding nullable columns
add 40e6e16 [FLINK-19997] Implement an e2e test for sql-client with
Confluent Registry Avro format
No new revisions were added by this update.
Summary of changes:
.../flink-end-to-end-tests-common-kafka/pom.xml | 62 ++++
.../tests/util/kafka/KafkaContainerClient.java | 131 +++++++++
.../util/kafka/SQLClientSchemaRegistryITCase.java | 225 ++++++++++++++
.../kafka/containers/SchemaRegistryContainer.java | 50 ++++
.../src/test/resources/log4j2-test.properties | 6 +
.../flink-end-to-end-tests-common/pom.xml | 5 +
.../flink/tests/util/flink/FlinkContainer.java | 300 +++++++++++++++++++
.../flink/LocalStandaloneFlinkResourceFactory.java | 83 +-----
.../flink/tests/util/flink/SQLJobSubmission.java | 7 +
.../apache/flink/tests/util/util/FileUtils.java | 88 ++++++
flink-end-to-end-tests/pom.xml | 13 +
.../formats/avro/RowDataToAvroConverters.java | 189 ++++++++----
.../avro/typeutils/AvroSchemaConverter.java | 14 +-
.../avro/typeutils/AvroSchemaConverterTest.java | 322 +++++++++++++--------
.../flink-sql-avro-confluent-registry/pom.xml | 20 +-
flink-formats/flink-sql-avro/pom.xml | 4 +
16 files changed, 1251 insertions(+), 268 deletions(-)
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaContainerClient.java
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkContainer.java
