Re: FlinkSQL如何处理上游的表结构变更

Sat, 05 Sep 2020 20:16:08 -0700 

我理解SQL本身都是强类型的，要处理这种schema会变更的情况可能本身就不是很合适。

CC 云邪，不知道云邪大佬对这个有没有更好的想法。

忝忝向仧 <[email protected]> 于2020年9月5日周六 下午4:50写道：

> 同问如果是上游表结构变更没有及时通知到下游，数据同步这块就会报错
> 有没什么办法解决？
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [email protected]&gt;;
> 发送时间:&nbsp;2020年9月4日(星期五) 下午2:18
> 收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
> 主题:&nbsp;FlinkSQL如何处理上游的表结构变更
>
>
>
> Hi all:
> flink version : 1.11.0
> 场景：上游的数据来自binlog，当发生表结构变更时，希望能够实时的变动flink内部表的schema，但是目前来看，表的schema都是create
> table时写死的，有什么办法可以处理这种场景呢



-- 

Best,
Benchao Li

回复