我正在尝试运行这个程序:[Flink CEP Monitoring][1]
[1]:https ://github.com/tillrohrmann/cep-monitoring在 Amazon EC2 上安装了 openjdk1.8 和 Flink 1.0.2。但是当我试图运行这个程序时,它会抛出以下异常:
缺少“地图”的泛型类型参数。您的编译器似乎没有将它们存储到 .class 文件中。目前,只有 Eclipse JDT 编译器保留了安全使用 lambdas 特性所需的类型信息。有关如何编译包含 lambda 表达式的作业的更多信息,请参阅文档。org.apache.flink.api.java.typeutils.TypeExtractor.validateLambdaGenericParameter(TypeExtractor.java:1316) org.apache.flink.api.java.typeutils.TypeExtractor.validateLambdaGenericParameters(TypeExtractor.java:1302) org.apache.flink。 api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:346) org.apache.flink.cep.PatternStream.select(PatternStream.java:64) org.stsffap.cep.monitoring.CEPMonitoring.main(CEPMonitoring.java: 95)
由于 Lambda 表达式,有什么方法可以用 Java 8 编译 Flink 程序吗?我该如何解决这个错误?