pravega/flink-connectors

Support format metadata

Closed this issue · 0 comments

thekingofcity commented

Problem description
With the work of #533, it is possible to read data in other formats(such as Debezium). However, the metadata from the formats are lost in the current implementation.

Problem location

  • FlinkPravegaDynamicTableSource
  • FlinkPravegaDynamicDeserializationSchema

Suggestions for an improvement
Push the format metadata down