Re: flink avro schema 升级变动，job如何平滑过渡

[Shammon FY]

Hi

你可以贴一下错误看下具体原因

Best,
Shammon

On Fri, Feb 24, 2023 at 6:10 PM Peihui He <peihu...@gmail.com> wrote:

> Hi, all
>
> 请教大家有没有遇到这样的情况，flink 使用avro
> 消费kafka中数据，后来在schema结构中加入新的字段。在灰度过程中会混杂着新老数据，这样的flink 消费程序就会挂掉。
>
> 大家一般是怎么处理的呢
>
> Best Wishes.
>