flink1.10袋鼠云迁移 flink1.15原生环境事项汇总

表DDL(平台自动生成)修改适配

1 DDL语法不通用 (袋鼠云DDL中支持给别名 DDL采用数据中台生成的模板,并把老版本DDL中的配置通过到相应参数中)

2 袋鼠云DDL支持给别名

sql中字段和DDL中字段不一致. 两种解决方案:

1 FlinkSQL别名语法和袋鼠云略不同

袋鼠云DDL:

parseJson(parseJson(_MESSAGE, 'data'), 'recordId') AS recordId

FlinkSQL1.15 DDL:

recordId AS parseJson(parseJson(_MESSAGE, 'data'), 'recordId')

标签： flinksql 袋鼠云

本文转载自: https://blog.csdn.net/qq_35515661/article/details/134529967
版权归原作者 Thomas2143 所有，如有侵权，请联系我们删除。