栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

FlinkSQL 执行executeInsert方法,把结果写出到MySQL时,结果表和sink的表的字段顺序不一样导致错误

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

FlinkSQL 执行executeInsert方法,把结果写出到MySQL时,结果表和sink的表的字段顺序不一样导致错误

FlinkSQL 执行executeInsert方法,把结果写出到MySQL时,结果表和sink的表的字段顺序不一样导致错误

        Table result = tEnv.sqlQuery("select " +
                " edt w_end, " +
                " item_id, " +
                " ct item_count, " +
                " rn rk" +
                " from t2" +
                " where rn <= 3");
//        result.execute().print();
        // 5. 写出到Mysql中
        
        // 5.1 建立动态表与Mysql关联
        tEnv.executeSql("CREATE TABLE `hot_item` (n" +
                "  `item_id` bigint,n" +
                "  `w_end` timestamp ,n" +
                "  `item_count` bigint ,n" +
                "  `rk` bigint ,n" +
                "  PRIMARY KEY (`w_end`,`rk`)not enforcedn" +
                ")with(" +
                "   'connector' = 'jdbc',n" +
                "   'url' = 'jdbc:mysql://hadoop162:3306/flink_sql?useSSL=false',n" +
                "   'table-name' = 'hot_item',n" +
                "   'username' = 'root',n" +
                "   'password' = 'aaaaaa'" +
                ")  ");
        // 5.2 写出
        result.executeInsert("hot_item");
结论

FlinkSQL 执行executeInsert方法时,结果表和sink的表的字段顺序必须一致

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/975586.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号