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

2020-09-03 Thread xiao cai
Hi all: flink version : 1.11.0 场景：上游的数据来自binlog，当发生表结构变更时，希望能够实时的变动flink内部表的schema，但是目前来看，表的schema都是create table时写死的，有什么办法可以处理这种场景呢

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

2020-09-05 Thread Benchao Li
"user-zh" > < > flin...@163.com>; > 发送时间: 2020年9月4日(星期五) 下午2:18 > 收件人: "user-zh" > 主题: FlinkSQL如何处理上游的表结构变更 > > > > Hi all: > flink version : 1.11.0 > 场景：上游的数据