网络常识

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

    Thomas21432023年11月29日
    收录于话题
    #flinksql
    表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')

    ---

    相关信息

    你可能还喜欢

    热门推荐信息

    初识Dockerfile

    Byqq_58647543

    Dockerfile简介 从之前的学习中我们可以了解到：镜像的定制实际上就是定制每一层所添加的配置、文件。那么如果我们可以把每一层修改、安装、构建、操作的命令都写入一个脚本，用这个脚本来构建、定制镜像 ...