一.背景
自定义Sourc,采用elements方法
二.代码
env.fromElements("aa" , "aa","bb",3.0).print()
翻译了下报错:
三.解决办法
查看源码:
元素必须全部为“相同类型”
代码修改:
env.fromElements(("aa" , 1,2.0),("aa",1,9.2)).print()
运行结果:
4> (aa,1,2.0)
5> (aa,1.9,2)
Process finished with exit code 0
如果我的博客对你有帮助、如果你喜欢我的博客内容,可以点个赞哟
当然也可以加VX:LQ518123002,一起共同学习交流Flink。