Dale Lane created FLINK-33058:
---------------------------------

             Summary: Support for JSON-encoded Avro
                 Key: FLINK-33058
                 URL: https://issues.apache.org/jira/browse/FLINK-33058
             Project: Flink
          Issue Type: Improvement
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
            Reporter: Dale Lane


Avro supports two encoding methods: binary and JSON

cf. [https://avro.apache.org/docs/1.11.1/specification/#encodings] 

flink-avro currently has a hard-coded assumption that Avro data is 
binary-encoded (and cannot process Avro data that has been JSON-encoded).

I propose adding a new optional format option to flink-avro: *avro.encoding*

It will support two options: 'binary' and 'json'. 

It unset, it will default to 'binary' to maintain compatibility/consistency 
with current behaviour. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to