[
https://issues.apache.org/jira/browse/HUDI-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated HUDI-1664:
-----------------------------
Description:
A Flink SQL table has DDL that defines the table schema, we can use that to
infer the Avro schema and there is no need to declare a Avro schema explicitly
anymore.
But we still keep the config option for explicit Avro schema in case there is
corner cases that the inferred schema is not correct (especially for the
nullability).
was:Supports reading as streaming for Flink MOR table. The writer writes avro
logs and reader monitor the latest commits in the timeline the assign the split
reading task for the incremental logs.
> Avro schema inference for Flink SQL table
> -----------------------------------------
>
> Key: HUDI-1664
> URL: https://issues.apache.org/jira/browse/HUDI-1664
> Project: Apache Hudi
> Issue Type: Sub-task
> Components: Flink Integration
> Reporter: Danny Chen
> Assignee: Danny Chen
> Priority: Major
> Fix For: 0.8.0
>
>
> A Flink SQL table has DDL that defines the table schema, we can use that to
> infer the Avro schema and there is no need to declare a Avro schema
> explicitly anymore.
> But we still keep the config option for explicit Avro schema in case there is
> corner cases that the inferred schema is not correct (especially for the
> nullability).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
