Greg Wills created FLINK-35439:
----------------------------------
Summary: Python Support for AvroSchemaConverter
Key: FLINK-35439
URL: https://issues.apache.org/jira/browse/FLINK-35439
Project: Flink
Issue Type: Improvement
Components: API / Python
Affects Versions: 1.18.1, 1.17.2
Reporter: Greg Wills
The java class org.apache.flink.formats.avro.typeutils.AvroSchemaConverter is
not integrated into the apache-flink Python library (pyflink). My goal is to
dynamically create a Pyflink table schema from an avro schema, but without a
Python interface via py4j do so, that task is difficult.
Especially for the Table API, this would improve schema management and
evolution practices. Currently, the responsibility is on the user to statically
create the table schema (used as the Avro reader schema). Schema updates can
cause this static reader schema that is generated from the table schema to be
incompatible with the writer schema (when consuming/deserializing).
This is the case specifically for the format avro-confluent.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
