scala下Map算子报类型问題

来源：11-8 使用Flink完成实时日志清洗功能开发

杰夫斯基

2019-11-10

图片描述
使用Scala来实现日志分析，使用map加Lambda来实现时，运行时报了错。如截屏所示，是通不过静态类型检查。我的相关库版本是Flink1.7.2， Scala 2.12
拿过老师的源码，但Pom.xml缺少ES的依赖没法运行起来。

写回答

2回答

Michael_PK

2019-11-10

现在这代表没看出有啥问题，JDK版本是8吗？整个工程rebuild下，没用的导入都删除

Michael_PK

2019-11-10

你先把data输出，看里面是什么,是否有你需要的信息

杰夫斯基

Michael_PK

我就是不能解决才找老师。 Debug进去都是Scala和Flink内部的代码，我表示看不懂。值已经打印出来了，业务代码也很简单。异常的意思是无法根据代码推断Map返回值的结构，这个和实际运行值应该没有关系，从代码上可以推导出来：在map接受的参数里，x是字符串，因为Consumer读取到的就是字符串，而字符串的splits方法返回的是字符串数据，map函数返回值中，只是选择了其中几个，理论上是可以推导的。

2019-11-10

共5条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

查看课程

相似问题

Scala程序无法在idea里面运行，并且报错

回答 3

又出问题了

回答 1

Scala 有类似Java 的program arguments的程序参数吗

回答 1

flink1.9版直接运行出错

回答 2

JAVA的flatmap与scala的flatmap有区别吗

回答 1

打开慕课网App查看更多内容