概述
来源:大数据技术与架构
作者:王知无&林夕_Yume
大数据技术与架构
点击右侧关注，大数据开发领域最强公众号！
暴走大数据
点击右侧关注，暴走大数据！
By
大数据技术与架构
场景描述：Flink API废弃后的一个问题。
大家担心的终于来了。
问题
前两天群友反应了一个问题：
Flink1.9进行了数据类型的转化，
目前使用的Type被弃用，推荐使用Datatypes类型，但是之前使用的Type类型的方法对应的schema typeinformation没有对应的API，无法使用。
解决办法
整个问题的根本原因是废弃了一个tablesink的注册方法。
解决方案如下：
代码如下：
TableSink csvSink = new CsvTableSink("/path/to/file", "|");
String[] fieldNames = {"product", "amount"};
TypeInformation[] fieldTypes = {Types.STRING, Types.INT};
DataType[] newFieldType = {DataTypes.STRING(), DataTypes.INT()};
TypeInformation<?>[] newtypeInformations = TypeConversions.fromDataTypeToLegacyInfo(newFieldType);
// 也可以下面这样
//TypeInformation<?> str = LegacyTypeInfoDataTypeConverter.toLegacyTypeInfo(DataTypes.STRING());
//TypeInformation<?> integ = LegacyTypeInfoDataTypeConverter.toLegacyTypeInfo(DataTypes.INT());
//TypeInformation[] newTypInfo = {str, integ};
tableEnv.registerTableSink("RubberOrders", fieldNames, newtypeInformations, csvSink);
思考
没有最坑，只有更坑，请问Flink集群大家升级了几次了？
欢迎点赞+收藏+转发朋友圈素质三连
文章不错？点个【在看】吧！ ?
最后
以上就是整齐马里奥为你收集整理的一个Flink API的废弃引发的血案的全部内容，希望文章能够帮你解决一个Flink API的废弃引发的血案所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复