背景：
本菜鸟在造了一个extends了RichSinkFunction<ItemCountSum2>的MysqLsink class，想把Table中数据转换成指定对象的流，再sink入MysqL当中，又遇到一个当时难整的bug。
出现问题：
解决思路：
检查代码中是否有转换问题出错，然而并没有，继续尝试缩短错误范围，
发现并不是flatMap算子的问题，而是toRetractStream方法调用已经出现问题了。但是这个语句里面并没有显式的类型转换，那么我们就可以大概知道错误出在把table结果转换成流时，数据类型和给定的class里的数据类型出现了冲突。
解决方案：
1.可以尝试严格限制给定class的数据类型和table的类型保持一致。（=。=代码量大时有点麻烦，不建议）
2.先把表格数据转换成Row.class类的数据流，再从每一个Row中提取出所需要的数据，必要时对数据进行转换，再“输入”到自己定义的指定类中。（本人使用）
方便的是Row.class里Filed已经自动给您划分好，你直接用此方法就可以提取出想得到的字段的数据：
总的流程就是：
table ===> DataStream<Tuple2<Boolean,ItemCountSum2>>
===>DataStreamSink<ItemCountSum2>
table ===> DataStream<Tuple2<Boolean,Row>>
===> DataStreamSink<ItemCountSum2>
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
