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

[xiao cai]

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