You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by xiao cai <fl...@163.com> on 2020/09/04 06:18:34 UTC
FlinkSQL如何处理上游的表结构变更
Hi all:
flink version : 1.11.0
场景：上游的数据来自binlog，当发生表结构变更时，希望能够实时的变动flink内部表的schema，但是目前来看，表的schema都是create table时写死的，有什么办法可以处理这种场景呢
Re: FlinkSQL如何处理上游的表结构变更
Posted by Benchao Li <li...@apache.org>.
我理解SQL本身都是强类型的，要处理这种schema会变更的情况可能本身就不是很合适。
CC 云邪，不知道云邪大佬对这个有没有更好的想法。
忝忝向仧 <15...@qq.com> 于2020年9月5日周六 下午4:50写道：
> 同问如果是上游表结构变更没有及时通知到下游，数据同步这块就会报错
> 有没什么办法解决？
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人:
> "user-zh"
> <
> flinkcx@163.com>;
> 发送时间: 2020年9月4日(星期五) 下午2:18
> 收件人: "user-zh"<user-zh@flink.apache.org>;
>
> 主题: FlinkSQL如何处理上游的表结构变更
>
>
>
> Hi all:
> flink version : 1.11.0
> 场景：上游的数据来自binlog，当发生表结构变更时，希望能够实时的变动flink内部表的schema，但是目前来看，表的schema都是create
> table时写死的，有什么办法可以处理这种场景呢
--
Best,
Benchao Li
回复：FlinkSQL如何处理上游的表结构变更
Posted by 忝忝向仧 <15...@qq.com>.
同问如果是上游表结构变更没有及时通知到下游，数据同步这块就会报错
有没什么办法解决？
------------------ 原始邮件 ------------------
发件人: "user-zh" <flinkcx@163.com>;
发送时间: 2020年9月4日(星期五) 下午2:18
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: FlinkSQL如何处理上游的表结构变更
Hi all:
flink version : 1.11.0
场景：上游的数据来自binlog，当发生表结构变更时，希望能够实时的变动flink内部表的schema，但是目前来看，表的schema都是create table时写死的，有什么办法可以处理这种场景呢