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

2023-12-13 08:42:13

表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')

---

文章来源:https://blog.csdn.net/qq_35515661/article/details/134529967
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。