[HUDI-1663] Streaming read for Flink MOR table

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 0.8.0
• Component/s: flink
• Labels: pull-request-available
• Assignee: Danny Chen
• Reporter: Danny Chen
• Created: 05/Mar/21 02:13
• Updated: 10/Mar/21 14:44
• Resolved: 10/Mar/21 14:44

Description

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.

Issue Links

• duplicates: HUDI-1664 Avro schema inference for Flink SQL table
• links to: GitHub Pull Request #2640